setpgid总是出错

timespace

回复 10# buzzerrookie
解决办法
在wc进程开始处加入：

1. 
   
2. close(pipes[0][0]);
   
3. close(pipes[0][1]);
   

复制代码

main最后一部分改为

1. 
   
2.         close(pipes[0][0]);
   
3.         close(pipes[0][1]);
   
4.         waitpid(pids[1], NULL, 0);
   
5.         close(pipes[1][0]);
   
6.         close(pipes[1][1]);
   
7.         waitpid(pids[2], NULL, 0);
   

复制代码

但还有潜在问题：
1. pipe在进程间的引用关系太乱了。比如wc完全没必要继承pipe[0][...]，还有副作用。wc引用了pipes[0][1]，却没关闭，导致more进程永远阻塞在read(0, ...)，这是你进程退不出的原因。理顺代码，只在必要的时候创建管道，在不用的时候立即关闭
2. 用setpgid有问题。more和/dev/tty有交互，但setpgid使main子进程全部进入单独的后台进程组，不能访问/dev/tty，否则触发SIGTTIN，挂起进程。more这种终端交互命令很少会卡在管道中间，一般在最后执行，还要确保more所在进程组为前台进程组。setpgid在支持&（进入shell后台）功能时才有用，你现在用不到

强烈建议看过APUE相应章节后，模仿shell管道的进程关系，同时理解pipe用法，否则会浪费不少时间。


   

buzzerrookie

回复 11# timespace


    非常感谢，还是得好好看APUE。写这个的目的是操作系统课实验让自己写个类似的简单 shell，其中有一步我用到了这些东西。再次谢谢您。

chllcy88

大哥 我这个代码加了下面这个 还是阻塞在more处 不知道什么原因 忘指点下

在wc进程开始处加入：
close(pipes[0][0]);

close(pipes[0][1]);

1. #include <stdio.h>
   
2. 
   
3. #include <unistd.h>
   
4. 
   
5. #include <sys/wait.h>
   
6. #include <sys/types.h>
   
7. #include <cstdlib>
   
8. #include <iostream>
   
9. using namespace std;
   
10. 
    
11. int isready(int fd)
    
12. {
    
13.         int rc;
    
14.         fd_set fds;
    
15.         struct timeval tv;
    
16. 
    
17.         FD_ZERO(&fds);
    
18.         FD_SET(fd, &fds);
    
19.         tv.tv_sec = 1;
    
20.         tv.tv_usec = 0;
    
21.         rc = select(fd + 1, &fds, NULL, NULL, &tv);
    
22.         if (rc < 0) //error
    
23.                 return -1;
    
24. 
    
25.         return FD_ISSET(fd, &fds) ? 1 : 0;
    
26. }
    
27. int main()
    
28. 
    
29. {
    
30. 
    
31.         pid_t pids[10];
    
32. 
    
33.         int pipes[10][2];
    
34. 
    
35.         char *ls[] =
    
36.         { "ls", NULL };
    
37. 
    
38.         char *more[] =
    
39.         { "more", NULL };
    
40. 
    
41.         char *wc[] =
    
42.         { "wc", NULL };
    
43. 
    
44.         int i, status;
    
45. 
    
46.         for (i = 0; i < 10; i++)
    
47.         {
    
48. 
    
49.                 if (pipe(pipes[i]) == -1)
    
50.                 {
    
51. 
    
52.                         printf("pipe error\n");
    
53. 
    
54.                 }
    
55. 
    
56.         }
    
57. 
    
58.         if ((pids[0] = fork()) == -1)
    
59.         {
    
60. 
    
61.                 perror("fork error");
    
62. 
    
63.         }
    
64.         else if (pids[0] == 0)
    
65.         {
    
66. 
    
67.                 //输出
    
68. 
    
69.                 close(pipes[0][0]);
    
70.                 close(STDOUT_FILENO);
    
71. 
    
72.                 dup2(pipes[0][1], STDOUT_FILENO);
    
73. 
    
74.                 close(pipes[0][1]);
    
75. 
    
76.                 if (execvp(ls[0], ls) == -1)
    
77.                 {
    
78. 
    
79.                         printf("exec %s failed\n", ls[0]);
    
80. 
    
81.                 }
    
82. 
    
83.         }
    
84.         else if (pids[0] > 0)
    
85.         {
    
86. 
    
87.                 wait(NULL);
    
88. 
    
89.                 if ((pids[2] = fork()) == -1)
    
90.                 {
    
91. 
    
92.                         perror("fork error");
    
93. 
    
94.                 }
    
95.                 else if (pids[2] == 0)
    
96.                 {
    
97.                      close(pipes[0][0]);
    
98. 
    
99.                       close(pipes[0][1]);
    
100. 
     
101.                         //输入
     
102.                         //sleep(2);
     
103.                         if (isready(pipes[0][0]) > 0)
     
104.                         {
     
105.                                 cout << "ready" << endl;
     
106.                                 close(pipes[0][1]);
     
107.                                 close(STDIN_FILENO);
     
108.                                 dup2(pipes[0][0], STDIN_FILENO);
     
109. 
     
110.                                 close(pipes[0][0]);
     
111. 
     
112.                                 //输出
     
113. 
     
114.                                 close(pipes[1][0]);
     
115.                                 close(STDOUT_FILENO);
     
116.                                 dup2(pipes[1][1], STDOUT_FILENO);
     
117.                                 dup2(pipes[1][1], STDERR_FILENO);
     
118. 
     
119.                                 close(pipes[1][1]);
     
120. 
     
121.                                 if (execvp(more[0], more) == -1)
     
122.                                 {
     
123. 
     
124.                                         printf("exec %s failed\n", more[0]);
     
125. 
     
126.                                 }
     
127.                         }
     
128. 
     
129.                 }
     
130.                 else if (pids[2] > 0)
     
131.                 {
     
132.                         //输入
     
133.                         wait(NULL);
     
134.                         ////waitpid( pids[2], &status, 0 );
     
135. 
     
136.                         if (isready(pipes[1][0]) > 0)
     
137.                         {
     
138.                                 cout << "ready 2" << endl;
     
139.                                 close(pipes[1][1]);
     
140.                                 close(STDIN_FILENO);
     
141. 
     
142.                                 dup2(pipes[1][0], STDIN_FILENO);
     
143. 
     
144.                                 close(pipes[1][0]);
     
145. 
     
146.                                 if (execvp(wc[0], wc) == -1)
     
147.                                 {
     
148. 
     
149.                                         printf("exec %s failed\n", ls[0]);
     
150. 
     
151.                                 }
     
152.                         }
     
153. 
     
154.                 }
     
155. 
     
156.         }
     
157. 
     
158.         close(pipes[0][0]);
     
159. 
     
160.         close(pipes[0][1]);
     
161. 
     
162.         close(pipes[1][0]);
     
163. 
     
164.         close(pipes[1][1]);
     
165. 
     
166.         return 0;
     
167. 
     
168. }

复制代码

buzzerrookie

回复 13# chllcy88


    我是用C给改的，就把cout换成了printf。

1. 
   
2. #include <stdio.h>
   
3. #include <unistd.h>
   
4. #include <sys/wait.h>
   
5. #include <sys/types.h>
   
6. #include <stdlib.h>
   
7. 
   
8. int isready(int fd)
   
9. {
   
10.         int rc;
    
11.         fd_set fds;
    
12.         struct timeval tv;
    
13. 
    
14.         FD_ZERO(&fds);
    
15.         FD_SET(fd, &fds);
    
16.         tv.tv_sec = 1;
    
17.         tv.tv_usec = 0;
    
18.         rc = select(fd + 1, &fds, NULL, NULL, &tv);
    
19.         if (rc < 0) //error
    
20.                 return -1;
    
21. 
    
22.         return FD_ISSET(fd, &fds) ? 1 : 0;
    
23. }
    
24. int main()
    
25. {
    
26. 
    
27.         pid_t pids[10];
    
28.         int pipes[10][2];
    
29.         char *ls[] = { "ls", NULL };
    
30.         char *more[] = { "more", NULL };
    
31.         char *wc[] = { "wc", NULL };
    
32.         int i, status;
    
33. 
    
34.         for (i = 0; i < 10; i++){
    
35.                 if (pipe(pipes[i]) == -1){
    
36.                         printf("pipe error\n");
    
37.                 }
    
38.         }
    
39. 
    
40.         if((pids[0] = fork()) == -1){
    
41.                 perror("fork error");
    
42.         } else if (pids[0] == 0){
    
43.                 //输出
    
44.                 close(pipes[0][0]);
    
45.                 close(STDOUT_FILENO);
    
46.                 dup2(pipes[0][1], STDOUT_FILENO);
    
47.                 close(pipes[0][1]);
    
48. 
    
49.                 if (execvp(ls[0], ls) == -1){
    
50.                         printf("exec %s failed\n", ls[0]);
    
51.                 }
    
52.         } else if (pids[0] > 0){
    
53.                 wait(NULL);
    
54.                 if ((pids[2] = fork()) == -1){
    
55.                         perror("fork error");
    
56.                 } else if (pids[2] == 0){
    
57.                      //close(pipes[0][0]);
    
58.                      //close(pipes[0][1]);
    
59.                                   //输入
    
60.                      //sleep(2);
    
61.                      if(isready(pipes[0][0]) > 0){
    
62.                              printf("ready\n");
    
63.                              close(pipes[0][1]);
    
64.                              close(STDIN_FILENO);
    
65.                              dup2(pipes[0][0], STDIN_FILENO);
    
66.                              close(pipes[0][0]);
    
67.                                          //输出
    
68.                              close(pipes[1][0]);
    
69.                              close(STDOUT_FILENO);
    
70.                              dup2(pipes[1][1], STDOUT_FILENO);
    
71.                              dup2(pipes[1][1], STDERR_FILENO);
    
72.                              close(pipes[1][1]);
    
73.                              if (execvp(more[0], more) == -1){
    
74.                                      printf("exec %s failed\n", more[0]);
    
75.                                           }
    
76.                                   }
    
77.                 } else if (pids[2] > 0){
    
78.                         close(pipes[0][0]);
    
79.                         close(pipes[0][1]);
    
80.                         //输入
    
81.                         wait(NULL);
    
82.                         //waitpid( pids[2], &status, 0 );
    
83.                         if (isready(pipes[1][0]) > 0){
    
84.                                 printf("ready 2\n");
    
85.                                 close(pipes[1][1]);
    
86.                                 close(STDIN_FILENO);
    
87.                                 dup2(pipes[1][0], STDIN_FILENO);
    
88.                                 close(pipes[1][0]);
    
89. 
    
90.                                 if (execvp(wc[0], wc) == -1){
    
91.                                         printf("exec %s failed\n", wc[0]);
    
92.                                 }
    
93.                         }
    
94. 
    
95.                 }
    
96.         }
    
97.         close(pipes[0][0]);
    
98.         close(pipes[0][1]);
    
99.         close(pipes[1][0]);
    
100.         close(pipes[1][1]);
     
101.         return 0;
     
102. }
     

复制代码

因为原来的 else if (pids[2] == 0) 这句之后 close(pipes[0][0]); close(pipes[0][1]); 管道还没用就给关闭了，所以 ls 和 more 没用管道连上。还有一个地方是 else if (pids[2] > 0) 之后 close(pipes[0][0]); close(pipes[0][1]); 把管道pipe[0]都关闭，让more结束。其实还是用时再创建管道比较好，而不是开始创建一堆，就像 timespace 说的那样。