Discussion :

[mansour67]

bonsoir, je veux creer npipes et n processus , dans mon cas je vais prendre 4 pipes .. je lis sur l'entrée strandard et j'ecris dans le premier tube et ainsi de suite jusqu'au dernier qui ecrit sur la sortie standard.

voici mon code . est 'il correct car quand je l'execute il me donne pas la main pour introduire une donnée avec le clavier(entrée standard).

Code C :

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <sys/wait.h> 
 
int main() {
 
int n,i=0, t[2];
char buffer [512];
 
for(i;i>4;i++)
 
{
 
	/*creer le tube*/
 
	  if (pipe(t) == -1){  
		perror("pipe"); 
		exit(1);
  		 }
	printf("Le tube %d\n",i);
 
 
       /*dupliquer un processus*/
 
	switch(fork()){
		case -1:
			{
			printf("erreur\n"); 
			exit(1);
			}
 
		case 0 : /*fils*/
 
			/*fermer la sortie du tube*/
			 close (t[1]);
			/* lecture du tube*/
                         while ((n=read(t[0],buffer,sizeof(buffer)))>0)
			/*ecriture sur la sortie standard*/
			 write(1,buffer,n);
			/*fermer la sortie du tube*/
			close(t[0]);
			exit(0);
 
 
		default: /*le père*/
 
			/*fermer la sortie du tube*/
			close (t[0]);
 
			/*lecture de l'entrée standard*/
			while((n=read(1,buffer,sizeof(buffer)))>0)
			/*ecriture dans le tube*/
			write(t[1],buffer,n);
			/*fermer l'entrée du tube*/
			close(t[1]);
 
 
 
		}
 
}
exit(EXIT_SUCCESS);
 
}

merci d'avance

[Sve@r]

J'ai l'impression que t'as récupéré un code de communication à un pipe entre 2 processus et que t'as essayé de l'adapter à 4 processus en le mettant dans une boucle (et ça foire de suite ne serait-ce que parce que tu n'as qu'un seul pipe "t" et non 4 comme tu le dis)

Commence d'abord par faire marcher ton code à un pipe. Il est d'ailleurs presque parfait (faut juste ne pas le mettre dans une boucle). Et analyse son fonctionnement
- le père ferme le coté lecture de son pipe et écrit dans le coté écriture
- le fils ferme le coté écriture et lit le coté lecture

Ensuite, une fois que t'auras bien pigé le truc, adapte-le à 4 processus (te faudra 3 tubes et non un seul) avec chaque processus "p" qui écrit sur son tube "p" et qui va lire le tube "p - 1" ce qui donne
- le père (processus 0) écrit sur le tube [0]
- le fils 1 lit le tube[0] et écrit sur le [1]
- le fils 2 lit le tube[1] et écrit sur le [2]
- le fils 3 lit le tube[2] et écrit sur l'écran
Bien sûr, chaque tube[n] possède lui-même un cote[0] et un cote[1]. Je serais d'ailleurs d'avis de créer le type "pipe" ce qui te permettrait de pas te mélanger les pinceaux entre "tableau de pipes" et "tableau des cotés"

Code C :

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

1
2
3
4
5
6
7
8
9
10
11
12
typedef struct {
    int cote[2];
} t_pipe;
 
int main()
{
    t_pipe tabPipe[3];
    size_t i;
 
    for (i=0; i < 3; i++)
         pipe(tabPipe[i]);
}

Ensuite, faut créer les 3 fils

Code :

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

1
2
3
4
5
6
7
8
9
for (i=0; i < 4; i++)
{
     if (fork() == 0)
     {
          // on est dans le fils => gestion du processus
          processus(i, tabPipe); 
          exit(0);
     }
}

Ensuite à toi de définir la fonction "processus()" qui sera dévolue à un processus quel qu'il soit. Faut bien entendu te rappeler que le processus(n) va lire le pipe "n - 1" et écrire sur le pipe "n" (donc ils n'ont pas besoin des pipes qui ne sont pas "n" ou "n -1"). Par exemple, la fonction peut démarrer comme ça

Code C :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
void processus(int n, t_pipe tabPipe[3])
{
    size_t i;
    for (i=0; i < 3; i++)
    {
         if ((i + 1) != n)
              close(tabPipe[i][0]);
         if (i != n)
              close(tabPipe[i][1]);
    }
 
     ... ensuite à toi de voir (je vais pas tout te faire quand-même...)
}