Utilisation des fork et des pipes

**akrogames** · 20/10/2009, 18h28

Bonjour à tous j'essaye de faire circuler un entier sur un anneau à 5 noeuds. Le premier fils
l'initialise, il s'incrémente sur chaque site. lorsque le fils 1 reçoit
un jeton dont la valeur est supérieure à 50 il gère la terminaison de
ses frères et du père.
Le problème c'est que là il me fait n'importe quoi et je ne sais pas très bien pourquoi ? Une petite aide serait la bienvenue.

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
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
 
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
 
#define lire 0
#define ecrire 1
 
int i;
int nbClient;
int status;
 
int main(int argc, char **argv)
{
 
//Initialisation des variables
nbClient = atoi(argv[1]);
int tube[nbClient][2];
int pid[nbClient];
 
 
//Creation des tubes
for(i=0;i<nbClient;i++)
{
	pipe(tube[i]);
}
 
 
//Creation des processus
for(i=0;i<nbClient;i++)
{
 
	switch(fork())
	{
	case 0:
		pid[i] = getpid();
		close(tube[i][lire]);
		close(tube[((i-1)%nbClient)][ecrire]);
		int jeton;
 
		if(i==0)
		{
			jeton=0;
			printf("Client Numero : %d(%d) => Envoie du jeton : %d\n",i+1,getpid(),jeton);
			write(tube[i][ecrire],&jeton,sizeof(jeton));
		}
 
		do
		{
			read(tube[((i-1)%nbClient)][lire],&jeton,sizeof(jeton));
			//printf("Processus: %d => Lecture du jeton : %d\n",getpid(),jeton);
			//printf("Client Numero : %d => PID : %d\n",i+1,pid[i]);
 
			if(jeton < 10)
			{
 
				jeton++;
				printf("Processus: %d => Envoie du jeton : %d\n",getpid(),jeton);
				write(tube[i][ecrire],&jeton,sizeof(jeton));
			}
			else
			{
 
			}
 
		} while(jeton < 10);
 
			close(tube[((i-1)%nbClient)][lire]);
			write(tube[((i-1)%nbClient)][ecrire],&jeton,sizeof(jeton));
 
		close(tube[i][ecrire]);
		close(tube[((i-1)%nbClient)][lire]);
 
		exit(i);
		break;
 
	case -1:
		printf("Probleme dans la creation du processus\n");
		exit(EXIT_FAILURE);
 
	/*default:
		printf("");*/
	}
}
 
//Attente des processus
for(i=0;i<nbClient;i++)
{
	wait(&status);
	//printf("Mise en attente du processus : %d\n",&status);
}
 
 
 
return EXIT_SUCCESS;
 
}

Bonne soirée

**fredremy68** · 20/10/2009, 22h55

Salut,

Je te conseille de revoir ton algo.

Déjà le jeton n'atteindra jamais 50 puisqu'il est incrémenter si il est <10.

Ton code fait que chaque fils écrit 10 fois le jeton. Rien à voir avec ton énoncé.

Bon travail

Fred

**akrogames** · 21/10/2009, 08h36

Bah avant de mettre 50 j'ai mis 10 c'est pour sa

Sinon oui en effet cela affiche pour chaque processus 10 fois...
Mais comment faire alors ?

C'est cela la question...

Un petit coup de pouce serait le bienvenue...

Bonne journée

**fredremy68** · 21/10/2009, 11h50

Dans ton switch case 0: tu fait ta boucle do while. Elle est faite pour chaque processus fils. Donc chaque fils affiche 10*.

Mais en fait à quoi te sert cette boucle?

Pour moi l'algo de base serait:

1) créer les tubes:
tube0 fils 0 vers 1
tube1 fils 1 vers 2
tube2 fils 2 vers 3
tube3 fils 3 vers 4
tube4 fils 4 vers 0

2) créer les fils.
le père fork 5 * et attend.

3) Travail des fils:
3.1)si on est le premier fils. Ecrire jeton dans tube 0 puis attendre sur lecture tube 4: si jeton = 50 arret sinon incrémenter jeton et le mettre dans tube 0.
3.2) Si on est un autre fils: attendre sur lecture puis incrémenter jeton et écrire

Fred

**fredremy68** · 21/10/2009, 13h52

Une solution rapide et pas optimale à ton problème... Je culpabilise un peu de faire tes exercices mais bon...

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
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
66
67
68
69
70
71
72
73
74
75
76
#include <stdio.h>
#include <stdlib.h>
#include <sys/wait.h>
#include <unistd.h>
#include <sys/types.h>
#include <string.h>
 
#define lire 0
#define ecrire 1
#define Nbclient 5
 
int tube[Nbclient][2];
 
void premierfils(void){
 
    close (tube[0][lire]);
    close (tube [Nbclient-1][ecrire]);
 
    int jeton = 0;
 
    while (jeton <50){
        write (tube[0][ecrire],&jeton,sizeof(int));
        printf ("Ecriture de fils 0 jeton %d \n",jeton);
        read (tube[Nbclient-1][lire],&jeton,sizeof(int));
        jeton++;
    }
    jeton = -1;
    write (tube[0][ecrire],&jeton,sizeof(int));
    exit(EXIT_SUCCESS);
 
}
 
void autrefils(int numero){
 
    close (tube[numero][lire]);
    close (tube[numero-1][ecrire]);
 
    int jeton = 0;
 
    while (jeton != -1){
        read (tube[numero-1][lire],&jeton,sizeof(int));
        write (tube[numero][ecrire],&jeton,sizeof(int));
        printf ("Ecriture de fils %d jeton %d \n",numero,jeton);
    }
 
    exit(EXIT_SUCCESS);
 
}
 
 
int main (int argc, char * argv[]){
 
int pid;
 
// creation des tubes
 
int i;
 
for (i=0;i<Nbclient;i++) pipe(tube[i]);
 
for (i=0;i<Nbclient;i++){
 
    pid = fork();
 
    if (pid==0){
 
        if (i==0) {premierfils();} else {autrefils(i);}
 
    }
}
 
for (i=0;i<Nbclient;i++) wait(0);
 
exit(0);
 
}

**akrogames** · 21/10/2009, 16h51

Coucou Merci de votre aide.

J'ai tester ton programme fredremy68 mais le problème c'est que le jeton s'incrèmente pas sur chaque fils... Tu vois ce que je veux dire ?
Il s'incrémente à chaque tour.

Cela dit je vais prendre exemple sur ton code car il est pas mal. Oh tu sais je suis pas très fort en C alors ne culpabilise pas trop

**fredremy68** · 21/10/2009, 19h18

A d'accord, je le modifie pour avoir un incrément à chaque fils, essaye quand même de le comprendre..

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
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
66
67
68
69
70
71
72
73
74
75
76
77
#include <stdio.h>
#include <stdlib.h>
#include <sys/wait.h>
#include <unistd.h>
#include <sys/types.h>
#include <string.h>
 
#define lire 0
#define ecrire 1
#define Nbclient 5
 
int tube[Nbclient][2];
 
void premierfils(void){
 
    close (tube[0][lire]);
    close (tube [Nbclient-1][ecrire]);
 
    int jeton = 0;
 
    while (jeton <50){
        write (tube[0][ecrire],&jeton,sizeof(int));
        printf ("Ecriture de fils 0 jeton %d \n",jeton);
        read (tube[Nbclient-1][lire],&jeton,sizeof(int));
        jeton++;
    }
    jeton = -1;
    write (tube[0][ecrire],&jeton,sizeof(int));
    exit(EXIT_SUCCESS);
 
}
 
void autrefils(int numero){
 
    close (tube[numero][lire]);
    close (tube[numero-1][ecrire]);
 
    int jeton = 0;
 
    while (jeton != -1){
        read (tube[numero-1][lire],&jeton,sizeof(int));
        jeton++; // incremente a chaque fils
        write (tube[numero][ecrire],&jeton,sizeof(int));
        printf ("Ecriture de fils %d jeton %d \n",numero,jeton);
    }
 
    exit(EXIT_SUCCESS);
 
}
 
 
int main (int argc, char * argv[]){
 
int pid;
 
// creation des tubes
 
int i;
 
for (i=0;i<Nbclient;i++) pipe(tube[i]);
 
for (i=0;i<Nbclient;i++){
 
    pid = fork();
 
    if (pid==0){
 
        if (i==0) {premierfils();} else {autrefils(i);}
 
    }
}
 
for (i=0;i<Nbclient;i++) wait(0);
 
exit(0);
 
}

**akrogames** · 22/10/2009, 19h22

Coucou !

Encore merci de m'avoir m'aidé mais je n'arrive pas à comprendre quelque chose...
A la fin de l'exécution du programme il se s'arrête pas normalement. J'ai pourtant essayé de l'arrêter en mettant des closes et des exit un peu partout...

Mais rien y fait ? Une idée ?

Utilisation des fork et des pipes

Réseau C

Discussions similaires

Partager

Partager