#include <sys/types.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>


int main()
{
    int fd[2], result;
    size_t size;
    char resstring[64];

    int semid;
    key_t key;

    if((key = ftok("p4.c", 0)) < 0) {
        printf("Can't generate key\n");
        exit(-1);
    }

    if((semid = semget(key, 2, 0666 | IPC_CREAT)) < 0){
        printf("Can't get semid\n");
        exit(-1);
    }

    struct sembuf mybuf;
    mybuf.sem_op = 1;
    mybuf.sem_flg = 0;
    mybuf.sem_num = 1;
    //Устанавливаем отсутствие данных в пайпе
    semop(semid, &mybuf, 1);
    mybuf.sem_num = 0;
    //Увеличиваем семафор на 1, чтобы оба процесса не залочились
    semop(semid, &mybuf, 1);
    mybuf.sem_op = 0;

    if(pipe(fd) < 0) {
        printf("Can't create pipe\n");
        exit(-1);
    }

    result = fork();

    if(result <0) {
        printf("Can't fork child\n");
        exit(-1);
    } else if (result > 0) {
        //parent
        char *msg[] = {
            "Parent message 1",
            "Parent message 2",
            "Parent message 3",
            "Parent message 4",
            "Parent message 5"
        };

        int s = 0, r = 0, hd = 0;


        while(1) {
            //Пытаемся занять канал
            mybuf.sem_op = -1;
            semop(semid, &mybuf, 1);
            //Заняли
            //Проверяем, есть ли данные в канале
            mybuf.sem_op = 0;
            mybuf.sem_flg = IPC_NOWAIT;
            mybuf.sem_num = 1;
            if(!(semop(semid, &mybuf, 1) < 0)) {
                //Есть данные в канале
                //Получаем и пишем
                read(fd[0], resstring, 64);
                printf("%s\n", resstring);
                r++;
                hd = 1;
            } else {
                hd = 0;
            }
            //Посылаем данные, если еще не выслали все
            if(s < 5) {
                write(fd[1], msg[0], strlen(msg[0])+1);
                s++;
                if(!hd) {
                    //Если в канале не было данных
                    mybuf.sem_op = -1;
                    mybuf.sem_flg = 0;
                    mybuf.sem_num = 1;
                    semop(semid, &mybuf, 1);
                }
            } else if(hd) {
                //Прочитали, но не написали, а данные в канале были
                mybuf.sem_op = 1;
                mybuf.sem_flg = 0;
                mybuf.sem_num = 1;
                semop(semid, &mybuf, 1);
            }

            //Освобождаем канал
            mybuf.sem_op = 1;
            mybuf.sem_num = 0;
            semop(semid, &mybuf, 1);

            if(r == 4 && s == 5)
                break;
        }
        printf("Parent exit\n");
        //size = write(fd[1], "Hello, world!", 14);
        //printf("Parent exit, writed %d\n", size);
    } else {
        //child
        char *msg[] = {
            "Child message 1",
            "Child message 2",
            "Child message 3",
            "Child message 4",
            "Child message 5"
        };
        //size = read(fd[0], resstring, 14);
        int s = 0, r = 0, hd = 0;

        while(1) {
            //Пытаемся занять канал
            mybuf.sem_op = -1;
            semop(semid, &mybuf, 1);
            //Заняли
            //Проверяем, есть ли данные в канале
            mybuf.sem_op = 0;
            mybuf.sem_flg = IPC_NOWAIT;
            mybuf.sem_num = 1;
            if(!(semop(semid, &mybuf, 1) < 0)) {
                //Есть данные в канале
                //Получаем и пишем
                read(fd[0], resstring, 64);
                printf("%s\n", resstring);
                r++;
                hd = 1;
            } else {
                hd = 0;
            }
            //Посылаем данные, если еще не выслали все
            if(s < 5) {
                write(fd[1], msg[0], strlen(msg[0])+1);
                s++;
                if(!hd) {
                    //Если в канале не было данных
                    mybuf.sem_op = -1;
                    mybuf.sem_flg = 0;
                    mybuf.sem_num = 1;
                    semop(semid, &mybuf, 1);
                }
            } else if(hd) {
                //Прочитали, но не написали, а данные в канале были
                mybuf.sem_op = 1;
                mybuf.sem_flg = 0;
                mybuf.sem_num = 1;
                semop(semid, &mybuf, 1);
            }
            //Освобождаем канал
            mybuf.sem_op = 1;
            mybuf.sem_num = 0;
            semop(semid, &mybuf, 1);


            if(r == 4 && s == 5)
                break;
        }
        printf("Child exit\n");
        //printf("%s\n",resstring);

    }
    semctl(semid, 0, IPC_RMID, 0);
    return 0;
}