Читать «UNIX: взаимодействие процессов» онлайн - страница 60
Уильям Ричард Стивенс
2 int
3 main(int argc, char **argv)
4 {
5 if (argc != 2)
6 err_quit("usage: mqunlink <name>");
7 Mq_unlink(argv[1]);
8 exit(0);
9 }
С помощью этой программы мы можем удалить очередь сообщений, созданную программой mqcreate1:
solaris % mqunlink /temp.1234
При этом будут удалены все три файла из каталога /tmp, которые относятся к этой очереди.
5.3. Функции mq_getattr и mq_setattr
У каждой очереди сообщений имеются четыре атрибута, которые могут быть получены функцией mq_getattr и установлены (по отдельности) функцией mq_setattr:
#include <mqueue.h>
int mq_getattr(mqd_t
int mq_setattr(mqd_t
/* Обе функции возвращают 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 присваивает полям структуры, на которую указывает
Функция mq_setattr устанавливает атрибуты очереди, но фактически используется только поле mqflags той структуры, на которую указывает
Кроме того, если указатель
Пример: программа mqgetattr
Программа из листинга 5.3 открывает указанную очередь сообщений и выводит значения ее атрибутов.
Листинг 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 <name>");
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.