Листинг 6.21. Определение системных ограничений для очередей сообщений System V
//svmsg/limits.c
1 #include "unpipc.h"
2 #define MAX_DATA 64*1024
3 #define MAX_NMESG 4096
4 #define MAX_NIDS 4096
5 int max_mesg;
6 struct mymesg {
7 long type;
8 char data[MAX_DATA];
9 } mesg;
10 int
11 main(int argc, char **argv)
12 {
13 int i, j, msqid, qid[MAX_NIDS];
14 /* определение максимального размера сообщения */
15 msqid = Msgget(IPC_PRIVATE, SVMSG_MODE | IPC_CREAT);
16 mesg.type = 1;
17 for (i = MAX_DATA; i > 0; i –= 128) {
18 if (msgsnd(msqid, &mesg, i, 0) == 0) {
19 printf("maximum amount of data per message = %d\n", i);
20 max_mesg = i;
21 break;
22 }
23 if (errno != EINVAL)
24 err_sys("msgsnd error for length %d", i);
25 }
26 if (i == 0)
27 err_quit("i == 0");
28 Msgct(lmsqid, IPC_RMID, NULL);
29 /* количество сообщений в очереди */
30 mesg.type = 1;
31 for (i = 8; i <= max_mesg; i *= 2) {
32 msqid = Msgget(IPC_PRIVATE, SVMSG_MODE | IPC_CREAT);
33 for (j = 0; j < MAX_NMESG; j++) {
34 if (msgsnd(msqid, &mesg, i, IPC_NOWAIT) != 0) {
35 if (errno == EAGAIN)
36 break;
37 err_sys("msgsnd error, i = %d, j = %d", i, j);
38 break;
39 }
40 }
41 printf("%d %d-byte messages were placed onto queue,", j, i);
42 printf(" %d bytes total\n". i*j);
43 Msgctl(msqid, IPC_RMID, NULL);
44 }
45 /* максимальное количество идентификаторов */
46 mesg.type = 1;
47 for (i = 0; i <= MAX_NIDS; i++) {
48 if ((qid[i] = msgget(IPC_PRIVATE, SVMSG_MODE | IPC_CREAT)) == –1) {
49 printf("%d identifiers open at once\n", i);
50 break;
51 }
52 }
53 for (j = 0; j < i; j++)
54 Msgctl(qid[j], IPC_RMID, NULL);
55 exit(0);
56 }