init-acces-concurrent.c

Aller à la documentation de ce fichier.

 
#include <manux/types.h>
#include <stdio.h>
#include <manux/errno.h>
#include <unistd.h>   // creerNouvelleTache
#include <manux/string.h>
 
#define TAILLE_BUFFER 16
 
#define NB_LECTEURS  2
#define NB_ECRIVAINS 2
 
int fd[2];  // Le tube
 
void lecteur()
{
   int r, c=0;
   char b[TAILLE_BUFFER];
   
   printf("[%d] Je suis un lecteur !\n", identifiantTache());
   fermer(fd[1]);
   
   do {
      r = lire(fd[0], b, TAILLE_BUFFER - 1);
      printf("[%d] lecture %d\n", identifiantTache(), r);
      if (r > 0) {
         b[r] = 0;
         printf(b);
         c += r;
      } else if (r < 0){
    printf("[%d] Erreur lecture\n", identifiantTache());
      }
   } while (r > 0);
 
   printf("\n[%d] Fini ... En tout, j'ai lu %d !\n", identifiantTache(), c);
}
 
void ecrivain()
{
   int r, c  = 0;
   
   char * b = "Bonjour les jeunes ! ";
 
   printf("[%d] Je suis un ecrivain !\n", identifiantTache());
   fermer(fd[0]);
 
   do {
     printf("[%d] Je vais ecrire %d\n", identifiantTache(), strlen(b));
      r = ecrire(fd[1], b, strlen(b));
      printf("[%d] Voila j'ai ecrit %d\n", identifiantTache(), r);
      if (r >= 0) {
         c += r;
      } else {
         printf("[%d] Erreur ecriture\n", identifiantTache());
      }
   } while (r > 0);
 
   printf("[%d] En tout, j'ai ecrit %d !\n", identifiantTache(), c);
 
   fermer(fd[1]);
}
 
void init()
{
  int r, l, e;
 
   printf("Bonjour le mode utilisateur !\n");
 
   r = tube(fd);
 
   if ( r != ESUCCES) {
      printf("r = %d : casse la pipe !?\n", r);
   } else {
      for (e = 0; e < NB_ECRIVAINS; e++) {
         r = creerNouvelleTache(ecrivain, FALSE);
      }
      for (l = 0; l < NB_LECTEURS; l++) {
         r = creerNouvelleTache(lecteur, FALSE);
      }
   }
   fermer(fd[0]);
   fermer(fd[1]);
   printf("Voila voila !\n");
   while(1){};
}