You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
93 lines
2.5 KiB
93 lines
2.5 KiB
#include <unistd.h>
|
|
#include <errno.h>
|
|
#include <sys/wait.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
|
|
#define TAILLE_BUF 80 // 80 = taille d'une ligne
|
|
|
|
void fermeTubesFils(int N, int tubes[N][2]) {
|
|
for (int i = 0; i < N; i++) {
|
|
close(tubes[i][1]);
|
|
}
|
|
}
|
|
|
|
void codeDuFils(int N, int tubes[N][2], int numFils) {
|
|
char buffer[TAILLE_BUF];
|
|
unsigned int cpt = 0;
|
|
|
|
close(tubes[numFils][1]); // Fermer l'extrémité d'écriture inutile du tube
|
|
|
|
while (read(tubes[numFils][0], buffer, TAILLE_BUF) > 0) {
|
|
cpt++;
|
|
printf("\t\e[1;33mFils n° %d : %d : lecture de\e[1;31m %s\e[0m\n", numFils, cpt, buffer);
|
|
}
|
|
|
|
printf("Fils se termine sur fin de lecture du tube\n");
|
|
close(tubes[numFils][0]);
|
|
exit(0);
|
|
}
|
|
|
|
void codeDuPere(int N, int tubes[N][2], int i) {
|
|
char buffer[TAILLE_BUF];
|
|
close(tubes[i][0]); // Fermer l'extrémité de lecture inutile du tube
|
|
|
|
while (fgets(buffer, TAILLE_BUF, stdin) != NULL) {
|
|
int dest_process;
|
|
char text[TAILLE_BUF];
|
|
if (sscanf(buffer, "%d %[^\n]", &dest_process, text) == 2 && dest_process >= 0 && dest_process < N) {
|
|
// Écriture du texte dans le tube du processus destinataire approprié
|
|
write(tubes[dest_process][1], text, strlen(text));
|
|
} else {
|
|
fprintf(stderr, "Message invalide (il faut mettre le numero du fils en 1er) : %s", buffer);
|
|
}
|
|
}
|
|
|
|
fermeTubesFils(N, tubes);
|
|
for (int j = 0; j < N; j++) {
|
|
wait(NULL); // Attendre que tous les fils se terminent
|
|
}
|
|
|
|
printf("Père se termine après ses fils.\n");
|
|
exit(EXIT_SUCCESS);
|
|
}
|
|
|
|
int main(int argc, char *argv[]) {
|
|
int i, N;
|
|
pid_t pid;
|
|
int tubes[100][2];
|
|
|
|
if (argc != 2) {
|
|
fputs("Donnez un argument entier.\n", stderr);
|
|
exit(1);
|
|
}
|
|
|
|
N = atoi(argv[1]);
|
|
if (N <= 0 || N > 100) {
|
|
fprintf(stderr, "N doit être un entier positif ou inférieur à 100.\n");
|
|
exit(1);
|
|
}
|
|
|
|
// Créez les tubes pour la communication entre les processus
|
|
for (i = 0; i < N; i++) {
|
|
if (pipe(tubes[i]) == -1) {
|
|
perror("pipe");
|
|
exit(errno);
|
|
}
|
|
}
|
|
|
|
/* Le père va créer N fils */
|
|
for (i = 0; i < N; i++) {
|
|
if ((pid = fork()) == -1) {
|
|
perror("pb fork");
|
|
exit(errno);
|
|
} else if (pid == 0) {
|
|
codeDuFils(N, tubes, i); // Code du fils
|
|
}
|
|
}
|
|
|
|
codeDuPere(N, tubes, 0); // Code du père (utilisation du premier tube)
|
|
return 0;
|
|
}
|