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

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; // текущее количество сообщений в очереди

}

Указатель на такую структуру может быть передан в качестве четвертого аргумента mq_open, что дает возможность установить параметры mq_maxmsg и mq_msgsize в момент создания очереди. Другие два поля структуры функцией mq_open игнорируются.

Функция mq_getattr присваивает полям структуры, на которую указывает attr, текущие значения атрибутов очереди.

Функция mq_setattr устанавливает атрибуты очереди, но фактически используется только поле mqflags той структуры, на которую указывает attr, что дает возможность сбрасывать или устанавливать флаг запрета блокировки. Другие три поля структуры игнорируются: максимальное количество сообщений в очереди и максимальный размер сообщения могут быть установлены только в момент создания очереди, а количество сообщений в очереди можно только считать, но не изменить.

Кроме того, если указатель oattr ненулевой, возвращаются предыдущие значения атрибутов очереди (mq_flags, mq_maxmsg, mq_msgsize) и текущий статус очереди (mq_curmsgs).

Программа из листинга 5.3 открывает указанную очередь сообщений и выводит значения ее атрибутов.

//pxmsg/mqgetattr.c

1 #include "unpipc.h"

2 int

3 main(int argc, char **argv)

4 {

5 mqd_t mqd;

6 struct mq_attr attr;

7 if (argc != 2)

8 err_quit("usage: mqgetattr ");

9 mqd = Mq_open(argv[1], O_RDONLY);

10 Mq_getattr(mqd, &attr);

11 printf ("max #msgs = %ld, max #bytes/msg = %ld, "

12 "#currently on queue = %ld\n",

13 attr.mq_maxmsg, attr.mq_msgsize, attr.mq_curmsgs);

14 Mq_close(mqd);

15 exit(0);

16 }

Мы можем создать очередь сообщений и вывести значения ее атрибутов, устанавливаемые по умолчанию:

solaris % mqcreate1 /hello.world

solaris % mqgetattr /hello.world

max #msgs = 128, max #bytes/msg = 1024, #currently on queue = 0

Вспомним размер одного из файлов очереди, созданной с использованием устанавливаемых по умолчанию значений атрибутов. Он был выведен командой ls в примере после листинга 5.1. Это значение можно получить как 128×1024+1560 = 132632.

Добавочные 1560 байт представляют собой, скорее всего, дополнительную информацию: 8 байт на сообщение плюс добавочные 536 байт.

Мы можем изменить программу из листинга 5.1 таким образом, чтобы при создании очереди иметь возможность указывать максимальное количество сообщений и максимальный размер сообщения. Мы не можем указать только один из этих параметров; нужно обязательно задать оба (см., впрочем, упражнение 5.1). В листинге 5.4 приведен текст новой программы.

//pxmsg/mqcreate.c

1 #include "unpipc.h"

2 struct mq_attr attr; /* mq_maxmsg и mq_msgsize инициализируются О */

3 int

4 main(int argc, char **argv)

5 {

6 int с flags;

7 mqd_t mqd;

8 flags = O_RDWR | O_CREAT;

9 while ((c = Getopt(argc, argv, "em:z:")) != –1) {

10 switch (c) {

11 case 'e':

12 flags |= O_EXCL;

13 break;

14 case 'm':

15 attr.mq_maxmsg = atol(optarg);

16 break;

17 case 'z':

18 attr.mq_msgsize = atol(optarg);

19 break;

20 }

21 }

22 if (optind != argc – 1)

23 err_quit("usage: mqcreate [ –е ] [ –m maxmsg –z msgsize ] ");