Листинг 5.16. Заголовочный файл mqueue.h
//my_pxmsg_mmap/mqueue.h
1 typedef struct mymq_info *mymqd_t;
2 struct mymq_attr {
3 long mq_flags; /* флаг очереди : O_NONBLOCK */
4 long mq_maxmsg; /* максимальное количество сообщений в очереди */
5 long mq_msgsize; /* максимальный размер сообщения в байтах */
6 long mq_curmsgs; /* количество сообщений в очереди */
7 };
8 /* одна структура mymq_hdr{} на очередь, в начале отображаемого файла */
9 struct mymq_hdr {
10 struct mymq_attr mqh_attr; /* атрибуты очереди */
11 long mqh_head; /* индекс первого сообщения*/
12 long mqh_free; /* индекс первого пустого сообщения */
13 long mqh_nwait; /* количество заблокированных mq_receive() потоков */
14 pid_t mqh_pid; /* ненулевой PID. если включено уведомление */
15 struct sigevent mqh_event; /* для mq_notify() */
16 pthread_mutex_t mqh_lock; /* блокировка: mutex*/
17 pthread_cond_t mqh_wait; /* и условная переменная */
18 };
19 /* один mymsg_hdr{} в начале каждого сообщения */
20 struct mymsg_hdr {
21 long msg_next; /* индекс следующего сообщения в списке */
22 /* msg_next должно быть первым полем в структуре */
23 ssize_t msg_len; /* реальная длина */
24 unsigned int msg_prio; /* приоритет */
25 };
26 /* одна mymq_info{} выделяется при каждом mq_open() */
27 struct mymq_info {
28 struct mymq_hdr *mqi_hdr; /* начало отображаемого файла */
29 long mqi_magic; /* магическое значение после инициализации */
30 int mqi_flags; /* флаги для данного процесса */
31 };
32 #define MQI_MAGIC 0x98765432
33 /* размер сообщения округляется для подгонки */
34 #define MSGSIZE(i) ((((i) + sizeof(long)-1) / sizeof(long)) * sizeof(long))
Рис. 5.2. Схема структур данных, используемых при реализации очередей сообщений posix через отображаемый в память файл