C tube Nommé (fifo). Le processus Parent est coincé

Vous devriez vraiment vérifier la valeur de retour sur les appels de fonction pour les erreurs, en particulier mkfifo() et open().

Votre appel à wait() va causer des problèmes à son emplacement actuel. L'ouverture d'un FIFO pour la lecture bloque normalement jusqu'à ce qu'un autre processus ouvre la même FIFO pour l'écriture, et vice versa¹. Le parent est en attente de l'enfant à la fin et de l'enfant est en attente d'un processus de lecteur, c'est à dire, le parent, de se connecter à la FIFO.

^{1 - voir la note sur open() ci-dessous pour l'utilisation de O_NONBLOCK avec une FIFO}

Le déplacement de la wait() appel juste avant que le processus parent quitte avec la modification de la mode dans l'appel à mkfifo() à 0666 semble résoudre certains de vos problèmes immédiats.

Il est également conseillé de supprimer le FIFO lorsque vous avez terminé avec elle.

unlink("myfifo");

---

De la open() documentation des fonctions de la norme IEEE Std 1003.1-2004:

Lors de l'ouverture d'une FIFO avec O_RDONLY ou O_WRONLY ensemble:

• Si O_NONBLOCK est définie, un open() pour la lecture seule est de retour sans délai. Un open() pour l'écriture seule doit retourner une erreur si aucun processus qui a ouvert le fichier pour la lecture.

• Si O_NONBLOCK est clair, un open() pour la lecture seule est de bloquer le thread appelant jusqu'à ce qu'un thread ouvre le fichier en écriture. Un open() pour l'écriture seule peut bloquer le thread appelant jusqu'à ce qu'un thread ouvre le fichier en lecture.

---

L'exemple suivant est une combinaison de la code dans votre question initiale et la FIFO page de Beej Guide d'Unix à l'IPC:

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <unistd.h>
#define FIFO_NAME "myfifo"
int main(void)
{
char buf[256];
int num, fd;
pid_t pid;
if (mkfifo(FIFO_NAME, 0666) < 0)
perror("mkfifo");
pid = fork();
if (pid == 0)
{
printf("child - waiting for readers...\n");
if ((fd = open(FIFO_NAME, O_WRONLY)) < 0)
perror("child - open");
printf("child - got a reader -- type some stuff\n");
while (fgets(buf, sizeof(buf), stdin), !feof(stdin))
{
if ((num = write(fd, buf, strlen(buf))) < 0)
perror("child - write");
else
printf("child - wrote %d bytes\n", num);
}
close(fd);
exit(0);
}
else
{
printf("parent - waiting for writers...\n");
if ((fd = open(FIFO_NAME, O_RDONLY)) < 0)
perror("parent - open");
printf("parent - got a writer\n");
do
{
if ((num = read(fd, buf, sizeof(buf))) < 0)
perror("parent - read");
else
{
buf[num] = '\0';
printf("parent - read %d bytes: \"%s\"\n", num, buf);
}
} while (num > 0);
close(fd);
wait(0);
}
unlink(FIFO_NAME);
return 0;
}

Cet exemple a été testé sous Linux. Appuyez sur la touche Ctrl-D pour terminer le programme.