Читать «UNIX: взаимодействие процессов» онлайн - страница 81

26-32 Экземпляр такой структуры динамически создается функцией mq_open при открытии очереди и удаляется mq_close. Поле mqi_hdr указывает на отображаемый файл (адрес начала файла возвращается mmap). Указатель на эту структуру имеет основной в нашей реализации тип mqd_t, он принимает значение, возвращаемое mq_open.

Поле mqi_magiс принимает значение MQI_MAGIC в момент инициализации структуры. Это значение проверяется всеми функциями, которым передается указатель типа mqd_t, что дает им возможность удостовериться, что указатель действительно указывает на структуру типа mq_infо. mqi_flags содержит флаг отключения блокировки для открывшего очередь процесса.

Макрос MSGSIZE

33-34 В целях выравнивания содержимого файла (alignment) мы располагаем начало каждого сообщения так, чтобы его индекс был кратен размеру длинного целого. Следовательно, если максимальный размер сообщения не допускает такого выравнивания, мы добавляем к нему от 1 до 3 байт, как показано на рис. 5.2. При этом предполагается, что размер длинного целого — 4 байт (что верно для Solaris 2.6). Если размер длинного целого 8 байт (в Digital Unix 4.0B), нам придется добавлять к каждому сообщению от 1 до 7 байт.

Функция mq_open

В листинге 5.17 приведен текст первой части функции mq_open, создающей новую очередь сообщений или открывающей существующую.

Листинг 5.17. Функция mq_open: первая часть

//my_pxmsg._mmap/mq_open. с
1  #include "unpipc.h"
2  #include "mqueue.h"
3  #include <stdarg.h>
4  #define MAX_TRIES 10
5  struct mymq_attr defattr =
6   { 0, 128, 1024, 0 };
7  mymqd_t
8  mymq_open(const char *pathname, int oflag, …)
9  {
10  int i, fd, nonblock, created, save_errno;
11  long msgsize, filesize, index;
12  va_list ap;
13  mode_t mode;
14  int8_t *mptr;
15  struct stat statbuff;
16  struct mymq_hdr *mqhdr;
17  struct mymsg_hdr *msghdr;
18  struct mymq_attr *attr;
19  struct mymq_info *mqinfo;
20  pthread_mutexattr_t mattr;
21  pthread_condattr_t cattr;
22  created = 0;
23  nonblock = oflag & O_NONBLOCK;
24  oflag &= ~O_NONBLOCK;
25  mptr = (int8_t *) MAP_FAILED;
26  mqinfo = NULL;
27 again:
28  if (oflag & O_CREAT) {
29   va_start(ap, oflag); /* ар инициализируется последним аргументом */
30   mode = va_arg(ap, va_mode_t) & ~S_IXUSR;
31   attr = va_arg(ap, struct mymq_attr *);
32   va_end(ap);
33   /* открытие с установкой бита user-execute */
34   fd = open (pathname, oflag | O_EXCL | O_RDWR, mode | S_IXUSR);
35   if (fd < 0) {
36    if (errno == EEXIST && (oflag & O_EXCL) == 0)
37     goto exists; /* уже существует, OK */
38    else
39     return((mymqd_t) –1);
40   }
41   created = 1;
42   /* при создании файла он инициализируется */
43   if (attr == NULL)
44    attr = &defattr;
45   else {
46    if (attr->mq_maxmsg <– 0 || attr->mq_msgsize <= 0) {
47     errno = EINVAL;
48     goto err;
49    }
50   }

Обработка списка аргументов переменного размера

29-32 Функция может быть вызвана либо с двумя, либо с четырьмя аргументами в зависимости от того, указан ли флаг O_CREAT. Если флаг указан, третий аргумент имеет тип mode_t, а это простой системный тип, являющийся одним из целых типов. При этом мы столкнемся с проблемой в BSD/OS, где этот тип данных определен как unsigned short (16 бит). Поскольку целое в этой реализации занимает 32 бита, компилятор С увеличивает аргумент этого типа с 16 до 32 бит, потому что все короткие целые в списке аргументов увеличиваются до обычных целых. Но если мы укажем mode_t при вызове va_arg, он пропустит 16 бит аргумента в стеке, если этот аргумент был увеличен до 32 бит. Следовательно, мы должны определить свой собственный тип данных, va_mode_t, который будет целым в BSD/OS и типом mode_t в других системах. Эту проблему с переносимостью решают приведенные ниже строки нашего заголовка unpipc.h (листинг В.1):