Семафоры

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>
#include <stdio.h>
#include <sys/stat.h>
#include <unistd.h>
 
#define SEM_ID  2001      /* ключ массива семафоров */
#define SHM_ID_ARR  2002      /* ключ разделяемой памяти */
#define SHM_ID_SEQ  2003
#define MAX_STRING  8 //длина итоговой последовательности
 
typedef struct
{
    int proc_num; //переменная для распределения порядкового номера процесса
    int writed; //переменная, хранящая количество записей в файл
} sequence_t;

#include "sequence.h"
#include <stdlib.h>
#include <errno.h>
 
extern int errno;
 
void sys_err(char *msg) { //служебная функция вывода ошибки инициализации
    printf("errno: %d\n", errno);
    puts(msg);
    exit(1);
}
 
int main() {
    int pid = getpid();
    int semid;
    int shmid1;
    int shmid2;
    int num = 0;
    int *arr; //массив 2 int
    sequence_t *seq; //служебный объект
    if ((semid = semget(SEM_ID, 1, S_IRUSR | S_IWUSR | IPC_CREAT | 0666)) < 0)
        sys_err("can not get semaphore");
 
    if ((shmid1 = shmget(SHM_ID_ARR, 2 * sizeof(int), S_IRUSR | S_IWUSR | IPC_CREAT)) < 0) //выделение 2 int общей памяти
        sys_err("arr can not get shared memory segment");
    if ((arr = (int *) shmat(shmid1, 0, 0)) == NULL)
        sys_err("arr shared memory attach error");
 
    if ((shmid2 = shmget(SHM_ID_SEQ, sizeof(sequence_t), S_IRUSR | S_IWUSR | IPC_CREAT)) < 0) //выделение общего seq_t вспомогательного объекта
        sys_err("seq can not get shared memory segment");
    if ((seq = (sequence_t *) shmat(shmid2, 0, 0)) == NULL)
        sys_err("seq shared memory attach error");
 
    FILE *f = fopen("/Users/vladislav/CLionProjects/lab4/text.txt", "w+");
 
    semctl(semid, 0, SETVAL, 0);
    seq->proc_num = 1;
    seq->writed = 0;
    arr[0] = 0;
    arr[1] = 0;
    fork();
    if (getpid() != pid) fork();
 
    while (1) {
        if (semctl(semid, 0, GETVAL, 0)) continue; //блокировка на ждать
        semctl(semid, 0, SETVAL, 1); //установка блокировки
 
        if (num == 0) { //раздача порядковых номеров процессам
            num = seq->proc_num;
            seq->proc_num++;
        }
 
        if (seq->writed >= MAX_STRING/2) { //условие выхода
            semctl(semid, 0, SETVAL, 0); //снятие блокировки
            if (getpid() != pid) exit(1); //завершение дочерних процессов
            break;
        }
 
        if ((num == 1) && ((arr[0] == 0 && arr[1] == 0) || (arr[0] == 0 && arr[1] != num))) { //условие для первого int
            printf("Процесс %d пишет %d \n", num, num);
            arr[0] = num;
        }
 
        if (arr[0] == 1 && arr[1] == 0 && num == 2) { //условие для второго int
            printf("Процесс %d пишет %d \n", num, num);
            arr[1] = num;
        }
 
        if (arr[0] == 1 && arr[1] == 2 && num == 3) { //условие для записи в файл
            printf("Записано: %d %d \n", arr[0], arr[1]);
            fprintf(f, " %d %d", arr[0], arr[1]); //непосредственно запись
            arr[0] = 0; //обнуление разделяемой памяти
            arr[1] = 0;
            seq->writed++;
        } else {
            semctl(semid, 0, SETVAL, 0); //снятие блокировки
        }
    }
 
    shmdt(arr); //очищение памяти
    shmdt(seq);
    if (shmctl(shmid1, IPC_RMID, (struct shmid_ds *) 0) < 0)
        sys_err("server: shared memory remove error");
    if (shmctl(shmid2, IPC_RMID, (struct shmid_ds *) 0) < 0)
        sys_err("server: shared memory remove error");
    return 0;
}