/* Programma di esempio per l'uso delle pipe.
 * In questo caso semplice il figlio continua
 * ad inviare dati al padre.
 */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#define __USE_POSIX
#include <signal.h>
#include <wait.h>
#include "myutils.h"

/* Dimensione del buffer per la stringa ricevuta
 * dal processo padre */
#define BUFFSIZE 80

/* Scommentare la linea seguente per vedere scattare la SIGPIPE */
#define DO_SIGPIPE

/* Forward declaration */
void handler(int signo);

int main(void)
{
  int pipefd[2], i;
  pid_t child;
  struct sigaction nuova, vecchia;
  char scritta[] = "Prova di scrittura nella PIPE";
  char local[BUFFSIZE];

  /* Installo l'handler della SIGPIPE */
  nuova.sa_handler = handler;
  nuova.sa_flags = 0;
  sigemptyset(&nuova.sa_mask);
  if (sigaction(SIGPIPE, &nuova, &vecchia) == -1) 
    sys_err("Errore nell'installazione della SIGPIPE");

  printf("Lunghezza del buffer della FIFO %ld\n",
	 sysconf(_PC_PIPE_BUF));

  if (pipe(pipefd) == -1) 
    sys_err("Errore nella creazione della pipe");
	
  if ((child = fork()) < 0) 
    sys_err("Errore nella fork");
  else if (child == 0) {
    /* Il processo figlio chiude il descrittore in lettura poiche' 
       sulla pipe deve solo scrivere. */
    close(pipefd[0]);

    /* Ciclo for con cui viene effettuato il passaggio della
     * stringa. */
    for(i=0; i<strlen(scritta); i++) {
      if (write(pipefd[1], &scritta[i], sizeof(char)) == -1) 
	sys_err("Errore nella write ...");
    }
    /* Come fine stringa invio un byte a 0 */
    if (write(pipefd[1], 0, sizeof(char)) == -1) 
      sys_err("Errore nella write");

    printf("Fine della scritta\n");
    close(pipefd[1]);
  }
  else {
    /* Il processo padre chiude la pipe in scrittura
     * perche' deve solo leggere .... */
    close(pipefd[1]);
    /* La SIGPIPE scatta quando c'e' una pipe aperta in scrittura 
     * ma non in lettura .. infatti in questo caso al task viene 
     * notificato, con la SIGPIPE appunto, che
     * potrebbe rimanere indefinitamente bloccato sulla pipe. */
#ifdef DO_SIGPIPE
    close(pipefd[0]);
    /* Nel caso di chiusura della PIPE il padre aspetta la
     * fine del task figlio. */
    wait(NULL);
    exit(0);
#endif
    for(i=0; i<BUFFSIZE; i++) {
      if (read(pipefd[0], &local[i], sizeof(char)) == -1) 
	sys_err("Errore nella read ...");
      if (local[i] == 0)
	break;
    }
    local[BUFFSIZE-1] = 0;
		
    printf("Scritta ricevuta -- %s \n", local);
  }
  return 0;
}

void handler(int signo)
{
  printf("Ricevuta signal numero %d \n", signo);
  printf("SIGPIPE = %d \n", SIGPIPE);
  exit(0);
}