mqnotify函数

surpassgood

1 #include <mqueue.h>
  2 #include <unistd.h>
  3 #include <stdio.h>
  4 #include <stdlib.h>
  5 #include <pthread.h>
  6 #include <errno.h>
  7
  8 mqd_t mqd;
  9 struct mq_attr attr;
10 struct sigevent sigev;
11
12 static void notify_thread(union sigval);
13
14 int main(int argc,char **argv)
15 {
16     if(argc!=2){
17         printf("usage : mqnotifyread1 <name>";
18         return -1;
19     }
20
21     mqd=mq_open(argv[1],O_RDONLY|O_NONBLOCK);
22     mq_getattr(mqd,&attr);
23

24     sigev.sigev_notify=SIGEV_THREAD;
25     sigev.sigev_value.sival_ptr=NULL;
26     sigev.sigev_notify_function=notify_thread;
27     sigev.sigev_notify_attributes=NULL;
28     mq_notify(mqd,&sigev);
29
30     for(;
31         pause();
32
33     return 0;
34
35 }
36 static void notify_thread(union sigval arg)
37 {
38     ssize_t n;
39     void *buff;
40
41     printf("notify_thread started \n";
42     buff=malloc(attr.mq_msgsize);
43     mq_notify(mqd,&sigev);
44
45     while((n=mq_receive(mqd,buff,attr.mq_msgsize,NULL))>=0)
46     {

47         printf("mq_receive error\n";
48     }
49     if(errno!=EAGAIN){
50         printf("mq_receive error \n";
51     }
52     free(buff);
53     pthread_exit(NULL);
54
55
56
57 }
这段代码是Unix网络编程卷二中的77 的，
我
在一个窗口
[root@localhost 5]# ./mqsend /chao 23 56
在另一个窗口
[root@localhost 5]# ./mqnotifyread1 /chao
notify_thread started
mq_receive error
为什么显示错误，应该是打印你接收到的字节数呀

way030724

45     while((n=mq_receive(mqd,buff,attr.mq_msgsize,NULL))>=0)
46     {

47         printf("mq_receive error\n";
48     }

n为接收到size，收到消息时条件成立，为什么打印error？ 自己的输出描述与逻辑不符吧？