Создание семафора

int Semaphore::open(int *pcreated)
{
    int id = 0;     // результат
    *pcreated = 0;  // семафор не создан
 
    // попытаться получить семафор
    if((id = semget(key, 1, 0)) == -1)
    {
        // не удалось, рассмотрим причину
        if (errno = ENOENT)
        {
            // запрощенный семафор не существует
            // создаем его
            if((this->id = semget(key, 1, IPC_CREAT | 0664)) == -1)
            {
                printf("Error: can't create semaphore.\n");
                return id;
            }
            *pcreated = 1;  // семафор был создан
        }
        else
        {
            printf("Error: can't get semaphore.\n");
            return id;
        }
    }
 
    // инициализировать семафор, если текущий процесс его создал
    if (*pcreated)
    {
        // структура данных для управления семафором
#ifndef _SEM_SEMUN_UNDEFINED_
    union semun
    {
        int val;                    // значение для команды SETVAL
        struct semid_ds *buf;       // буфер для команд IPC_STAT и IPC_SET
        unsigned short int *array;  // массив для команд GETALL и SETALL
        struct seminfo *__buf;      // буфер для команд IPC_INFO
    };
#endif
        union semun s_un;
        // начальное значение семафора
        s_un.val = 1;
        // установить начальное значение семафора
        if (semctl(id, 0, SETVAL, s_un) == -1)
        {
            printf("Error: can't init semaphore.\n");
            // с семафором работать нельзя
            return -1;
        }
    }
 
    return id;
}

#include "semaphore.h"
 
double calculate(char filename[128])
{
    FILE *fInput;
    double n = 0, result = 0;
 
    if ((fInput = fopen(filename, "r")) != NULL)
    {
        while (!feof(fInput))
        {
            fscanf(fInput, "%lf", &n);
            result += n;
        }
    }
    else
    {
        printf("Error! Can't open file \"%s\".",filename);
    }
 
    fclose (fInput);
 
    return result;
}
 
int main(int argc, char *argv[])
{
    double sum = 0;
    Semaphore semaphore;
 
    if (argc < 2)
    {
        printf("Usage %s[list of file names].", argv[0]);
        return -1;
    }
 
    if (semaphore.id != -1)
    {
        fopen("res.txt", "w");
 
        for(int i = 1; i < argc; i++ )
        {
            pid_t pid = fork();
 
            if(pid != 0)
            {
                double result = calculate(argv[i]);
 
                if (semaphore.lock() != 0)
                {
                    printf("Error! Can't lock %d semaphore, fork №%d!\n", semaphore.id, i);
                    return -1;
                }
 
                sum = 0;
 
                FILE *fOutput;
                if((fOutput = fopen("res.txt", "r")) != NULL)
                {
                    fscanf(fOutput,"%lf", &sum);
                }
                else
                {
                    printf("Error! Cant work with result file\n");
                    return -1;
                }
 
                sum += result;
 
                if((fOutput = fopen("res.txt", "w")) != NULL)
                {
                    fprintf(fOutput,"%lf", sum);
                }
 
                fclose(fOutput);
 
                if(semaphore.unlock() != 0)
                {
                    printf("Error! Can't unlock %d sem, fork №%d!\n", semaphore.id, i);
                    return -1;
                }
 
                return 0;
            }
        }
    }
    else
    {
        return -1;
    }
}

#include "semaphore.h"
 
#define key 1234
 
Semaphore::Semaphore()
{
    id = open();
}
 
int Semaphore::open()
{
 
    int id = 0;     // результат
    bool pcreated = false;  // семафор не создан
 
    // попытаться получить семафор
    if((id = semget(key, 1, 0)) == -1)
    {
        // не удалось, рассмотрим причину
        if (errno = ENOENT)
        {
            // запрощенный семафор не существует
            // создаем его
            if((id = semget(key, 1, IPC_CREAT | 0664)) == -1)
            {
                printf("Error: can't create semaphore.\n");
                return id;
            }
            pcreated = true;  // семафор был создан
        }
        else
        {
            printf("Error: can't get semaphore.\n");
            return id;
        }
    }
 
    // инициализировать семафор, если текущий процесс его создал
    if (pcreated)
    {
        // структура данных для управления семафором
#ifndef _SEM_SEMUN_UNDEFINED_
    union semun
    {
        int val;                    // значение для команды SETVAL
        struct semid_ds *buf;       // буфер для команд IPC_STAT и IPC_SET
        unsigned short int *array;  // массив для команд GETALL и SETALL
        struct seminfo *__buf;      // буфер для команд IPC_INFO
    };
#endif
        union semun s_un;
        // начальное значение семафора
        s_un.val = 1;
        // установить начальное значение семафора
        if (semctl(id, 0, SETVAL, s_un) == -1)
        {
            printf("Error: can't init semaphore.\n");
            // с семафором работать нельзя
            return -1;
        }
    }
 
    return id;
}
 
int Semaphore::lock()
{
    struct sembuf s_buf = {0, -1, 0};
 
    if (semop(id, &s_buf, 1) == -1)
    {
        // проверяем причину
        if (errno == EIDRM)
        {
            // семафор был удален другим процессом
            return -1;
        }
        return 1;
    }
 
    return 0;
}
 
int Semaphore::unlock()
{
    struct sembuf s_buf = {0, 1, 0};
 
    if (semop(id, &s_buf, 1) == -1) {
        return 1;
    }
 
    return 0;
}
 
int Semaphore::close()
{
    semctl(id, 0, IPC_RMID, 0);
    return 0;
}