/* 
 * Programme demandant l'entrée d'un nombre et calculant la fonction
 * f(x) = 2*x + 1
 * Le programme s'arrête une fois qu'on a tapé -1
 */

#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>

/* Definition des tubes de communication */
int p_a1[2];
int a1_a2[2];
int a2_p[2];

void a1(){
  int x;
  int resultat;

  do {
    read(p_a1[0], &x, sizeof(x));
    if (x != -1) {
      resultat = 2*x;
    }
    else {
      resultat = x;
    }
    write(a1_a2[1], &resultat, sizeof(resultat));
  }while(x != -1);
}

void a2(){
  int resultat;
  int nouveauResultat;
  do {
    read(a1_a2[0], &resultat, sizeof(resultat));
    if (resultat != -1) {
      nouveauResultat = resultat + 1;
      write(a2_p[1], &nouveauResultat, sizeof(nouveauResultat));
    }
  } while (resultat != -1);    
}

void parent(){
  int x, reponse;

  do {
    printf("Entrez un entier (ou -1 pour arreter le programme)\n");
    scanf("%d", &x);
    write(p_a1[1], &x, sizeof(x));
    if (x != -1){
      read(a2_p[0], &reponse, sizeof(reponse));
      printf("f(%d) = %d\n\n", x, reponse);
    }
  } while (x != -1);
}

int main(){
  int pid;

  /* Initialisations des tubes */
  if (pipe(p_a1)<0) {
    perror("pipe");
    exit(1);
  }
  if (pipe(a1_a2)<0) {
    perror("pipe");
    exit(1);
  }
  if (pipe(a2_p)<0) {
    perror("pipe");
    exit(1);
  }
  /* Fork des enfants */
  pid = fork();
  switch(pid){
  case -1:
    perror("echec de fork");
    exit(1);
  case 0:
    /* enfant A1 */
    close(p_a1[1]);
    close(a1_a2[0]);
    close(a2_p[0]);
    close(a2_p[1]);
    a1();
    close(p_a1[0]);
    close(a1_a2[1]);
    break;
  default:
    /* parent */
    close(p_a1[0]);
    close(a1_a2[1]);
    pid = fork();
    switch(pid){
    case -1:
      perror("echec de fork");
      exit(1);
    case 0:
      /* enfant A2 */
      close(p_a1[1]);
      close(a2_p[0]);
      a2();
      close(a1_a2[0]);
      close(a2_p[1]);
      break;
    default:
      /* parent */
      close(a1_a2[0]);
      close(a2_p[1]);
      parent();
      close(p_a1[1]);
      close(a2_p[0]);
    }
  }
  return 0;
}