一個(gè)父子進(jìn)程信號(hào)通信的小程序

shiningLoRe

小弟新手, 寫了一個(gè)父子進(jìn)程信號(hào)通信的小程序， 運(yùn)行的時(shí)候有點(diǎn)問題，請(qǐng)大家?guī)兔�看�?br />

1. 
   
2. #include <stdio.h>
   
3. #include <string.h>
   
4. #include <unistd.h>
   
5. #include <stdlib.h>
   
6. #include <sys/types.h>
   
7. #include <sys/stat.h>
   
8. #include <fcntl.h>
   
9. #include <signal.h>
   
10. #include <sys/uio.h>
    
11. #include <sys/wait.h>
    
12. #include <sys/errno.h>
    
13. 
    
14. #define MAXCNT 4
    
15. 
    
16. void sig_usr(int signo)
    
17. {
    
18.         if( signo == SIGCONT)
    
19.                 printf("received SIGCONT\n");
    
20.         else
    
21.                 printf("received unexpected signal(%d)\n", signo);
    
22. 
    
23.         return;
    
24. }
    
25. 
    
26. int main(void)
    
27. {
    
28.         int idx = 0;
    
29.         int status;
    
30. 
    
31.         pid_t pid;
    
32. 
    
33.         if( (pid=fork()) < 0 ) {
    
34.                 printf("fork error\n");
    
35.                 exit(1);
    
36.         }else if (pid == 0) {                   /* child */
    
37.                 while( idx < MAXCNT ) {
    
38.                         if( signal(SIGCONT, sig_usr) == SIG_ERR ) {
    
39.                                 printf("c signal error\n");
    
40.                                 exit(2);
    
41.                         }
    
42.                         printf("child[%d]\n", idx);
    
43.                         fflush(stdout);
    
44.                         if( idx < MAXCNT - 1 ){
    
45.                                 printf("child pause ...\n");
    
46.                                 fflush(stdout);
    
47.                                 kill(getppid(), SIGCONT);
    
48.                                 pause();
    
49.                         }
    
50.                         printf("child up ...\n");
    
51.                         fflush(stdout);
    
52.                         idx++;
    
53.                 }
    
54.                 exit(99);
    
55.         }else {                                 /* parent */
    
56.                 while( idx < MAXCNT ) {
    
57.                         if( signal(SIGCONT, sig_usr) == SIG_ERR ) {
    
58.                                 printf("p signal error\n");
    
59.                                 exit(3);
    
60.                         }
    
61.                         printf("parent[%d]\n", idx);
    
62.                         fflush(stdout);
    
63.                         kill(pid, SIGCONT);
    
64.                         if( idx < MAXCNT - 1 ) {
    
65.                                 printf("parent pause ...\n");
    
66.                                 fflush(stdout);
    
67.                                 kill(pid, SIGCONT);
    
68.                                 pause();
    
69.                         }
    
70.                         printf("parent up ...\n");
    
71.                         fflush(stdout);
    
72.                         idx++;
    
73.                 }
    
74.                 if( waitpid(pid, &status, 0) < 0 ) {
    
75.                         printf("waitpid error\n");
    
76.                         exit(3);
    
77.                 }
    
78.         }
    
79.         return 0;
    
80. }
    

復(fù)制代碼

編譯: gcc -Wall -O2 -o test test.c
運(yùn)行: ./test

1. 
   
2. [root@linux /home/test]./test
   
3. child[0]
   
4. child pause ...
   
5. parent[0]
   
6. parent pause ...
   
7. received SIGCONT
   
8. child up ...
   
9. child[1]
   
10. child pause ...
    
11. received SIGCONT
    
12. parent up ...
    
13. parent[1]
    
14. parent pause ...
    
15. received SIGCONT
    
16. child up ...
    
17. child[2]
    
18. child pause ...
    
19. received SIGCONT
    
20. parent up ...
    
21. parent[2]
    
22. parent pause ...
    
23. received SIGCONT                          <=== seemed hang here
    
24. 
    

復(fù)制代碼

父進(jìn)程在等待之后發(fā)送 SIGCONT, 子進(jìn)程沒有 up,  CTRL+Z stop進(jìn)程之后, fg 在運(yùn)行它又成功了. 希望大家?guī)兔Ψ治鲆幌? 謝謝！

shiningLoRe

1. 
   
2. [root@linux test]# ./test
   
3. child[0]
   
4. child pause ...
   
5. parent[0]
   
6. parent pause ...
   
7. received SIGCONT
   
8. child up ...
   
9. child[1]
   
10. child pause ...
    
11. received SIGCONT
    
12. parent up ...
    
13. parent[1]
    
14. parent pause ...
    
15. received SIGCONT
    
16. child up ...
    
17. child[2]
    
18. child pause ...
    
19. received SIGCONT
    
20. parent up ...
    
21. parent[2]
    
22. parent pause ...
    
23. received SIGCONT
    
24. 
    
25. [1]+  Stopped                 ./test                            <=== CTRL+Z
    
26. 
    
27. [root@linux test]# fg
    
28. ./test
    
29. received SIGCONT
    
30. parent up ...
    
31. parent[3]
    
32. parent up ...
    
33. received SIGCONT
    
34. child up ...
    
35. child[3]
    
36. child up ...
    
37. [root@linux test]# echo $?
    
38. 0
    
39. [root@linux test]#
    

復(fù)制代碼

incle

能不能試一試用別的信號(hào)呢? 比如用戶自定義那幾個(gè).

G00GLE

程序執(zhí)行流程的問題。有時(shí)候會(huì)出現(xiàn)這種情況：

父進(jìn)程還沒掛起，子進(jìn)程就給它發(fā)SIGCOUT信號(hào)，當(dāng)它掛起時(shí)，卻等不到子進(jìn)程的
SIGCOUT信號(hào)，因?yàn)榇藭r(shí)子進(jìn)程也在等待父進(jìn)程的信號(hào)，這樣系統(tǒng)就處于一種死鎖的狀態(tài)了。

具體的問題也就是， signal注冊(cè)信號(hào)和pause掛起之間有個(gè)時(shí)間窗口，在這個(gè)窗口內(nèi)信號(hào)已經(jīng)
發(fā)生過，程序當(dāng)然就一直處于pause狀態(tài)了。

shiningLoRe

SIGCONT 信號(hào)系統(tǒng)默認(rèn)的處理方式可以對(duì)付這個(gè)
SIGUSR1, SIGUSR2 還要在去定義

shiningLoRe

1. 
   
2. child up ...
   
3. child[2]
   
4. child pause ...            <= child pause
   
5. received SIGCONT     <= parent received
   
6. parent up ...
   
7. parent[2]
   
8. parent pause ...
   
9. received SIGCONT     <= child received                   <=== seemed hang here
   

復(fù)制代碼

child 已經(jīng)掛起了, 然后在收到的父進(jìn)程的SIGCONT 信號(hào)的

JohnBull

這時(shí)候應(yīng)該使用可靠信號(hào)語義實(shí)現(xiàn)，用pause有競爭。
man sigsuspend
man sigprocmask

shiningLoRe

謝謝版主提示, 我對(duì)上面的程序做了修改,大致能運(yùn)行正確了, 父子進(jìn)程互相傳遞信號(hào), 交替打印

1. 
   
2. #include <stdio.h>
   
3. #include <string.h>
   
4. #include <unistd.h>
   
5. #include <stdlib.h>
   
6. #include <sys/types.h>
   
7. #include <sys/stat.h>
   
8. #include <fcntl.h>
   
9. #include <signal.h>
   
10. #include <sys/uio.h>
    
11. #include <sys/wait.h>
    
12. #include <sys/errno.h>
    
13. 
    
14. #define MAXCNT 4
    
15. 
    
16. volatile sig_atomic_t    contflag;    /* set nonzero by signal handler */
    
17. 
    
18. void sig_usr(int signo)
    
19. {
    
20.         if( signo == SIGCONT) {
    
21.                 contflag = 1;
    
22.                 printf("received SIGCONT\n");
    
23.         } else
    
24.                 printf("received unexpected signal(%d)\n", signo);
    
25. 
    
26.         return;
    
27. }
    
28. 
    
29. int main(void)
    
30. {
    
31.         int idx = 0;
    
32.         int status;
    
33.         pid_t pid;
    
34. 
    
35.         sigset_t newmask;
    
36.         sigset_t oldmask;
    
37.         sigset_t zeromask;
    
38. 
    
39.         sigemptyset(&zeromask);
    
40.         sigemptyset(&newmask);
    
41.         sigaddset(&newmask, SIGCONT);
    
42.         if( (pid=fork()) < 0 ) {
    
43.                 printf("fork error\n");
    
44.                 exit(1);
    
45.         }else if (pid == 0) {                   /* child */
    
46.                 while( idx < MAXCNT ) {
    
47.                         if( signal(SIGCONT, sig_usr) == SIG_ERR ) {
    
48.                                 printf("c signal error\n");
    
49.                                 exit(2);
    
50.                         }
    
51.                         if (sigprocmask(SIG_BLOCK, &newmask, &oldmask) < 0) {
    
52.                                 printf("SIG_BLOCK error\n");
    
53.                                 exit(1);
    
54.                         }
    
55.                         printf("child[%d]\n", idx);
    
56.                         printf("child pause ...\n");
    
57.                         kill(getppid(), SIGCONT);
    
58.                         while( contflag == 0)
    
59.                                 sigsuspend(&zeromask);
    
60.                         printf("child up ...\n");
    
61.                         contflag = 0;
    
62.                         if( sigprocmask(SIG_SETMASK, &oldmask, NULL) < 0 ) {
    
63.                                 printf("SIG_SETMASK error\n");
    
64.                                 exit(2);
    
65.                         }
    
66.                         idx++;
    
67.                 }
    
68.                 kill(getppid(), SIGCONT);       /* child done */
    
69.                 exit(99);
    
70.         }else {                                 /* parent */
    
71.                 while( idx < MAXCNT ) {
    
72.                         if( signal(SIGCONT, sig_usr) == SIG_ERR ) {
    
73.                                 printf("p signal error\n");
    
74.                                 exit(3);
    
75.                         }
    
76.                         if (sigprocmask(SIG_BLOCK, &newmask, &oldmask) < 0) {
    
77.                                 printf("SIG_BLOCK error\n");
    
78.                                 exit(3);
    
79.                         }
    
80.                         printf("parent pause ...[%d]\n", idx);
    
81.                         kill(pid, SIGCONT);
    
82.                         while( contflag == 0)
    
83.                                 sigsuspend(&zeromask);
    
84.                         printf("parent up ...\n");
    
85.                         contflag = 0;
    
86.                         if( sigprocmask(SIG_SETMASK, &oldmask, NULL) < 0 ) {
    
87.                                 printf("SIG_SETMASK error\n");
    
88.                                 exit(3);
    
89.                         }
    
90.                         idx++;
    
91.                 }
    
92.                 if( waitpid(pid, &status, 0) < 0 ) {
    
93.                         printf("waitpid error\n");
    
94.                         exit(3);
    
95.                 }
    
96.         }
    
97.         return 0;
    
98. }
    
99. 
    

復(fù)制代碼