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

Отображение файла в память

59-63 Файл отображается в память функцией mmap.

Выделение памяти под структуру mq_info

64-66 При каждом вызове mq_open создается отдельный экземпляр mq_infо. Эта структура после создания инициализируется.

Инициализация структуры mq_hdr

67-87 Инициализируется структура mq_hdr. Заголовок связного списка сообщений (mqh_head) инициализируется нулем, а все сообщения в очереди добавляются к списку свободных (mqh_frее).

Инициализация взаимного исключения и условной переменной

88-102 Поскольку очереди сообщений Posix могут использоваться совместно произвольным количеством процессов, которые знают имя очереди и имеют соответствующие разрешения, нам нужно инициализировать взаимное исключение и условную переменную с атрибутом PTHREAD_PROCESS_SHARED. Для этого мы сначала инициализируем атрибуты вызовом pthread_mutexattr_init, а затем устанавливаем значение атрибута совместного использования процессами, вызвав pthread_mutexattr_setpshared. После этого взаимное исключение инициализируется вызовом pthread_mutex_init. Аналогичные действия выполняются для условной переменной. Мы должны аккуратно удалить взаимное исключение и условную переменную даже при возникновении ошибки, поскольку вызовы pthread_ mutexattr_init и pthread_condattr_init выделяют под них память (упражнение 7.3).

Сброс бита user-execute

103-107 После инициализации очереди сообщений мы сбрасываем бит user-execute. Это говорит другим процессам о том, что очередь была проинициализирована. Мы также закрываем файл вызовом close, поскольку он был успешно отображен в память и держать его открытым больше нет необходимости.

В листинге 5.19 приведен конец функции mq_open, в котором осуществляется открытие существующей очереди сообщений.

Листинг 5.19. Третья часть функции mq_open: открытие существующей очереди сообщений

//my_pxmsg_mmap/mq_open.с
109 exists:
110  /* открытие файла и отображение его в память */
111  if ((fd = open(pathname, O_RDWR)) < 0) {
112   if (errno == ENOENT && (oflag & O_CREAT))
113    goto again;
114  goto err;
115  }
116  /* проверяем, что инициализация завершена */
117  for (i = 0; i < MAX TRIES; i++) {
118   if (stat(pathname, &statbuff) == –1) {
119    if (errno == ENOENT && (oflag & O_CREAT)) {
120     close(fd);
121     goto again;
122    }
123    goto err;
124   }
125   if ((statbuff.st_mode & S_IXUSR) == 0)
126   break;
127   sleep(1);
128  }
129  if (i == MAX_TRIES) {
130   errno = ETIMEDOUT;
131   goto err;
132  }
133  filesize = statbuff.st_size;
134  mptr = mmap(NULL, filesize, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
135  if (mptr == MAP_FAILED)
136   goto err;
137  close(fd);