UNIX: взаимодействие процессов

24 }
25 /* перед удалением находим максимальное значение, используя sid[0] */
26 for (j = 7; j < MAX_VALUE; j += 8) {
27 arg.val = j;
28 if (semctl(sid[0], 0, SETVAL, arg) == –1) {
29 semvmx = j – 8;
30 printf("max semaphore value = %d\n", semvmx);
31 break;
32 }
33 }
34 for (j = 0; j < i; j++)
35 Semctl(sid[j], 0, IPC_RMID);
36 /* определяем максимальное количество семафоров в наборе */
37 for (i = 1; i <= MAX_MEMBERS; i++) {
38 semid = semget(IPC_PRIVATE, i, SVSEM_MODE | IPC_CREAT);
39 if (semid == –1) {
40 semmsl = i-1;
41 printf("max of %d members per set\n", semmsl);
42 break;
43 }
44 Semctl(semid, 0, IPC_RMID);
45 }
46 /* сколько всего семафоров можно создать? */
47 semmns = 0;
48 for (i = 0; i < semmni; i++) {
49 sid[i] = semget(IPC_PRIVATE, semmsl, SVSEM_MODE | IPC_CREAT);
50 if (sid[i] == –1) {
51 /*
52 До этого в наборе было semmsl элементов,
53 но теперь мы уменьшаем количество элементов на 1 и смотрим.
54 не получится ли создать семафор
55 */
56 for (j = semmsl-1; j > 0; j--) {
57 sid[1] = semget(IPC_PRIVATE, j, SVSEM_MODE | IPC_CREAT);
58 if (sid[i] != –1) {
59 semmns += j;
60 printf("max of %d semaphores\n", semmns);
61 Semctl(sid[i], 0, IPC_RMID);
62 goto done;
63 }
64 }
65 err_quit("j reached 0, semmns = %d", semmns);
66 }
67 semmns += semmsl;
68 }
69 printf("max of %d semaphores\n", semns);
70 done:
71 for (j = 0; j < i; j++)
72 Semctl(sid[j], 0, IPC_RMID);
73 /* определяем количество операций за вызов semop */
74 semid = Semget(IPC_PRIVATE, semmsl, SVSEM_MODE | IPC_CREAT);
75 for (i = 1; i <= MAX_NOPS; i++) {
76 ops[i-1].sem_num = i-1;
77 ops[i-1].sem_op = 1;
78 ops[i-1].sem_flg = 0;
79 if (semop(semid, ops, i) += –1) {
80 if (errno != E2BIG)
81 err_sys("expected E2BIG from semop");
82 semopn = i-1;
83 printf("max of %d operations per semop\n", semopn);
84 break;
85 }
86 }
87 Semctl(semid, 0, IPC_RMID);
88 /* определение максимального значения semadj */
89 /* создание одного набора с одним семафором */
90 semid = Semget(IPC_PRIVATE, 1, SVSEM_MODE | IPC_CREAT);
91 arg.val = semvmx;
92 Semctl(semid, 0, SETVAL, arg); /* устанавливаем значение на максимум */
93 for (i = semvmx-1; i > 0; i--) {
94 ops[0].sem_num = 0;
95 ops[0].sem_op = –i;
96 ops[0].sem_flg = SEM_UNDO;
97 if (semop(semid, ops, 1) != –1) {
98 semaem = i;
99 printf("max value of adjust-on-exit = %d\n", semaem);
100 break;
101 }
102 }
103 Semctl(semid, 0, IPC_RMID);
104 /* определение максимального количества структур UNDO */
105 /* создаем один набор с одним семафором и инициализируем нулем */
106 semid = Semget(IPC_PRIVATE, 1, SVSEM_MODE | IPC_CREAT);
107 arg.val = 0;
108 Semctl(semid, 0, SETVAL, arg); /* установка значения семафора в 0 */
109 Pipe(pipefd);
110 child = Malloc(MAX_NPROC * sizeof(pid_t));
111 for (i = 0; i < MAX_NPROC; i++) {
112 if ((child[i] = fork) == –1) {
113 semmnu = i – 1;
114 printf("fork failed, semmnu at least %d\n", semmnu);
115 break;
116 } else if (child[i] == 0) {
117 ops[0].sem_num = 0; /* дочерний процесс вызывает semop */
118 ops[0].sem_op = 1;
119 ops[0].sem_flg = SEM_UNDO;
120 j = semop(semid, ops, 1); /* 0 в случае успешного завершения. –1 – в случае ошибки */
121 Write(pipefd[1], &j, sizeof(j));
122 sleep(30); /* ожидает завершения родительским процессом */
123 exit(0); /* на всякий случай */
124 }
125 /* родительский процесс считывает результат вызова semop */
126 Read(pipefd[0], &j, sizeof(j));
127 if (j == –1) {
128 semmnu = i;
129 printf("max # undo structures = %d\n", semmnu);