Уильям Стивенс - UNIX - взаимодействие процессов

ПРИМЕЧАНИЕ

Мы увидим, что если очередь сообщений реализована через отображаемые в память файлы (раздел 12.2), она может обладать живучестью файловой системы, но это не является обязательным и рассчитывать на это нельзя.

Поскольку очереди сообщений Posix обладают по крайней мере живучестью ядра, можно написать набор небольших программ для работы с ними — с этими программами будет проще экспериментировать. Программа из листинга 5.1 [1] Все исходные тексты, опубликованные в этой книге, вы можете найти по адресу http://www.piter.com/download. создает очередь сообщений, имя которой принимается в качестве аргумента командной строки.

//pxmsg/mqcreate1.с

1 #include "unpipc.h"

2 int

3 main(int argc, char **argv)

4 {

5 int с flags:

6 mqd_t mqd;

7 flags = O_RDWR | O_CREAT;

8 while ((c = Getopt(argc, argv, "e")) != –1) {

9 switch (c) {

10 case 'e':

11 flags |= O_EXCL;

12 break;

13 }

14 }

15 if (optind != argc – 1)

16 err_quit("usage: mqcreate [ –e ] ");

17 mqd = Mq_open(argv[optind], flags, FILE_MODE, NULL);

18 Mq_close(mqd);

19 exit(0);

20 }

В командной строке можно указать параметр –е, управляющий исключающим созданием очереди. (О функции getopt и нашей обертке Getopt рассказано более подробно в комментарии к листингу 5.5.) При возвращении функция getopt сохраняет в переменной optind индекс следующего аргумента, подлежащего обработке.

Мы вызываем функцию mq_open, указывая ей в качестве имени IPC полученный из командной строки параметр, не обращаясь к рассмотренной нами в разделе 2.2 функции px_ipc_name. Это даст нам возможность узнать, как в данной реализации обрабатываются имена Posix IPC (мы используем для этого наши маленькие тестовые программы на протяжении всей книги).

Ниже приведен результат работы программы в Solaris 2.6:

solaris % mqcreate1 /temp.1234 очередь успешно создается

solaris % ls -l /tmp/.*1234

-rw-rw-rw– 1 rstevens other1 132632 Oct 23 17:08 /tmp/.MQDtemp.1234

-rw-rw-rw– 1 rstevens other1 0 Oct 23 17:08 /tmp/.MQLtemp.1234

-rw-r--r-- 1 rstevens other1 0 Oct 23 17:08 /tmp/.MQPDtemp.1234

solaris % mqcreate1 –e /temp.1234 очередь уже создана

mq_open error for /temp.1234: File exists

Мы назвали эту версию программы mqcreate1, поскольку она будет улучшена в листинге 5.4, после того как мы обсудим использование атрибутов очереди. Разрешения на доступ к третьему файлу определяются константой FILE_MODE (чтение и запись для пользователя, только чтение для группы и прочих пользователей), но у двух первых файлов разрешения отличаются. Можно предположить, что в файле с буквой D в имени хранятся данные; файл с буквой L представляет собой какую-то блокировку, а в файле с буквой Р хранятся разрешения.

В Digital Unix 4.0B мы указываем действительное имя создаваемого файла:

alpha % mqcreate1 /tmp/myq.1234 очередь успешно создается

alpha % ls –l /tmp/myq.1234

-rw-r--r-- 1 rstevens system 11976 Oct 23 17:04 /tmp/myq.1234

alpha % mqcreate1 –e /tmp/myq.1234 очередь уже создана

mq_open error for /tmp/myq.1234: File exists

В листинге 5.2 приведена программа mqunlink, удаляющая из системы очередь сообщений.

//pxmsg/mqunlink.c

1 #include "unpipc.h"

2 int

3 main(int argc, char **argv)

4 {

5 if (argc != 2)

6 err_quit("usage: mqunlink ");

7 Mq_unlink(argv[1]);

8 exit(0);

9 }

С помощью этой программы мы можем удалить очередь сообщений, созданную программой mqcreate1:

solaris % mqunlink /temp.1234

При этом будут удалены все три файла из каталога /tmp, которые относятся к этой очереди.

У каждой очереди сообщений имеются четыре атрибута, которые могут быть получены функцией mq_getattr и установлены (по отдельности) функцией mq_setattr:

#include

int mq_getattr(mqd_t mqdes , struct mq_attr * attr );

int mq_setattr(mqd_t mqdes , const struct mq_attr * attr , struct mq_attr * oattr );

/* Обе функции возвращают 0 в случае успешного завершения; –1 – в случае возникновения ошибок */

Структура mq_attr хранит в себе эти четыре атрибута:

struct mq_attr {

long mq_flags; /* флаг очереди: 0, O_NONBLOCK */

long mq_maxmsg; /* максимальное количество сообщений в очереди */

long mq_msgsize; /* максимальный размер сообщения (в байтах) */

long mq_curmsgs; // текущее количество сообщений в очереди