c - 使用 fifos 和管道的两个进程不想通信

Question

我目前正在学习 Linux 以及所有关于 fork、fifos、管道的东西。基本上，我想做的是让 2 个进程进行通信，这些进程与 2 个 fifos 通信 -> P1 向 P2 发送他 child 的 pid，这也是 P2 所做的。一旦他得到它，他就会将它发送给打印它的 child (通过管道)。 (+ child 通过第二个管道发回一个数字)

它编译没有错误，可以运行，但终端中什么也没有出现。好吧，如果不画它有点难以解释，这是第一个的代码:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <signal.h>
#include <sys/mman.h>
#include "erreur.c"
#include <fcntl.h> //Pour O_WDONLY etc

int pidProc1;
int pidProc2;
int pfd01[2];
int pfd10[2];

main()
{
if((pipe(pfd01)) == -1) erreur("pipe");
if((pipe(pfd10)) == -1) erreur("pipe");
switch(pidProc1 = fork())
{
case 0 : fils();
case -1 : erreur("fork");
}
pere();
}

pere()
{
int fd12;
int fd21;   
char * chaine;
int nb;
    // On fait les ouvertures des fifos
if ((fd12 = open ("fifo12", O_RDONLY) ) == -1 ) erreur ("Ouverture fifo12 en lecture");
if ((fd21 = open ("fifo21", O_WRONLY) ) == -1 ) erreur ("Ouverture fifo21 en ecriture");

if (read (fd12, &pidProc2, sizeof(int) ) == -1)erreur("aaaaaaaaaaaaaaaaa");
    printf("Je suis P1 %d et je recupere le pid du fils de P2 : %d \n",getpid(),pidProc2);

if ( write(fd21, &pidProc1, sizeof(int)) ==-1 ) erreur("bbbbbbbbbbbbbbb");
    printf("Envoi du pid de fils de P1 à P2 \n");

if(close(pfd01[0])==-1) erreur("close");

if ( write(pfd01[1], &pidProc2, sizeof(int)) ==-1 ) erreur("ccccccc");
    printf("Envoi du pid du fils de P2 à F1  \n");

if(close(pfd10[1])==-1) erreur("close");
if ( read(pfd10[0], &nb, sizeof(int)) ==-1 )    erreur("ddddddddddddd");
    printf("un numero!!! %d \n",nb);

}

fils()
{
if(close(pfd01[1])==-1) erreur("close");
if ( read(pfd01[0], &pidProc2, sizeof(int)) ==-1 )  erreur("dddddddddd");
    printf("Je suis le fils %d et j ai recu le pid du fils : %d",getpid(),pidProc2);

if(close(pfd10[0])==-1) erreur("close");
if ( write(pfd10[1], 7, sizeof(int)) ==-1 ) erreur("eee");
    printf("time for the son F1 to send something \n");

}

这是第二个:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <signal.h>
#include <sys/mman.h>
#include "erreur.c"
#include <fcntl.h> //Pour O_WDONLY etc

int pidProc1;
int pidProc2;
int pfd02[2];
int pfd20[2];
main()
{
if((pipe(pfd02)) == -1) erreur("pipe");
if((pipe(pfd20)) == -1) erreur("pipe");
switch(pidProc2 = fork())
{
case 0 : fils();
case -1 : erreur("fork");
}
pere();
}

pere()
{
int fd12;
int fd21;   
int nb;
    // On fait les ouvertures des fifos
if ((fd21 = open ("fifo21", O_RDONLY) ) == -1 ) erreur ("Ouverture fifo21 en lecture");
if ((fd12 = open ("fifo12", O_WRONLY) ) == -1 ) erreur ("Ouverture fifo12 en ecriture");

if ( read(fd21, &pidProc1, sizeof(int)) ==-1 )  erreur("bbbbbbbbbbbbbbb");
    printf("Je suis P2 %d et je recup l'id de l'autre fils tmtc : %d \n",getpid(),pidProc1);    

if (write (fd12, &pidProc2, sizeof(int) ) == -1)erreur("aaaaaaaaaaaaaaaaa");
    printf("Je suis P2 %d et je j'envoie le pid fils : %d \n",getpid(),pidProc2);


if(close(pfd02[0])==-1) erreur("close");
if ( write(pfd02[1], &pidProc1, sizeof(int)) ==-1 ) erreur("cccccc");
    printf("Envoi du pid du fils de P1 à F2 \n");


if(close(pfd20[1])==-1) erreur("close");
if ( read(pfd20[0], &nb, sizeof(int)) ==-1 )    erreur("dddddddddddd");
    printf("un numero!!! %d \n",nb);

}

fils()
{    
if(close(pfd02[1])==-1) erreur("close");
if ( read(pfd02[0], &pidProc1, sizeof(int)) ==-1 )  erreur("ddddddd");
    printf("Je suis le fils %d et j ai recu le pid fils : %d",getpid(),pidProc1);

if(close(pfd20[0])==-1) erreur("close");
if ( write(pfd20[1], 7, sizeof(int)) ==-1 ) erreur("eee");
    printf("time for the son F1 to send something \n");

}

抱歉这篇文章太长了!我正在学习，所以每个提示都值得赞赏!

编辑:对于那些可能会测试的人:这是我的 erreur.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <signal.h>
#include <sys/mman.h>
#include <fcntl.h> //Pour O_WDONLY etc...

void erreur (char *message)
{   char buffer[BUFSIZ];
    strcpy (buffer, strerror(errno));
    fprintf (stderr, "Erreur: %s\terrno=%d (%s)\n", message, errno, buffer);
    exit(1);
}

Answer 1

我将第一个代码作为 a，第二个作为 b

您的代码中有 2 个死锁:

1. 当打开 fifo 时，打开和写入应该匹配，否则它将永远阻塞，除非将 O_NONBLOCK 添加到打开模式。您可能想使用 man fifo

   查看 fifo 的手册页

   FIFO 必须打开 两端(读和写)才可以传递数据。
   通常，打开 FIFO block 直到另一端也打开。

   所以如果 a 中的代码是:

   if ((fd12 = open ("fifo12", O_RDONLY) ) == -1 ) erreur ("Ouverture fifo12 en lecture");
   if ((fd21 = open ("fifo21", O_WRONLY) ) == -1 ) erreur ("Ouverture fifo21 en ecriture");
   

   在 b 代码中应该是(注意它在你的代码中是相反的)

   if ((fd12 = open ("fifo12", O_WRONLY) ) == -1 ) erreur ("Ouverture fifo12 en ecriture");
   if ((fd21 = open ("fifo21", O_RDONLY) ) == -1 ) erreur ("Ouverture fifo21 en lecture");
   

2. 读和写应该匹配，在你的代码中 a 和 b 尝试从 fifo 读取而没有人写入它，所以死锁。

   如果 a 中的代码是:

   if (read (fd12, &pidProc2, sizeof(int) ) == -1)erreur("aaaaaaaaaaaaaaaaa");
       printf("Je suis P1 %d et je recupere le pid du fils de P2 : %d \n",getpid(),pidProc2);
   if ( write(fd21, &pidProc1, sizeof(int)) ==-1 ) erreur("bbbbbbbbbbbbbbb");
       printf("Envoi du pid de fils de P1 à P2 \n");
   

   在 b 代码中应该是:(它在你的代码中是相反的)

   if (write (fd12, &pidProc2, sizeof(int) ) == -1)erreur("aaaaaaaaaaaaaaaaa");
       printf("Je suis P2 %d et je j'envoie le pid fils : %d \n",getpid(),pidProc2);
   if ( read(fd21, &pidProc1, sizeof(int)) ==-1 )  erreur("bbbbbbbbbbbbbbb");
       printf("Je suis P2 %d et je recup l'id de l'autre fils tmtc : %d \n",getpid(),pidProc1);