#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <sys/wait.h>

/* versione con N pipe */

/* tipo che definisce una pipe */
typedef int pipe_t[2];

int main(int argc, char *argv[])
{
  int pid;	/* pid per fork */
  int N; 	/* numero di caratteri e quindi numero di processi */
  int fdr; 	/* per open */
  int i, k; 	/* indici */
  int cont;	/* per conteggio */
  char c;	/* per leggere dal file */
  pipe_t *p; 	/* array dinamico di pipe */
  int pidFiglio, status, ritorno;    /* variabili per wait*/
  
  if (argc < 3)
  {
    printf("Errore nel numero dei parametri\n");
    exit(1);
  }

  /* numero dei caratteri passati sulla linea di comando */
  N = argc - 2;
  
  /* controllo singoli caratteri */
  for (i=0; i < N; i++)
    if (strlen(argv[i+2]) != 1)
    { printf("Errore nella stringa %s che non e' un singolo carattere\n", argv[i+2]); 
      exit(1);
    }

  /* alloco l'array di pipe */
  p = (pipe_t *)malloc(sizeof(pipe_t) * N);
  if (p == NULL) 
  { printf("Errore nella creazione array dinamico\n");
      exit(1);
  }
  
  /* creo N pipe */
  for (i=0; i < N; i++)
    if (pipe(p[i]) < 0)
    { printf("Errore nella creazione della pipe\n"); 
      exit(1);
    }
 
  printf("Sono il processo padre con pid %d e sto per generare %d figli\n", getpid(), N);
              
  for (i=0; i < N; i++)
  {
    /* creazione dei figli */
    if ((pid = fork()) < 0)
    {
      printf ("Errore nella fork\n");
      exit(1);
    }
    
    if (pid == 0) /* figlio */
    {
      printf("Figlio %d con pid %d\n", i, getpid());
  
      /* chiude tutte le pipe che non usa */
      for (k = 0; k < N; k++)
      {
        close(p[k][0]);
        if (k != i)
          close(p[k][1]);
      }
      
      /* apre il file */
      if ((fdr = open(argv[1], O_RDONLY)) < 0)
      { printf("Errore nella apertura del file %s\n", argv[1]);
        exit(-1);
      }
      cont = 0;
      /* conta le occorrenze del carattere assegnato */
      while(read(fdr, &c, 1) > 0)
      {
        if (c == argv[i+2][0])
          cont++;
      }
      /* comunica al padre usando la i-esima pipe */
      write(p[i][1], &cont, sizeof(cont));
      exit(0);
    }
  }
  
  /* padre */
  /* chiude tutte le pipe che non usa */
  for (k=0; k < N; k++)
  {
    close(p[k][1]);
  }
  /* legge dalle pipe i messaggi */
  for (i=0; i < N; i++)
  {
    if (read(p[i][0], &cont, sizeof(int)) > 0)
      printf("%d occorrenze del carattere %c nel file %s\n", cont, argv[i+2][0], argv[1]);
  }
  /* Attesa della terminazione dei figli */
  for(i=0;i < N;i++)
  {
   pidFiglio = wait(&status);
   if (pidFiglio < 0)
   {
      printf("Errore wait\n");
      exit(9);
   }
   if ((status & 0xFF) != 0)
                printf("Figlio con pid %d terminato in modo anomalo\n", pidFiglio);
   else
   {
                ritorno=(int)((status >> 8) & 0xFF);
                printf("Il figlio con pid=%d ha ritornato %d (se 255 problemi!)\n", pidFiglio, ritorno);
   }
  } 
  exit(0);                                              
}