setpgid总是出错

buzzerrookie

我用管道实现 ls|wc 命令（随意做实验用的），第一次 fork 后 exec 了 ls，第二次 fork 后 exec 了 wc，然后用管道把 ls 和 wc 连接在了一起。
我想把 ls 自己设成了一个进程组，然后把 wc 加入 ls 的进程组，这时问题就出现了，ls 设置自己为进程组长可以，但是 wc 加入的时候出现了问题。
请各位帮忙看看是怎么回事，非常感谢。

1. 
   
2. #include <stdio.h>
   
3. #include <sys/wait.h>
   
4. #include <unistd.h>
   
5. #include <errno.h>
   
6. 
   
7. pid_t pgid = 0;
   
8. 
   
9. int main()
   
10. {
    
11.         char *prog1[] = {"ls", NULL};
    
12.         char *prog2[] = {"wc", NULL};
    
13.         pid_t pids[10];
    
14.         int pipes[2];
    
15. 
    
16.         if(pipe(pipes) == -1){
    
17.                 printf("pipe error\n");
    
18.         }
    
19.         printf("comm: %s, pid: %d, pgid: %d\n", "main", getpid(), getpgid(0));
    
20.         if((pids[0] = fork()) == -1){
    
21.                 perror("fork error");
    
22.         } else if(pids[0] == 0){
    
23.                 //输出
    
24.                 close(pipes[0]);
    
25.                 dup2(pipes[1], STDOUT_FILENO);
    
26.                 close(pipes[1]);
    
27. 
    
28.                 setpgid(0, 0);
    
29.                 pgid = getpid();
    
30.                 printf("ls pgid is %d\n", getpgid(0));
    
31.                 if(execvp(prog1[0], prog1) == -1){
    
32.                         printf("exec prog1 failed\n");
    
33.                 }
    
34.         } else if(pids[0] > 0){
    
35.                 pgid = pids[0];
    
36.                 setpgid(pids[0], pids[0]);
    
37.                 printf("comm: %s: pid: %d, pgid: %d\n",
    
38.                                 "ls", pids[0], getpgid(pids[0]));
    
39.                 waitpid(pids[0], NULL, 0);
    
40.         }
    
41.         if((pids[1] = fork()) == -1){
    
42.                 perror("fork error");
    
43.         } else if(pids[1] == 0){
    
44.                 //输入
    
45.                 close(pipes[1]);
    
46.                 dup2(pipes[0], STDIN_FILENO);
    
47.                 close(pipes[0]);
    
48.                 if(setpgid(0, pgid) == -1){
    
49.                         printf("in child, wc setpgid error\n");
    
50.                         printf("errorno: %d\n", errno);
    
51.                 }
    
52.                 printf("wc pgid is %d\n", getpgid(0));
    
53.                 if(execvp(prog2[0], prog2) == -1){
    
54.                         printf("exec prog2 failed\n");
    
55.                 }
    
56.         } else if(pids[1] > 0){
    
57.                 if(setpgid(pids[1], pgid) == -1){
    
58.                         printf("in parent, wc setpgid error\n");
    
59.                         printf("errorno; %d\n", errno);
    
60.                 }
    
61.                 printf("comm: %s: pid: %d, pgid: %d\n",
    
62.                                 "wc", pids[1], getpgid(pids[1]));
    
63.                 close(pipes[0]);
    
64.                 close(pipes[1]);
    
65.                 waitpid(pids[1], NULL, 0);
    
66.         }
    
67.         return 0;
    
68. }
    

复制代码

timespace

wc进程加入的时候，ls新进程组已经退出了，肯定会出错
调整代码逻辑，设法使wc setpgid时，ls进程组依然存活

mstxrgcu

在同一个进程中管道的读写端为什么都关闭？

buzzerrookie

回复 3# mstxrgcu


    dup2重定向之后就关闭了。

buzzerrookie

回复 2# timespace


    再请教个问题，像我这种自己创建的管道实现 ls|wc 时，是先执行ls，等ls执行完了再执行wc吗？
    调整代码逻辑的话，最后统一执行 exec 行吗？谢谢。

timespace

数据流向肯定是ls到wc，但不一定要ls完全结束才开始执行wc
管道的一个重大优点就在于很多时候可以并行执行，比如ls在写，wc读，完全不冲突

有个简单技巧，就是创建子进程的顺序与数据流相反：
1. main先创建wc进程，wc很可能在管道上读阻塞
2. main继续再创建ls进程，ls在管道上写
3. main waitpid
这样就可以利用管道的阻塞特性做到进程同步，那么setpgid就会成功了

mstxrgcu

关闭之后没有影响？

buzzerrookie

回复 7# mstxrgcu


    没有，已经重定向了。

buzzerrookie

回复 6# timespace

我这样写就setpgid成功了。您说的意思是这样吗？还有一个问题是我这样输出的结果与直接在shell中敲 ls|wc 输出的结果不同是因为管道文件的缘故吗？谢谢。

1. #include <stdio.h>
   
2. #include <sys/wait.h>
   
3. #include <unistd.h>
   
4. #include <errno.h>
   
5. 
   
6. pid_t pgid = 0;
   
7. 
   
8. int main()
   
9. {
   
10.         char *prog1[] = {"ls", NULL};
    
11.         char *prog2[] = {"wc", NULL};
    
12.         pid_t pids[10];
    
13.         int pipes[2];
    
14. 
    
15.         if(pipe(pipes) == -1){
    
16.                 printf("pipe error\n");
    
17.         }
    
18.         printf("comm: %s, pid: %d, pgid: %d\n", "main", getpid(), getpgid(0));
    
19. 
    
20.         if((pids[1] = fork()) == -1){
    
21.                 perror("fork error");
    
22.         } else if(pids[1] == 0){
    
23.                 //输入
    
24.                 close(pipes[1]);
    
25.                 dup2(pipes[0], STDIN_FILENO);
    
26.                 close(pipes[0]);
    
27.                 setpgid(0, 0);
    
28.                 pgid = getpid();
    
29. 
    
30.                 printf("wc pgid is %d\n", getpgid(0));
    
31.                 if(execvp(prog2[0], prog2) == -1){
    
32.                         printf("exec prog2 failed\n");
    
33.                 }
    
34.         } else if(pids[1] > 0){
    
35.                 pgid = pids[1];
    
36.                 if(setpgid(pids[1], pgid) == -1){
    
37.                         printf("in parent, wc setpgid error\n");
    
38.                         printf("errorno; %d\n", errno);
    
39.                 }
    
40.                 printf("comm: %s: pid: %d, pgid: %d\n",
    
41.                                 "wc", pids[1], getpgid(pids[1]));
    
42.                 //close(pipes[0]);
    
43.                 //close(pipes[1]);
    
44.         }
    
45.         if((pids[0] = fork()) == -1){
    
46.                 perror("fork error");
    
47.         } else if(pids[0] == 0){
    
48.                 //输出
    
49.                 close(pipes[0]);
    
50.                 dup2(pipes[1], STDOUT_FILENO);
    
51.                 close(pipes[1]);
    
52.                 if(setpgid(0, pgid) == -1){
    
53.                         printf("in child, ls setpgid error\n");
    
54.                         printf("errorno: %d\n", errno);
    
55.                 }
    
56.                 printf("ls pgid is %d\n", getpgid(0));
    
57.                 if(execvp(prog1[0], prog1) == -1){
    
58.                         printf("exec prog1 failed\n");
    
59.                 }
    
60.         } else if(pids[0] > 0){
    
61.                 setpgid(pids[0], pgid);
    
62.                 printf("comm: %s: pid: %d, pgid: %d\n",
    
63.                                 "ls", pids[0], getpgid(pids[0]));
    
64.                 waitpid(pids[0], NULL, 0);
    
65.         }
    
66.         close(pipes[0]);
    
67.         close(pipes[1]);
    
68.         waitpid(pids[1], NULL, 0);
    
69.         return 0;
    
70. }

复制代码

buzzerrookie

回复 6# timespace


    不好意思啊，我还有一个问题，两个进程成功了，但三个时有问题了，不是setpgid的问题，应该是管道的问题。我实现 ls|more|wc ，我创建的顺序是wc，more和ls，程序没有结果而且总是不结束，请帮忙看一下原因，麻烦您了。

1. 
   
2. /*
   
3. * ls | more | wc，使这三个在一个进程组
   
4. */
   
5. #include <stdio.h>
   
6. #include <unistd.h>
   
7. #include <sys/wait.h>
   
8. 
   
9. pid_t pgid;
   
10. 
    
11. int main()
    
12. {
    
13.         pid_t pids[10];
    
14.         int pipes[10][2];
    
15.         char *ls[] = {"ls", NULL};
    
16.         char *more[] = {"more", NULL};
    
17.         char *wc[] = {"wc", NULL};
    
18.         int i;
    
19. 
    
20.         printf("comm: main, pid: %d, pgid: %d\n", getpid(), getpgid(0));
    
21.         /*
    
22.          * wc
    
23.          */
    
24.         for(i = 0; i < 10; i++){
    
25.                 if(pipe(pipes[i]) == -1){
    
26.                         printf("pipe error\n");
    
27.                 }
    
28.         }
    
29.         if((pids[2] = fork()) == -1){
    
30.                 perror("fork error");
    
31.         } else if(pids[2] == 0){
    
32.                 //输入
    
33.                 close(pipes[1][1]);
    
34.                 dup2(pipes[1][0], STDIN_FILENO);
    
35.                 close(pipes[1][0]);
    
36.                 if(setpgid(0, 0) == -1){
    
37.                         printf("in child, %s setpgid error\n", wc[0]);
    
38.                 }
    
39.                 pgid = getpgid(0);
    
40.                 if(execvp(wc[0], wc) == -1){
    
41.                         printf("exec %s failed\n", ls[0]);
    
42.                 }
    
43.         } else if(pids[2] > 0){
    
44.                 pgid = pids[2];
    
45.                 if(setpgid(pids[2],pids[2]) == -1){
    
46.                         printf("in parent, %s setpgid error\n", wc[0]);
    
47.                 }
    
48.                 printf("comm: %s, pid: %d, pgid: %d\n", wc[0], pids[2], getpgid(pids[2]));
    
49.         }
    
50.         /*
    
51.          * more
    
52.          */
    
53.         if((pids[1] = fork()) == -1){
    
54.                 perror("fork error");
    
55.         } else if(pids[1] == 0){
    
56.                 //输入
    
57.                 close(pipes[0][1]);
    
58.                 dup2(pipes[0][0], STDIN_FILENO);
    
59.                 close(pipes[0][0]);
    
60.                 //输出
    
61.                 close(pipes[1][0]);
    
62.                 dup2(pipes[1][1], STDOUT_FILENO);
    
63.                 close(pipes[1][1]);
    
64.                 if(setpgid(0, pgid) == -1){
    
65.                         printf("in child, %s setpgid error\n", more[0]);
    
66.                 }
    
67.                 if(execvp(more[0], more) == -1){
    
68.                         printf("exec %s failed\n", more[0]);
    
69.                 }
    
70.         } else if(pids[1] > 0){
    
71.                 if(setpgid(pids[1], pgid) == -1){
    
72.                         printf("in parent, %s setpgid error\n", more[0]);
    
73.                 }
    
74.                 printf("comm: %s, pid: %d, pgid: %d\n", more[0], pids[1], getpgid(pids[1]));
    
75.         }
    
76.         /*
    
77.          * ls
    
78.          */
    
79.         if((pids[0] = fork()) == -1){
    
80.                 perror("fork error");
    
81.         } else if(pids[0] == 0){
    
82.                 //输出
    
83.                 close(pipes[0][0]);
    
84.                 dup2(pipes[0][1], STDOUT_FILENO);
    
85.                 close(pipes[0][1]);
    
86.                 if(setpgid(0, pgid) == -1){
    
87.                         printf("in child, %s setpgid error\n", ls[0]);
    
88.                 }
    
89.                 if(execvp(ls[0], ls) == -1){
    
90.                         printf("exec %s failed\n", ls[0]);
    
91.                 }
    
92.         } else if(pids[0] > 0){
    
93.                 if(setpgid(pids[0], pgid) == -1){
    
94.                         printf("in parent, %s setpgid error\n", ls[0]);
    
95.                 }
    
96.                 printf("comm: %s: pid: %d, pgid: %d\n", ls[0], pids[0], getpgid(pids[0]));
    
97.                 waitpid(pids[0], NULL, 0);
    
98.         }
    
99.         waitpid(pids[1], NULL, 0);
    
100.         close(pipes[0][0]);
     
101.         close(pipes[0][1]);
     
102.         waitpid(pids[2], NULL, 0);
     
103.         close(pipes[1][0]);
     
104.         close(pipes[1][1]);
     
105.         return 0;
     
106. }
     

复制代码