Discussion :

[rdtech]

Bonjour,
je fais communiquer deux processus par tube nommé.
Le processus lecteur:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
int main()
{
    int retour, fd, nb;
    char data;
 
    retour = mkfifo("canal.fifo", 0600);
    if(retour < 0) {
        perror("mkfifo");
        exit(EXIT_FAILURE);
    }
 
    fd = open("canal.fifo", O_RDONLY);
    if(fd < 0) {
        perror("open");
        exit(EXIT_FAILURE);
    }
 
    printf("Le consommateur lit...\n");
    do {
		nb = read(fd, &data, 1);
		if(nb > 0)
			printf("%c", data);
    }while(nb > 0);
 
    close(fd);
	unlink("canal.fifo");
    exit(EXIT_SUCCESS);
}

Le processus écrivain:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
int main()
{
    int fd;
    char msg[64];
 
    fd = open("canal.fifo", O_WRONLY);
    if(fd < 0) {
        perror("open");
        exit(EXIT_FAILURE);
    }
 
    do
	{
		puts("Entrez un message: ");
		scanf("%s", msg);
		while(getchar() != '\n');
		if(msg[0] == 'q')
			break;
		write(fd, msg, strlen(msg)+1);
	}while(1);
    close(fd);
    exit(EXIT_SUCCESS);
}

Cela fonctionne à ceci près qu'il faut que je quitte l'écrivain qui fait donc un close(fd) pour que le lecteur soit débloquer de son read() et lise toutes les données accumulées dans le tube.
Est-ce qu'il faut flusher après un write() ou ai-je mal écrit?

Merci.

[rdtech]

Bonjour,
je me répond à moi-même.
Je m'en sors en faisant systématiquement des open/write/close pour transmettre mes données. Mais ça me semble incohérent pour un fonctionnement de type fifo. Ce qui est écrit devraient être automatiquement disponible à l'autre bout.
Me trompe-je?

Merci.

[Bousk]

close va faire un flush. Oui il faut faire un flush après write pour que les données soient disponibles en read à côté. C'est une optimisation pour l'écriture : on écrit plein de choses, puis on flush.

[rdtech]

Bonjour,
merci pour la réponse.
Mon appli a une architecture similaire à celle d'un client/serveur dans le sens où un processus est en écoute permanente sur le tube nommé.
Le processus "client" s'y connecte au lancement et envoie des données tant que nécessaire puis il s'arrête en faisant un close sur le descripteur du tube.
Mon pb: cela ferme le tube et le processus client stoppe (puisqu'il n'y a plus d'écrivain?).
Question: un processus peux t-il se déconnecter d'un tube sans qu'il se ferme?

Merci.