求解signal()函数在接收到第一次信号后还能正常处理之后的信号吗？

nick_lhy

问题以前也遇到过，但一直没怎么弄清楚，这次在学习UNP V2的Posix消息队列时又碰到，不能忍了
要看的主要是mqnotifysignal.c,其余mqcreate.c和mqsend.c在测试时需要，我代码里用的是APUE的头文件，没有的可以把err_sys,err_quit替换成printf，编译时要加上 -lrt 这个链接库，之后可能还要挂载消息队列文件系统 mount -t mqueue none /mnt 。。。

代码如下：

1. 
   
2. /* mqcreate.c */
   
3. #include  <apue.h>
   
4. #include  <mqueue.h>
   
5. 
   
6. struct mq_attr attr;
   
7. 
   
8. int main(int argc, char *argv[])
   
9. {
   
10.         char c;
    
11.         int flags;
    
12.         mqd_t mqd;
    
13. 
    
14.         flags = O_RDWR | O_CREAT;
    
15.         while( (c = getopt(argc, argv, "em:z:")) != -1 )
    
16.         {
    
17.                 switch ( c )
    
18.                 {
    
19.                         case 'e' :
    
20.                                 flags |= O_EXCL;
    
21.                                 break;
    
22.                         case 'm' :
    
23.                                 attr.mq_maxmsg = atol(optarg);
    
24.                                 break;
    
25.                         case 'z':
    
26.                                 attr.mq_msgsize = atol(optarg);
    
27.                                 break;
    
28.                         default :
    
29.                                 break;
    
30.                 }
    
31.         }
    
32. 
    
33.         if(optind != argc - 1)
    
34.                 err_quit("usage: mqcreate [-e] [-m maxmsg -z msgsize] <name>");
    
35. 
    
36.         if( (attr.mq_maxmsg != 0 && attr.mq_msgsize == 0) ||
    
37.                         (attr.mq_maxmsg == 0 && attr.mq_msgsize != 0))
    
38.                 err_quit("must specify both -m maxmsg and -z msgsize");
    
39. 
    
40.         if( (mqd = mq_open(argv[optind], flags, FILE_MODE, (attr.mq_maxmsg != 0) ? &attr : NULL)) < 0 )
    
41.                 err_sys("mq_open error");
    
42. 
    
43.         mq_close(mqd);
    
44. 
    
45.         exit(0);
    
46. }

复制代码

1. 
   
2. /* mqsend.c */
   
3. #include  <apue.h>
   
4. #include  <mqueue.h>
   
5. 
   
6. int main(int argc, char *argv[])
   
7. {
   
8.         mqd_t mqd;
   
9.         void *ptr;
   
10.         size_t len;
    
11.         unsigned int prio;
    
12. 
    
13.         if(argc != 4)
    
14.                 err_quit("usage: mqsend <name> <#bytes> <priority>");
    
15. 
    
16.         len = atoi(argv[2]);
    
17.         prio = atoi(argv[3]);
    
18. 
    
19.         if( (mqd = mq_open(argv[1], O_WRONLY)) < 0 )
    
20.                 err_sys("mq_open error");
    
21. 
    
22.         if( (ptr = calloc(len, sizeof(char))) == NULL )
    
23.                 err_sys("calloc error");
    
24. 
    
25.         if(mq_send(mqd, ptr, len, prio) < 0)
    
26.                 err_sys("mq_send error");
    
27. 
    
28.         exit(0);
    
29. }

复制代码

1. 
   
2. /* mqnotifysignal.c */
   
3. #include  <apue.h>
   
4. #include  <mqueue.h>
   
5. 
   
6. mqd_t mqd;
   
7. void *buff;
   
8. struct mq_attr attr;
   
9. struct sigevent sigev;
   
10. 
    
11. static void sig_usr1(int);
    
12. 
    
13. int main(int argc, char *argv[])
    
14. {
    
15.         if(argc != 2)
    
16.                 err_quit("usage: mqnotifysignal <name>");
    
17. 
    
18.         if( (mqd = mq_open(argv[1], O_RDONLY)) < 0 )
    
19.                 err_sys("mq_open error");
    
20.         if( mq_getattr(mqd, &attr) < 0 )
    
21.                 err_sys("mq_getattr error");
    
22.         if( (buff = malloc(attr.mq_msgsize)) == NULL )
    
23.                 err_sys("malloc error");
    
24. 
    
25.         if( signal(SIGUSR1, sig_usr1) < 0 )
    
26.                 err_sys("signal error");
    
27.         sigev.sigev_notify = SIGEV_SIGNAL;
    
28.         sigev.sigev_signo = SIGUSR1;
    
29.         if( mq_notify(mqd, &sigev) < 0 )
    
30.                 err_sys("mq_notify error");
    
31. 
    
32.         while(1)
    
33.                 pause();
    
34. 
    
35.         exit(0);
    
36. }
    
37. 
    
38. static void sig_usr1(int signo)
    
39. {
    
40.         ssize_t n;
    
41. 
    
42.         if( mq_notify(mqd, &sigev) < 0 )
    
43.                 err_sys("mq_notify error");
    
44. 
    
45.         if( (n = mq_receive(mqd, buff, attr.mq_msgsize, NULL)) < 0 )
    
46.                 err_sys("mq_receive error");
    
47.         printf("SIGUSR1 received, read %ld bytes\n", (long)n);
    
48. 
    
49.         return;
    
50. }

复制代码

测试结果是：
./mqcreate -m 10 -z 8192 /test
./mqnotifysignal /test1
现在在另一个控制台下:
./mqsend /test1 100 50   (正常，显示 “SIGUSR1 received, read 100 bytes”)
./mqsend /test1 100 50   (第二次就不正常了，显示 “User defined signal 1”)

现在如果把signal函数移动到while循环下，就可以正常每次都接收到消息，求解啊！

1. while(1)
   
2.         {
   
3.                 if( signal(SIGUSR1, sig_usr1) < 0 )
   
4.                         err_sys("signal error");
   
5.                 pause();
   
6.         }

复制代码

MMMIX

回复 1# nick_lhy


    signal() 現在就不要再用了，用 sigaction() 吧。你的問題，看看 signal() 的手冊就清楚了。

nick_lhy

回复 2# MMMIX


   好吧，以后都得用sigaction了看来

djsxut

APUE 里面也有说，signal处理信号后，需要在信号处理函数中重新安装处理程序。用sigaction好。