// Очереди сообщений Posix в Linux // Программа из учебника "Системное программирование в среде Linux", Гунько А.В., стр. 118 // Название: mqnotify.c // Описание: уведомление о приходе сообщения в пустую очередь //pxmsg/mqnotify.c #include #include #include #include #include #include #include #include mqd_t mqd; void *buff; struct mq_attr attr; struct sigevent sigev; static void sig_usr1(int); int main(int argc, char **argv) { if (argc != 2) { printf("usage: mqnotifysig "); exit(-1); } /* открываем очередь, получаем атрибуты, выделяем буфер */ mqd = mq_open(argv[1], O_RDONLY); mq_getattr(mqd, &attr); buff = malloc(attr.mq_msgsize); /* устанавливаем обработчик, включаем уведомление */ signal(SIGUSR1, sig_usr1); sigev.sigev_notify = SIGEV_SIGNAL; sigev.sigev_signo = SIGUSR1; mq_notify(mqd, &sigev); printf("Result:%s\n",strerror(errno)); for (;;) pause(); /* все делает обработчик */ exit(0); } static void sig_usr1(int signo) { ssize_t n; mq_notify(mqd, &sigev); /* сначала перерегистрируемся */ n = mq_receive(mqd, buff, attr.mq_msgsize, NULL); printf("SIGUSR1 received, read %ld bytes\n", (long) n); return; }