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

#define PERM 0644 /* in UNIX */

typedef int pipe_t[2]; 

int main(int argc, char **argv)
{ 
	/* Local variables */
	int N;		/* numero di argomenti come file */
	int i, j;		/* variabile ausiliaria per i loop */
	int pid;		/* process identifier di supporto */	
	int status;		/* variabile per lo stato della wait */
	int Fi; 		/* file descriptor per ognuno dei file passati */
	pipe_t *piped;	/* descrittori delle N pipe */
	int occ;		/* contatore delle occorrenze di C*/
	int occ_prev;	/* occorrenze del figlio precedente */
	char C;		/* carattere argv[argc-1][0] salvato per comodita'  */
	char ch;		/* buffer per la lettura da file */
	/* ----------------*/

	/* Controllo sul numero dei parametri */
	N=argc-2; /* Tolgo argv[0] e argv[argc-1]*/
	if( (N < 2) || ( N%2 != 0))
	{
		printf("Errore nel numero dei parametri. Uso: %s f1 f2 ... fN C \n",argv[0]);
		exit(-1);
	}
	
	C=argv[argc-1][0];
	
	/* Creazione delle pipe per la comunicazioni tra i figli e alla fine con il padre */
	piped = (pipe_t *) malloc(N*sizeof(pipe_t));
	if(piped==0)
	{
		printf("Errore nella malloc\n");
		exit(-2);
	}
	
	/* creazione delle N pipe */
	for(i=0; i<N; i++)
		if(pipe(piped[i])<0)
		{
			printf("Errore nella creazione delle pipe\n");
			exit(-3);	
		}		
		
	/* ciclo di creazione degli N figli */ 
	for (i=0; i<N; i++)
	{
		if((pid=fork())<0) 
		{
			printf("Errore nella creazione di un figlio\n");
			exit(-2);
		}
		else if(pid == 0) /*codice del figlio*/
			break; /* esco dal ciclo */
	} /* file ciclo for */


	if(pid==0) /*codice del figlio*/
	{
		/* Chiudo lati pipe che non utilizzo*/
		/* Figlio i scrive su pipe i e legge da pipe i-2 (se i>1)*/
		for (j=0; j<N; j++)
		{
			if(j!=i)
				close(piped[j][1]);
			if(i<2) /* primi due figli di entrambi i tipi */
				close(piped[j][0]);
			else
				if(j!=i-2)
					close(piped[j][0]);				
		}
		
		printf("Sono figlio con PID %d e apro il mio file %s\n", getpid(), argv[i+1]);

		/* Apro il file associato "Fi" per leggere */
		if((Fi=open(argv[i+1], O_RDONLY))<0)
		{
			printf("Errore nella apertura del file \"%s\"\n", argv[i+1]);
			exit(-5);
		}
				
		if(i%2!=0) /*figlio di tipo dispari --> fai prima lettura a vuoto */
			read(Fi, &ch, 1);
			
		occ=0;		
		while(read(Fi, &ch, 1)>0) /* qui i due tipi di figli sono allineati al loro primo carattere utile*/
		{
			if (ch == C)
				occ++;
			/* Altra lettura a vuoto per saltare il prossimo carattere */
			read(Fi, &ch, 1);
		}

		/* occ contiene ora il numero di occorrenze trovate fino all'EOF*/
		if(i>1) /* ad esclusione dei primi due figli */
		{
			/* aspetto il conteggio dal mio fratello precedente */
			read(piped[i-2][0], &occ_prev, sizeof(int));						
		}	
		else
			occ_prev=0;
		
		/* ci sommo le mie occorrenze ...*/
		occ_prev+=occ; 
		
		/*... e spedisco al successivo (al padre se sono ultimo o penultimo)*/
		write(piped[i][1], &occ_prev, sizeof(int));
			
		/* ritorno le occorrenze mie al padre */
		exit(occ);
	}

	/* codice del padre */
	
	/* Chiude le pipe che non utilizza */
	for(i=0; i<N; i++)
	{
		close(piped[i][1]);
		if(N-i<2) /* lascio aperti i lati lettura dei due ultimi figli */
			close(piped[i][0]);
	}
	
	for(i=N-1; i>=N-2; i--)
	{
		read(piped[i][0], &occ, sizeof(int));
		printf(" Figlio di indice %d ha tornato conteggio totale %d\n", i, occ);
	}
		
	for (i=0; i<N; i++)
	{
		pid=wait(&status);
		printf("Il figlio con PID %d �ritornato con valore %d\n", pid, (status>>8)&0xFF);
	}
exit(0);
}