Форум программистов, компьютерный форум, киберфорум
C/С++ под Linux
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.68/25: Рейтинг темы: голосов - 25, средняя оценка - 4.68
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286

Fork() и контроль порождённых процессов

24.04.2016, 14:35. Показов 4913. Ответов 10

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

Не по теме:

Прошу сильно не писать, с сями дружу лишь на уровне алгоритмизации


В общем есть следующее задание:
Функциональные требования к программе (согласно варианту задания):
  1. сразу после запуска должны порождаться несколько процессов, формируя определённое вариантом генеалогическое дерево процессов;
  2. каждый из процессов должен вывести свой идентификатор и идентификатор родительского процесса; выполнить некоторые действия согласно варианту; вывести сообщение, что процесс с таким-то идентификатором и таким-то идентификатором родительского процесса завершает работу;
  3. отправку и получение любых данных каждым процессом необходимо сопровождать выводом сообщения, что процесс с таким-то идентификатором произвёл такие-то действия;
  4. приложение должно быть протестировано в различных вариантах запуска в терминале ОС Linux, в том числе в конвейерах с другими командами, с разными вариантами перенаправления потоков ввода-вывода.
Все процессы должны выводить сообщения (см. функциональные требования), и, кроме того, производить дополнительные действия. Учтите, что передачу и получение информации каждым из процессов необходимо сопровождать выводом на экран информации типа "процесс такой-то передал/получил такую-то информацию таким-то образом (через конвейер, FIFO и т.д.)".
Каждый процесс, запустившись и сообщив об этом выводом строки в поток ошибки, должен отправить самому первому процессу сигнал SIGUSR1, а перед завершением работы сигнал SIGUSR2. При помощи этих сигналов первый процесс должен вести учет количества ваших процессов, функционирующих в данный момент в системе. По получении этих сигналов он должен вывести в поток ошибки сообщение с указанием этого количества.
Фиолетовый процесс выгружается последним. Прежде, чем завершиться, он должен создать новую директорию, в которую перенести все созданные в процессе работы файлы, а на их старом месте создать символические ссылки на эти файлы. Таким образом, после каждого из запусков должна оставаться новая директория с набором созданных файлов. Механизмы синхронизации и коммуникации между фиолетовым и остальными процессами выбрать по своему усмотрению.

Вариант 30. Жёлтый получает со стандартного потока ввода содержимое любого текстового файла и выводит на экран те его строки, которые начинаются с цифры, остальные строки передавая через FIFO зелёному. Тот заменяет в полученных строках X на Y и выводит результирующие строки на экран, а затем передаёт значение длины строки оранжевому при помощи семафоров (без дополнительных средств коммуникации). Оранжевый отображает на экран полученные значения и накопительную сумму и передаёт красному, используя общие файлы. Тот полученную информацию отображает на экране и сохраняет в файле.

Само собой, с алгоритмизацией проблем нет, то бишь не прошу накарябать всё, лишь только помочь с форками и контролем оных. ТО БИШЬ, где куда какую часть кода писать. что-то типа:
C
1
2
3
4
5
6
7
int main()
{
//тут фильтруем строки
//тут загоняем в фифо
//тут получаем из фифо и обрабатываем чего-то там
//тут семафором бла-бла
}
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
24.04.2016, 14:35
Ответы с готовыми решениями:

Создание процессов, системный вызов fork()
Доброго времени суток, просьба разъяснить такой вопрос, написал такой код #include <stdlib.h> #include <sys/types.h> ...

Очередность выполнения процессов после fork()
Подскажите, что будет выводиться в консоль если поле вызова fork() внутри обоих процессов будет выполняться бесконечный цикл выводящий...

Debian Linux - Создание процессов (дед, отец, сын), fork();
Привет всем. Появилось у меня несколько вопросов по созданию процессов. Может будете ругаться, но реально не могу понять.. Уже гугл...

10
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286
01.05.2016, 21:29  [ТС]
Up!
0
 Аватар для SergioO
261 / 209 / 99
Регистрация: 13.12.2015
Сообщений: 1,098
02.05.2016, 19:56
Цитата Сообщение от JokeR.BY Посмотреть сообщение
Up!
еще актуально?
0
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286
02.05.2016, 20:17  [ТС]
SergioO, в общем-то основной костяк проги написал. осталось разчехлиться с общими файлами mmap'ом то бишь)
0
 Аватар для SergioO
261 / 209 / 99
Регистрация: 13.12.2015
Сообщений: 1,098
02.05.2016, 20:18
задачка хорошая, но стандартная.
разрабатывается АТД Proccess. Я бы ввел внутреннее состояние процесса, как в автомате и в зависимости от этого состояния (число) процесс имел ту или иную конфигурацию. плюс, я так понял изначально в процессе родителе заложена некая структура (генеалогическое дерево) в соответствии с которым строится дерево процессов. на каждом шаге процесс отсекает от дерева "себя"... но это если через exec() там параметры можно передавать, а pid_t fork (void); только pid_t вернет и тогда логика уже должна быть внутри...
хотя, ведь процесс знает родительский PID PPID и по сигналу от него может открывать какой-нибудь IPC

скорее всего попробую тоже ее решить, а потом сравним )) ок?
0
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286
02.05.2016, 20:37  [ТС]
SergioO, у меня оно всё пока крайне костыльно, так что нечего там особо сравнивать будет-с)
(древо ниже, вроде к первому посту прикреплял, хз).
Изображения
 
0
 Аватар для SergioO
261 / 209 / 99
Регистрация: 13.12.2015
Сообщений: 1,098
02.05.2016, 20:49
JokeR.BY, они процессы должны именно fork() создаваться?
их же вроде всего 4 по заданию или что это дерево означает? это дерево и есть генеалогическая структура?
прикольная задача. к какому сроку ее сделать надо?
0
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286
02.05.2016, 20:52  [ТС]
пока оно в таком виде.
C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
#include <stdio.h>
#include <unistd.h>
#include "pid.h"
 
void printChild(const char * s)
{
    printf("%s: Это дочерний процесс\n", s);
    printf("%s: Мой pid = %d\n", s, getpid());
    printf("%s: Родительский pid = %d\n", s, getppid());
}
 
void printParent(const char * s)
{
    printf("%s: Это родительский процесс\n", s);
    printf("%s: Мой pid = %d\n", s, getpid());
}
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <ctype.h>
#include <semaphore.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/mman.h>
#include "pid.h"
 
#define LENGTH 1000
 
const char FIFONAME[] = "fifo.kr", NUMBSEM[] = "/numbersem", BOOLSEM[] = "/booleansem", SHAREDFILE[] = "sharedfile.bin";
 
int main(int argc, char *argv[])
{
    if (argc < 3)
    {
        perror("Введите больше аргументов!\n");
        return EXIT_FAILURE;
    }
    const char x = argv[1][0], y = argv[2][0]; //параметры X и Y
    pid_t childPid, wPid;
    sem_t *sem1, *sem2;
    int fd, n, llen, status = 0;
    unsigned short i;
    unsigned int semLen, sum = 0;
    char buf[LENGTH], *a;
    printParent("Голубой");
    for (i = 0; i < 3; ++i)
    {
        if ((childPid = fork()) == 0)
        {
            switch (i)
            {
                case 0: //Фиолетовый или Красный
                    switch (childPid = fork())
                    {
                        case -1:
                            perror("ERROR!");
                        case 0: //Красный
                            printChild("Красный");
                            //fd = open()
                            
                            
                            
                            exit(EXIT_SUCCESS);
                        default: //Фиолетовый
                            printChild("Фиолетовый");
                            while ((wPid = wait(&status)) > 0)
                                printf("Exit status of %d was %d\n", (int)wPid, status);
                            exit(EXIT_SUCCESS);
                    }
                case 1: //Оранжевый
                    printChild("Оранжевый");
                    if ((sem1 = sem_open(BOOLSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                    {
                        perror("Оранжевый: Не могу открыть бинарный семафор!");
                        exit(EXIT_FAILURE);
                    }
                    if ((sem2 = sem_open(NUMBSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                    {
                        perror("Оранжевый: Не могу открыть семафор-счётчик!");
                        exit(EXIT_FAILURE);
                    }                   
                    do
                    {
                        semLen = 0;
                        sem_wait(sem1);
                        while (sem_trywait(sem2) == 0)
                            ++semLen;
                        if (semLen != 0)
                        {
                            printf("Оранжевый: Длина строки: %d\n", semLen);
                            sum += semLen;
                        }
                    } while (semLen > 0);
                    printf("Оранжевый: Суммарная длина строк: %d\n", sum);
                    sem_close(sem1);
                    sem_close(sem2);
                    if ((fd = open(SHAREDFILE, O_RDWR | O_CREAT | O_TRUNC, (mode_t)0600)) < 0)
                    {
                        perror("Оранжевый: Не могу открыть общий файл!");
                        exit(EXIT_FAILURE);
                    }
                    close(fd);
                    exit(EXIT_SUCCESS);
                case 2: //Жёлтый или Зелёный
                    mkfifo(FIFONAME, 0666);
                    switch (childPid = fork())
                    {
                        case -1:
                            perror("ERROR!");
                        case 0: //Зелёный
                            printChild("Зелёный");
                            if ((fd = open(FIFONAME, O_RDONLY|O_NONBLOCK)) < 0)
                            {
                                perror("Зелёный: Cannot open FIFO\n");
                                exit(EXIT_FAILURE);
                            }
                            if ((sem1 = sem_open(BOOLSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                            {
                                perror("Зелёный: Не могу открыть бинарный семафор!");
                                exit(EXIT_FAILURE);
                            }
                            if ((sem2 = sem_open(NUMBSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                            {
                                perror("Зелёный: Не могу открыть семафор-счётчик!");
                                exit(EXIT_FAILURE);
                            }
                            while ((n = read(fd, buf, LENGTH)) > 0)
                            {
                                llen = strlen(buf);
                                for (a = buf; a < buf + (llen - 1); ++a)
                                {
                                    sem_post(sem2);
                                    if (x == *a)
                                        *a = y;
                                }
                                printf("Зелёный: %s", buf);
                                sem_post(sem1);
                            }
                            sem_post(sem1);
                            close(fd);
                            sem_close(sem1); sem_close(sem2);
                            exit(EXIT_SUCCESS);
                        default: //Жёлтый
                            printChild("Жёлтый");
                            if ((fd = open(FIFONAME, O_WRONLY)) < 0)
                            {
                                perror("Жёлтый: Cannot open FIFO\n");
                                exit(EXIT_FAILURE);
                            }
                            while (fgets(buf, LENGTH - 1, stdin) != NULL)
                            {
                                if (isdigit(buf[0]))
                                    printf("Жёлтый: %s", buf);
                                else
                                {
                                    n = write(fd, buf, LENGTH);
                                    if (n != LENGTH)
                                    {
                                        perror("Жёлтый: Не могу записать в FIFO!\n");
                                        exit(EXIT_FAILURE);
                                    }
                                }
                            }
                            close(fd);
                            while ((wPid = wait(&status)) > 0)
                                printf("Exit status of %d was %d\n", (int)wPid, status);
                            exit(EXIT_SUCCESS);
                    }
                default:
                    perror("Чёт ошибка какая-то о_О");
            }
        }
    }
    while ((wPid = wait(&status)) > 0)
        printf("Exit status of %d was %d\n", (int)wPid, status);
    return EXIT_SUCCESS;
}
Добавлено через 1 минуту
SergioO, судя по заданиям, что мне девушка передала, да - на форках
0
 Аватар для SergioO
261 / 209 / 99
Регистрация: 13.12.2015
Сообщений: 1,098
03.05.2016, 16:58
занялся решением сей задачи.
первые соображения
"строится" дерево будет fork() + execl() (скорее всего именно этот вариант exec, но не факт)
в коде описывается такое же дерево, но логическое, в зависимости от того, в каком узле дерева находится программа выполняет определенные действия коммуницировать не соседние узлы могут через каналы(дескрипторы каналов наследуются). получается два графа - граф построения и граф коммуникаций
те узлы, которые ничего не делают будут ждать завершения дочерних процессов.
так, первые наброски
C
1
waitpid (pid1, NULL, 0);
0
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286
09.05.2016, 23:25  [ТС]
и ещё раз Up!
0
CAPITAL OF ROCK!
 Аватар для JokeR.BY
1281 / 708 / 982
Регистрация: 03.03.2010
Сообщений: 2,286
12.05.2016, 16:00  [ТС]
и ещё раз Up! на сей раз прошу помочь привести в читабельный вид готовый (вроде бы) код, указать на косяки и тд...
pid.c
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
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include "pid.h"
#include <signal.h>
 
inline void printInfo(const char * s, pid_t * bluePid)
{
    if (bluePid)
        kill(*bluePid, SIGUSR1);
    fprintf(stderr, "%s: Мой pid = %d\n", s, (int)getpid());
    fprintf(stderr, "%s: Родительский pid = %d\n", s, (int)getppid());
}
 
inline int exitParent(const char * s)
{
    fprintf(stderr, "%s: Процесс #%d завершает работу\n", s, (int)getpid());
    return EXIT_SUCCESS;
}
 
inline int exitParentWithError(const char * s, const char * mes)
{
    fprintf(stderr, "%s: Процесс #%d завершает работу с ошибкой:\n", s, (int)getpid());
    perror(mes);
    return EXIT_FAILURE;
}
 
inline void exitFork(const char * s, pid_t * bluePid)
{
    if (bluePid)
        kill(*bluePid, SIGUSR2);
    fprintf(stderr, "%s: Процесс #%d завершает работу\n", s, getpid());
    exit(EXIT_SUCCESS);
}
 
inline void exitForkWithError(const char * s, const char * mes, pid_t * bluePid)
{
    if (bluePid)
        kill(*bluePid, SIGUSR2);
    fprintf(stderr, "%s: Процесс #%d завершает работу с ошибкой:\n", s, (int)getpid());
    perror(mes);
    exit(EXIT_FAILURE);
}
main.c
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
#include <stdio.h>
#include <time.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <ctype.h>
#include <semaphore.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/mman.h>
#include "pid.h"
#include "main.h"
 
#define LENGTH 1000
const char FIFONAME[] = "fifo.kr", NUMBSEM[] = "/numbersem", BOOLSEM[] = "/booleansem", SHAREDFILE[] = "sharedfile.bin", VIOLSEM[] = "/violsem", REDFILE[] = "red.txt";
char path[256], c[128];
unsigned short runProc = 0, closeProc = 0;
 
void one(int signo);
void two(int signo);
void Move_n_sym(const char fileName[]);
 
int main(int argc, char *argv[])
{
    /*аргументы x y*/
    if (argc < 3)
        return exitParentWithError("Голубой", "Слишком малое количество аргументов!");
    const char x = argv[1][0], y = argv[2][0]; //Параметры X и Y
    /*время*/
    long s_time = time(NULL);
    struct tm *m_time = localtime(&s_time);
    strftime(c, (size_t)128, "%c", m_time);
    
    strcpy(path, (argc > 3) ? argv[3] : c);
    //struct stat fileInfo;
    pid_t childPid, mainPid = getpid(); //пид форков, пид голубого
    sem_t *sem1, *sem2; //семафоры
    sigset_t sign; //сигнал
    int fd, n, *p; //открытые каналы|файлы|etc, темповая, замапленный файл
    unsigned short i; //счётчик форков
    unsigned int semLen, sum = 0; 
    char buf[LENGTH], *a; //строка, символ
    
    /*реакция процесса на сигналы*/
    //SIGUSR1 - one()
    struct sigaction act_one;
    memset(&act_one, 0, sizeof(act_one));
    act_one.sa_handler = one;
    sigfillset(&act_one.sa_mask);
    sigaction(SIGUSR1, &act_one, NULL);
 
    //SIGUSR2 - two()
    struct sigaction act_two;
    memset(&act_two, 0, sizeof(act_two));
    act_two.sa_handler = two;
    sigfillset(&act_two.sa_mask);    
    sigaction(SIGUSR2, &act_two, NULL);
    
    sigemptyset(&sign);
    /*ветвление*/
    for (i = 0; i < 3; ++i)
    {
        /*ветвление на голубой|фиолетовый|оранжевый|жёлтый*/
        if ((childPid = fork()) == 0)
        {
            switch (i)
            {
                case 0: //Фиолетовый или Красный
                    switch (childPid = fork())
                    {
                        case -1:
                            perror("ERROR!");
                        case 0: //Красный
                            printInfo("Красный", &mainPid);
                            //общий файл
                            if ((fd = open(SHAREDFILE, O_RDONLY, (mode_t)0666)) == -1)
                                exitForkWithError("Красный", "Не удалось открыть файл на чтение", &mainPid);
                            if ((p = mmap(0, sizeof(int), PROT_READ, MAP_SHARED, fd, (off_t)0)) == MAP_FAILED)
                                exitForkWithError("Красный", "Не удалось замапить общий файл", &mainPid);
                            sum = *p;
                            printf("Красный: Читаю данные из общего файла %d\n", sum);
                            if (munmap(p, sizeof(int)) == -1)
                            {
                                close(fd);
                                exitForkWithError("Красный", "Не удалось размапить общий файл", &mainPid);
                            }
                            close(fd);
                            //конец общий файл
                            //файл
                            if ((fd = open(REDFILE, O_WRONLY | O_TRUNC | O_CREAT, (mode_t)0666)) == -1)
                                exitForkWithError("Красный", "Не удалось открыть файл на запись", &mainPid);
                            sprintf(buf, "%d", sum);
                            if ((n = write(fd, buf, strlen(buf))) == -1)
                                exitForkWithError("Красный", "Не удалось записать в файл", &mainPid);
                            printf("Красный: %d байт записано в файл\n", n);
                            close(fd);
                            //конец файл
                            exitFork("Красный", &mainPid);
                        default: //Фиолетовый
                            printInfo("Фиолетовый", &mainPid);
                            if ((sem1 = sem_open(VIOLSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                                exitForkWithError("Фиолетовый", "Не могу открыть бинарный семафор", NULL);
                            sem_wait(sem1);
                            sem_close(sem1);
                            sleep(5);
                            printf("Фиолетовый: Все процессы завершены!\n");
                            if (mkdir(path, (mode_t)0775) == -1)
                                exitForkWithError("Фиолетовый", "Не могу создать папку", NULL);
                            Move_n_sym(REDFILE);
                            Move_n_sym(SHAREDFILE);
                            exitFork("Фиолетовый", NULL);
                    }
                case 1: //Оранжевый
                    printInfo("Оранжевый", &mainPid);
                    //семафоры
                    if ((sem1 = sem_open(BOOLSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                        exitForkWithError("Оранжевый", "Не могу открыть бинарный семафор", &mainPid);
                    if ((sem2 = sem_open(NUMBSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                        exitForkWithError("Оранжевый", "Не могу открыть семафор-счётчик", &mainPid);
                    do
                    {
                        semLen = 0;
                        printf("Оранжевый: Ожидаю разрешение на принятие длины слова\n");
                        sem_wait(sem1);
                        while (sem_trywait(sem2) == 0)
                            ++semLen;
                        if (semLen != 0)
                        {
                            printf("Оранжевый: Получил данные через семафоры - длина строки: %d\n", semLen);
                            sum += semLen;
                        }
                    } while (semLen > 0);
                    printf("Оранжевый: Приём данных через семафоры закончен\n");
                    printf("Оранжевый: Суммарная длина строк: %d\n", sum);
                    sem_close(sem1);
                    sem_close(sem2);
                    //конец семафоры
                    //общий файл
                    if ((fd = open(SHAREDFILE, O_RDWR | O_TRUNC| O_CREAT, (mode_t)0666)) == -1)
                        exitForkWithError("Оранжевый", "Невозможно открыть файл", &mainPid);
                    lseek(fd, sizeof(int), SEEK_SET);
                    write(fd, "", 1);
                    if ((p = mmap(0, sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED, fd, (off_t)0)) == MAP_FAILED)
                        exitForkWithError("Оранжевый", "Не удалось замапить общий файл", &mainPid);
                    *p = sum;
                    
                    if (msync(p, sizeof(int), MS_SYNC) == -1)
                    {
                        close(fd);
                        exitForkWithError("Оранжевый", "Не удалось синхронизировать память и общий файл", &mainPid);
                    }
                    
                    if (munmap(p, sizeof(int)) == -1)
                    {
                        close(fd);
                        exitForkWithError("Оранжевый", "Не удалось размапить общий файл", &mainPid);
                    }
                    close(fd);
                    //конец общий файл
                    exitFork("Оранжевый", &mainPid);
                case 2: //Жёлтый или Зелёный
                    mkfifo(FIFONAME, 0666);
                    switch (childPid = fork())
                    {
                        case -1:
                            perror("ERROR!");
                        case 0: //Зелёный
                            printInfo("Зелёный", &mainPid);
                            if ((fd = open(FIFONAME, O_RDONLY|O_NONBLOCK)) < 0)
                                exitForkWithError("Зелёный", "Не могу открыть FIFO", &mainPid);
                            if ((sem1 = sem_open(BOOLSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                                exitForkWithError("Зелёный", "Не могу открыть бинарный семафор", &mainPid);
                            if ((sem2 = sem_open(NUMBSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
                                exitForkWithError("Зелёный", "Не могу открыть семафор-счётчик", &mainPid);
                            while ((n = read(fd, buf, LENGTH)) > 0)
                            {
                                printf("Зелёный: Посредством FIFO получил строку %s", buf);
                                for (a = buf; a < buf + strlen(buf) - 1; ++a)
                                {
                                    sem_post(sem2);
                                    if (x == *a)
                                        *a = y;
                                }
                                printf("Зелёный: Обработал предыдущую строку до состояния %s", buf);
                                printf("Зелёный: передал длину строки (%d) через семафор\n", (int)strlen(buf));
                                sem_post(sem1);
                            }
                            sem_post(sem1);
                            printf("Зелёный: Освободил процесс из режима ожидания\n");
                            close(fd);
                            sem_close(sem1);
                            sem_close(sem2);
                            exitFork("Зелёный", &mainPid);
                        default: //Жёлтый
                            printInfo("Жёлтый", &mainPid);                            
                            //фифо
                            if ((fd = open(FIFONAME, O_WRONLY)) < 0)
                                exitForkWithError("Жёлтый", "Не могу открыть FIFO", &mainPid);
                            printf("Жёлтый: Читаю данные из stdin\n");
                            while (fgets(buf, LENGTH - 1, stdin) != NULL)
                            {
                                if (isdigit(buf[0]))
                                    printf("Жёлтый: %s", buf);
                                else
                                {
                                    n = write(fd, buf, LENGTH);
                                    if (n != LENGTH)
                                        exitForkWithError("Жёлтый", "Не могу записать в FIFO!", &mainPid);
                                    printf("Жёлтый: Передал через FIFO строку %s", buf);
                                }
                            }
                            close(fd);
                            //конец фифо
                            exitFork("Жёлтый", &mainPid);
                    }
                default:
                    perror("Чёт ошибка какая-то о_О");
            }
        }
    }
    printInfo("Голубой", NULL);
    if ((sem1 = sem_open(VIOLSEM, O_CREAT, 0666, 0)) == SEM_FAILED)
        exitParentWithError("Голубой", "Не могу открыть бинарный семафор\n");
    while (closeProc < 4)
        sigsuspend(&sign);
    sem_post(sem1);
    sem_close(sem1);
    return exitParent("Голубой");
}
 
void two(int signo)
{
    fprintf(stderr, "Голубой: Получен сигнал завершения дочернего процесса\n");
    fprintf(stderr, "Голубой: Общее число подпроцессов: %d\n", runProc - ++closeProc);
}
 
void one(int signo)
{
    fprintf(stderr, "Голубой: Получен сигнал запуска дочернего процесса\n");
    fprintf(stderr, "Голубой: Общее число подпроцессов: %d\n", ++runProc - closeProc);
}
 
void Move_n_sym(const char fileName[])
{
    char p1[256], p2[256];
    sprintf(p1, "%s/%s", path, fileName);
    if (rename(fileName, p1) == -1)
        exitForkWithError("Фиолетовый", "Не могу переместить файл", NULL);
    sprintf(p2, "%s%s", c, fileName);
    symlink(p1, p2);
}
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
12.05.2016, 16:00
Помогаю со студенческими работами здесь

Fork создание процессов
Скажите, я правильно написал программку, создающую процессы? /*UTS*/ #include &lt;unistd.h&gt; #include &lt;sys/types.h&gt; #include...

Генерация древа процессов используя fork
Битый час уже пытаюсь создать древо процессов по заданному образцу (0 1 1 2 2 5 6). То есть первый процесс не имеет родителя среди ваших...

Функция fork() - определить, сколько процессов будет порождено
Здравствуйте! Чувствую, что не в тот раздел пишу, но тем не менее, возник вопрос: если порождать новый процесс таким образом, то получится...

Параллельный запуск процессов с помощью fork(). Проверить код
Правильно ли я накидал параллельный запуск (в данном случае 10 ) процессов с помощью fork() ? if(pipe(filedes) == -1) { ...

Создание новых процессов, запуск внешних программ fork(), system
Задача запустить внешнее приложение и получить его ID, для того чтобы в дальнейшем отследить живо оно или нет. Почему-то получаю _всегда_...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
11
Ответ Создать тему
Новые блоги и статьи
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Access
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru