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

Стивенс Уильям Ричард
Шрифт:

Мы создаем указатель на структуру msgbuf общего вида, а затем выделяем место под реальную структуру (буфер записи) соответствующего размера, вызвав calloc. Эта функция инициализирует буфер нулем.

Листинг 6.3. Помещение сообщения в очередь System V

//svmsg/msgsnd.c

1 #include "unpipc.h"

2 int

3 main(int argc, char **argv)

4 {

5 int mqid;

6 size_t len;

7 long type;

8 struct msgbuf *ptr;

9 if (argc != 4)

10 err_quit("usage: msgsnd <pathname> <#bytes> <type>");

11 len = atoi(argv[2]);

12 type = atoi(argv[3]);

13 mqid = Msgget(Ftok(argv[1], 0), MSG_W);

14 ptr = Calloc(sizeof(long) + len, sizeof(char));

15 ptr->mtype = type;

16 Msgsnd(mqid, ptr, len, 0);

17 exit(0);

18 }

Программа msgrcv

В листинге 6.4 приведен текст программы msgrcv, считывающей сообщение из очереди. В командной строке может быть указан параметр –n, отключающий блокировку, а параметр –t может быть использован для указания типа сообщения в функции msgrcv.

2 Не существует простого способа определить максимальный размер сообщения (об этом и других ограничениях мы поговорим в разделе 6.10), поэтому мы определим свою собственную константу.

Листинг 6.4. Считывание сообщения из очереди System V

//svmsg/msgrcv.c

1 #include "unpipc.h"

2 #define MAXMSG (8192 + sizeof(long))

3 int

4 main(int argc, char **argv)

5 {

6 int c, flag, mqid;

7 long type;

8 ssize_t n;

9 struct msgbuf *buff;

10 type = flag = 0;

11 while ((c = Getopt(argc, argv, "nt:")) != –1) {

12 switch (c) {

13 case 'n':

14 flag |= IPC_NOWAIT;

15 break;

16 case 't':

17 type = atol(optarg);

18 break;

19 }

20 }

21 if (optind != argc – 1)

22 err_quit("usage: msgrcv [ –n ] [ –t type ] <pathname>");

23 mqid = Msgget(Ftok(argv[optind], 0), MSG_R);

24 buff = Malloc(MAXMSG);

25 n = Msgrcv(mqid, buff, MAXMSG, type, flag);

26 printf("read %d bytes, type = %ld\n", n, buff->mtype);

27 exit(0);

28 }

Программа msgrmid

Для удаления очереди сообщений мы вызываем функцию msgctl с командой IPC_RMID, как показано в листинге 6.5.

Листинг 6.5. Удаление очереди сообщений System V

//svmsg/msgrmid.c

1 #include "unpipc.h"

2 int

3 main(int argc, char **argv)

4 {

5 int mqid;

6 if (argc != 2)

7 err_quit("usage: msgrmid <pathname>");

8 mqid = Msgget(Ftok(argv[1], 0), 0);

9 Msgctl(mqid, IPC_RMID, NULL);

10 exit(0);

11 }

Примеры

Теперь воспользуемся четырьмя только что написанными программами. Создадим очередь и поместим в нее три сообщения:

solaris % msgcreate /tmp/no/such/file

ftok error for pathname "tmp/no/such/file" and id 0: No such file or directory

solaris % touch /trap/test1

solaris % msgcreate /tmp/test1