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

@Khelleos · Регистрация: 13.05.2010

Студворк — интернет-сервис помощи студентам

Запускаю код на одной машине все работает, на другой выдает ошибку "Error: can't init semaphore."
Ошибка возникает при открытии семафора.
Переменная key = 1234.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
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;
}

Tulosba · 16.03.2013, 10:46

Смотрите что записано в errno

@Khelleos · 18.03.2013, 21:31 **[ТС]**

Странно, перестала выдаваться ошибка "Error: can't init semaphore.". Но результать оказывается два раза больше чем надо.

main.cpp

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
#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;
    }
}

semaphore.cpp

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
#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;
}

Добавлено через 6 минут
Почему-то данные с каждого входного файла считываются два раза. Как такое может быть?

@grgdvo · 20.03.2013, 15:01

Сообщение от Khelleos

C++
1
2
3
4
5
fopen("res.txt", "w");
for(int i = 1; i < argc; i++ )
{
  pid_t pid = fork(); 
  if(pid != 0)

Странный у вас кусок кода! Зачем fopen без получения указателя на файл?
Далее про форк. В мануале написано:

Bash
1
2
RETURN VALUE
On success, the PID of the child process is returned in the parent, and 0 is returned in the child.  On failure, -1 is returned in the parent, no child process is created, and errno is set appropriately.

У вас условное выражение выполняет роидтельский процесс - тогда зачем fork?

По удвоенной сумме: может быть вы не совсем чисто соблюли условия тестирования? Я не запускал, но по коду что-то не видно, чтобы было удвоение.

@Khelleos · 22.03.2013, 20:59 **[ТС]**

Сообщение от grgdvo

Странный у вас кусок кода! Зачем fopen без получения указателя на файл?

нужно было просто создать пустой файл или очистить его в случае, если он создан. Просто это первое, что пришло в голову, но
решение проблемы дурацкое...

Сообщение от grgdvo

У вас условное выражение выполняет роидтельский процесс - тогда зачем fork?

Оуу...я думал fork вернёт id дочерного процесса, если он его создаст. Спасибо, не знал об этом.

Сообщение от grgdvo

По удвоенной сумме: может быть вы не совсем чисто соблюли условия тестирования? Я не запускал, но по коду что-то не видно, чтобы было удвоение.

Функция calculate выполняется два раза, при этом все условия соблюдены. Просто на одной машине все рабоет верно, на другой нет(сумма в два раза больше, чем должна быть)

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Desktop (MinGW): Рисуем цветные прямоугольники с помощью рисовальщика SDL3 на Си и C++ 8Observer8 17.03.2026 Содержание блога Финальные проекты на Си и на C++: finish-rectangles-sdl3-c. zip finish-rectangles-sdl3-cpp. zip	Символические и жёсткие ссылки в Linux. algri14 15.03.2026 Существует два типа ссылок — символические и жёсткие. Ссылка в Linux — это запись в каталоге, которая может указывать либо на inode «файла-ИСТОЧНИКА», тогда это будет «жёсткая ссылка» (hard link),. . .	[Owen Logic] Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ФедосеевПавел 14.03.2026 Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ВВЕДЕНИЕ Выполняя задание на управление насосной группой заполнения резервуара,. . .	делаю науч статью по влиянию грибов на сукцессию anaschu 13.03.2026 прикрепляю статью
SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .	Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .

Tulosba :) 4773 / 3267 / 497 Регистрация: 19.02.2013 Сообщений: 9,046
	16.03.2013, 10:46
	Смотрите что записано в errno 0