#include "stdio.h"
#include "unistd.h"
#include "wait.h"
#include "stdlib.h"

int pipe1[2];
int pipe2[2];

void proces2();
void proces3();

/* Funkcja liczy silnie*/
long factorial(int n)
{
    unsigned long fact = 1;
    int i;

    for (i = 1; i <= n; i++)
        fact = fact * i;

    return fact;
}

int main() {
    /* Tworze pipe i sprawdzam czy się udało*/
    if(pipe(pipe1) == -1) {
        perror("Nie udało się utworzyć pipe do komunikacji procesa macierzystego z potomkiem liczacym silnie");
    }
    /* Tak samo dla pipe 2*/
    if(pipe(pipe2) == -1) {
        perror("Nie udało się utworzyć pipe do komunikacji potomkow");
    }
    /* Tworzę pierwszego konsumenta */
    int rc = fork();
    if(rc == 0) {
        proces2();
        exit(0);
    }
    /* Tworzę drugiego konsumenta */
    rc = fork();
    if(rc == 0) {
        proces3();
        exit(0);
    }
    /* Zamykam dekryptor do odczytu do pipe1[0] bo ten proces do niego zapisuje a nie odczytuje */
    close(pipe1[0]);
    int odczytanaWartosc = -1;
    while(1) {
        /* Czytam z klawiatury liczbę*/
        scanf("%d", &odczytanaWartosc);
        /* Przesywam tą liczbę przez pipe do konsumenta proces 2*/
        rc = write(pipe1[1], (char*)&odczytanaWartosc, sizeof(int));
        if(rc < 0) {
            perror("Nie moge zapisac do pipe");
            exit(1);
        }
        /* Jeśli liczba była ujemna kończę pracę */
        if(odczytanaWartosc < 0)
            break;
    }
    /* czekam aż procesy 2 i 3 zakończą pracę i informuję o tym użytkownika */
    wait(0);
    wait(0);
    printf("Wszystkie procesy zakończyły pracę\n");
    fflush(stdout);
}

void proces2() {
    /* Zamykam nieużywane deskryptory*/
    close(pipe1[1]);
    close(pipe2[0]);
    int odebranaWartosc = -1;
    long fact = 0;
    while (1)
    {
        /* Odczytuje liczbe od producenta przez pipe*/
        int rc = read(pipe1[0], (char *)&odebranaWartosc, sizeof(int));
        if(rc < 0) {
            perror("Nie moge odczytac z pipe");
            exit(1);
        }
        /* Liczę silnię */
        fact = factorial(odebranaWartosc);
        if(odebranaWartosc < 0) {
            fact = -1;
        }
        /* Wysyłam obliczoną liczbę przez pipe do procesu 3, jeśli liczba była ujemna przesyłam -1 co jest sygnałem do zakończenia pracy */
        rc = write(pipe2[1], (char*)&fact, sizeof(long));
        if(rc < 0) {
            perror("Nie moge zapisac do pipe");
            exit(1);
        }
        /* Kończzę pracę jeśli odbiorę liczbę <0 */
        if(odebranaWartosc < 0)
            break;
    }
    close(pipe1[1]);

}
void proces3() {
    close(pipe2[1]);
    long odebranaWartosc = -1;
    while( 1 )
    {
        /* Pobieram liczbę od procesu 2*/
        int rc = read(pipe2[0], (char *)&odebranaWartosc, sizeof(long));
        if(rc < 0) {
            perror("Nie moge odczytac z pipe");
            exit(1);
        }
        /* Jeśli jest mniejsza od 0 kończę pracę */
        if(odebranaWartosc < 0)
            break;
        /* W przeciwnym wypadku wyświetlam przesłany wynik*/
        printf("%ld\n", odebranaWartosc);
        fflush(stdout);
    }
    close(pipe2[0]);
}