#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <string.h>
/*Esame 11 Luglio 2012*/

/*Tipo di Dato pipe*/
typedef int pipe_t[2];
/*Dichiarazione Esplicita Funzione Figlio*/
int figlio(char *Fi,int indice);

/*Variabili Globali*/
int K; /*Numero passato come ultimo Parametro*/
int N; /*Numero di file passati come parametri*/
int dim,retval;
int pid;/*PID per creazione figli*/
char Fout[256];/*Nome file creato dal padre*/
int fdout;/*File decriptor file Fout*/
char Media[12];/*Stringa contenente la scritta Equal-Sopra-Sotto Media*/
char str[256];/*Stringa di appoggio per scrittura in stdout*/
pipe_t *pfd_p;
pipe_t *pfd_f;
/*NOTA:Si utilizzano 2N pipe !!*/
/*N pipe pfd_p per la comunicazione figli-padre*/
/*N pipe pfd_f per la comunicazione padre-figli*/

int main(int argc,char **argv ){
	/*Variabili Locali*/
	int i,st;
	long int cont_ch;/*Variabile long int per lettura da pipe pfd_f*/

	/*Controllo numero parametri*/
	dim=argc-1;
	if (dim<3){
		snprintf(str,256,"USO scheletro F1 F2 FN M \n");
		write(1,str,strlen(str));
		return(1);
	}

	/*Controllo sul numero K*/
	K=atoi(argv[dim]);

	if (K <= 0){
		snprintf(str,256,"Inserire K intero strettamente positivo \n");
		write(1,str,strlen(str));
		return(2);
	}

	/*Creazione file Fout*/
	snprintf(Fout,256,"output.%d",K);
	fdout=creat(Fout,0644);
	if (fdout<0){
		snprintf(str,256,"Impossibile creare il file %s \n",Fout);
		write(1,str,strlen(str));
		return(3);
	}

	/*Assegno Numero di figli*/
	N=dim-1;
	/*Allocazione dinamica pipe pfd_p*/
	pfd_p=(pipe_t*)malloc(sizeof(pipe_t)*N);
	if (pfd_p==NULL){
		snprintf(str,100,"Errore allocazione pipe pfd_p \n ");
		write(1,str,strlen(str));
		return(4);
	}
	/*Creazione Pipe pfd_p*/
	for (i=0;i<N;i++){
		retval=pipe(pfd_p[i]);
		if (retval!=0){
			snprintf(str,100,"Errore nella creazione della pipe pfd_p %d \n ",i);
			write(1,str,strlen(str));
			return(5);
		}

	}
	/*Allocazione dinamica pipe pfd_f*/
	pfd_f=(pipe_t*)malloc(sizeof(pipe_t)*N);
	if (pfd_f==NULL){
		snprintf(str,100,"Errore allocazione pipe pfd_f \n ");
		write(1,str,strlen(str));
		return(6);
	}
	/*Creazione Pipe pfd_f*/
	for (i=0;i<N;i++){
		retval=pipe(pfd_f[i]);
		if (retval!=0){
			snprintf(str,100,"Errore nella creazione della pipe pfd_f %d \n ",i);
			write(1,str,strlen(str));
			return(7);
		}

	}
	/*Creazione figli*/
	for (i=0;i<N;i++){
		pid=fork();
		switch(pid){
			case 0: /*Figlio*/
				return (figlio(argv[i+1],i));

			case -1:/*Errore*/
				snprintf(str,100,"Errore creazione figlio numero %d PID %d \n ",i,pid);
				write(1,str,strlen(str));
				return(8);
		}

	}
	/*Se arrivo qui sono il padre*/
	/*Chiudo i lati delle pipe che il padre non usa*/
	/*Il padre scrive solo sulle pipe pfd_p*/
	/*Il padre legge solo dalle pipe pfd_f*/

	for (i=0;i<N;i++){
		close(pfd_f[i][1]);
		close(pfd_p[i][0]);
	}
	/*Per ogni figlio*/
	for (i=0;i<N;i++){
		/*Leggo il valore dalla pipe pfd_f*/
		if (read(pfd_f[i][0],&cont_ch,sizeof(long int))!=sizeof(long int)) {
			fprintf(stderr,"Impossibile leggere cont_ch\n");
			abort();
		}
		if (cont_ch>K){
			/*Preparo la stringa Sopra Media per il figlio */
			snprintf(Media,12,"Sopra Media");
		}

		if (cont_ch==K){
			/*Preparo la stringa Equal Media per il figlio */
			snprintf(Media,12,"Equal Media");
		}
		if (cont_ch<K){
			/*Preparo la stringa Sotto Media per il figlio */
			snprintf(Media,12,"Sotto Media");
		}
		/*Scrivo stringa al figlio su pfd_p[i]*/
		write(pfd_p[i][1],Media,12);
	}
	/*Stampo i valori di uscita dei figli*/
	for (i=0;i<N;i++){
		/*Attendo i figli e stampo il valori di uscita*/
		pid=wait(&st);
		snprintf(str,256,"Figlio con PID %d RITORNA %d \n",pid,WEXITSTATUS(st));
		write(1,str,strlen(str));
	}


	return(0);

}

int figlio(char *Fi,int indice){
/*Ogni figlio e' associato a un file Fi*/
/*Ogni figlio calcola la lunghezza del file Fi*/
/*Comunica la lunghezza al processo padre su pfd_f[indice]*/
/*Riceve la stringa comunicata dal padre su pfd_p[indice]*/
/*Scrive la stringa su Fout*/

int i;/*Indice generico*/
int fd;/*File descriptor file Fi*/
char ch;/*Carattere di appoggio per lettura dal file Fi*/
long int cont_ch;/*Contatore caratteri*/
char temp[256];/*Buffer per scrittura su Fout*/

/*Stampa di Controllo*/
snprintf(str,256,"Figlio INDICE %d FILE %s \n",indice,Fi);
write(1,str,strlen(str));
/*Chiusura lati pipe non utilizzati pfd_f*/
/*Ogni figlio usa solo la pipe pfd_f[indice]*/
for (i=0;i<N;i++){
        if (i!=indice){
                close(pfd_f[i][0]);
                close(pfd_f[i][1]);
        }
}

/*Scrivo SOLO sulla mia pipe pfd_f*/
close(pfd_f[indice][0]);

/*Chiusura lati pipe non utilizzati pfd_p*/
/*Ogni figlio usa solo la pipe pfd_p[indice]*/
for (i=0;i<N;i++){
        if (i!=indice){
                close(pfd_p[i][0]);
                close(pfd_p[i][1]);
        }
}

/*Leggo SOLO dalla mia pipe pfd_p*/
close(pfd_p[indice][1]);

/*Apertura file associato Fi*/
fd=open(Fi,O_RDONLY);
if (fd<0){
        snprintf(str,256,"Figlio INDICE %d Impossibile aprire file %s \n",indice,Fi);
        write(1,str,strlen(str));
}

/*Inizializzo variabile contatore caratteri*/
cont_ch=0;
/*Scansione file fd per conteggio caratteri*/
while(read(fd,&ch,1)>0){
        /*Ho letto un carattere*/
        /*Incremento contatore*/
        cont_ch++;
}
/*oppure molto piu' semplicemente si poteva usare la funzione lseek*/
/* cont_ch=lseed(fd, 0L, 2) */
/*Comunico al padre la lunghezza in caratteri del file*/
write(pfd_f[indice][1],&cont_ch,sizeof(long int));
/*Attendo la stringa che mi scrive il padre*/
if (read(pfd_p[indice][0],Media,12)!=12) {
	fprintf(stderr,"Lettura invalida da pdf_d[%d][0]\n",indice);
	exit(-1);
}
/*Scrivo sul file Fout stringa concatenata*/
snprintf(temp,256,"%s %s\n",Fi,Media);
write(fdout,&temp,strlen(temp));
/*Controllo valore scritto dal padre su pipe pfd_p*/
if(strcmp(Media,"Sopra Media")==0){
        retval=2;
}

if(strcmp(Media,"Sotto Media")==0){
        retval=1;
}

if(strcmp(Media,"Equal Media")==0){
        retval=0;
}
/*Ritorno retval al padre*/
return(retval);

}