Листинг 5.11. Использование mq_notify совместно с sigwait
//pxmsg/mqnotifysig4.c
1 #include "unpipc.h"
2 int
3 main(int argc, char **argv)
4 {
5 int signo;
6 mqd_t mqd;
7 void *buff;
8 ssize_t n;
9 sigset_t newmask;
10 struct mq_attr attr;
11 struct sigevent sigev;
12 if (argc != 2)
13 err_quit("usage: mqnotifysig4
14 /* открытие очереди, получение атрибутов, выделение буфера */
15 mqd = Mq_open(argv[1], O_RDONLY | O_NONBLOCK);
16 Mq_getattr(mqd, &attr);
17 buff = Malloc(attr.mq_msgsize);
18 Sigemptyset(&newmask);
19 Sigaddset(&newmask, SIGUSR1);
20 Sigprocmask(SIG_BLOCK, &newmask, NULL); /* блокируем SIGUSR1 */
21 /* установка обработчика, включение уведомления */
22 sigev.sigev_notify = SIGEV_SIGNAL;
23 sigev.sigev_signo = SIGUSR1;
24 Mq_notify(mqd, &sigev);
25 for (;;) {
26 Sigwait(&newmask, &signo);
27 if (signo == SIGUSR1) {
28 Mq_notify(mqd, &sigev); /* перерегистрируемся */
29 while ((n = mq_receive(mqd, buff, attr.mq_msgsize, NULL)) >= 0) {
30 printf("read %ld bytes\n", (long) n);
31 }
32 if (errno != EAGAIN)
33 err_sys("mq_receive error");
34 }
35 }
36 exit(0);
37 }