关于popen

marco_hxj

APUE第2版406页说
每次调用popen时，应当记住所创建子进程的ID
请问，怎么得到这个子进程ID的？

有些人推荐用fork+execl，但是我要在这个管道里传输一些指令，所以就选择了popen

net_robber

popen的时候子进程还没有创建

之后需要你手动创建



popen只是创建了管道

思一克

#include <stdio.h>

       FILE *popen(const char *command, const char *type);

       int pclose(FILE *stream);

DESCRIPTION
       The popen() function opens a process by creating a pipe, forking, and invoking the shell.  Since a pipe is by defâ

marco_hxj

原帖由 net_robber 于 2009-5-26 15:01 发表
popen的时候子进程还没有创建

之后需要你手动创建



popen只是创建了管道

popen需要自己手动创建子进程?

popen的第一个参数不是cmd吗?然后就直接自动fork然后执行了


我的代码：
snprintf(t_cmd, 256, "main_dec -f %s_ -s %s -m %d -q %d", t_fname, g_rec_path, 2, play_mode);
       
play_fp = popen(t_cmd, "w");

[ 本帖最后由 marco_hxj 于 2009-6-1 14:30 编辑 ]

JohnBull

原帖由 marco_hxj 于 2009-5-26 12:56 发表
APUE第2版406页说
每次调用popen时，应当记住所创建子进程的ID
请问，怎么得到这个子进程ID的？

有些人推荐用fork+execl，但是我要在这个管道里传输一些指令，所以就选择了popen

你不需要知道PID，stdio记住就行了，pclose的时候用得着。

chary8088

popen执行后就创建了pipe和process了，怎么还要手动创建子进程？？？第一次听说

openspace

原帖由 marco_hxj 于 2009-5-26 12:56 发表
APUE第2版406页说
每次调用popen时，应当记住所创建子进程的ID
请问，怎么得到这个子进程ID的？

有些人推荐用fork+execl，但是我要在这个管道里传输一些指令，所以就选择了popen

1. 
   
2. Figure 15.12. The popen and pclose functions
   
3. #include "apue.h"
   
4. #include <errno.h>
   
5. #include <fcntl.h>
   
6. #include <sys/wait.h>
   
7. 
   
8. /*
   
9. * Pointer to array allocated at run-time.
   
10. */
    
11. static pid_t    *childpid = NULL;
    
12. 
    
13. /*
    
14. * From our open_max(), Figure 2.16.
    
15. */
    
16. static int      maxfd;
    
17. 
    
18. FILE *
    
19. popen(const char *cmdstring, const char *type)
    
20. {
    
21.     int     i;
    
22.     int     pfd[2];
    
23.     pid_t   pid;
    
24.     FILE    *fp;
    
25. 
    
26.     /* only allow "r" or "w" */
    
27.     if ((type[0] != 'r' && type[0] != 'w') || type[1] != 0) {
    
28.         errno = EINVAL;     /* required by POSIX */
    
29.         return(NULL);
    
30.     }
    
31. 
    
32.     if (childpid == NULL) {     /* first time through */
    
33.         /* allocate zeroed out array for child pids */
    
34.         maxfd = open_max();
    
35.         if ((childpid = calloc(maxfd, sizeof(pid_t))) == NULL)
    
36.             return(NULL);
    
37.     }
    
38. 
    
39.     if (pipe(pfd) < 0)
    
40.         return(NULL);   /* errno set by pipe() */
    
41. 
    
42.     if ((pid = fork()) < 0) {
    
43.         return(NULL);   /* errno set by fork() */
    
44.     } else if (pid == 0) {                           /* child */
    
45.         if (*type == 'r') {
    
46.             close(pfd[0]);
    
47.             if (pfd[1] != STDOUT_FILENO) {
    
48.                 dup2(pfd[1], STDOUT_FILENO);
    
49.                 close(pfd[1]);
    
50.             }
    
51.         } else {
    
52.             close(pfd[1]);
    
53.             if (pfd[0] != STDIN_FILENO) {
    
54.                 dup2(pfd[0], STDIN_FILENO);
    
55.                 close(pfd[0]);
    
56.             }
    
57.         }
    
58. 
    
59.         /* close all descriptors in childpid[] */
    
60.         for (i = 0; i < maxfd; i++)
    
61.             if (childpid[i] > 0)
    
62.                 close(i);
    
63. 
    
64.         execl("/bin/sh", "sh", "-c", cmdstring, (char *)0);
    
65.         _exit(127);
    
66.     }
    
67. 
    
68.     /* parent continues... */
    
69.     if (*type == 'r') {
    
70.         close(pfd[1]);
    
71.         if ((fp = fdopen(pfd[0], type)) == NULL)
    
72.             return(NULL);
    
73.     } else {
    
74.         close(pfd[0]);
    
75.         if ((fp = fdopen(pfd[1], type)) == NULL)
    
76.             return(NULL);
    
77.     }
    
78. 
    
79.     childpid[fileno(fp)] = pid; /* remember child pid for this fd */
    
80.     return(fp);
    
81. }
    
82. 
    
83. 
    
84. int
    
85. pclose(FILE *fp)
    
86. {
    
87.     int     fd, stat;
    
88.     pid_t   pid;
    
89. 
    
90.     if (childpid == NULL) {
    
91.         errno = EINVAL;
    
92.         return(-1);     /* popen() has never been called */
    
93.     }
    
94. 
    
95.     fd = fileno(fp);
    
96.     if ((pid = childpid[fd]) == 0) {
    
97.         errno = EINVAL;
    
98.         return(-1);     /* fp wasn't opened by popen() */
    
99.     }
    
100. 
     
101.     childpid[fd] = 0;
     
102.     if (fclose(fp) == EOF)
     
103.         return(-1);
     
104. 
     
105.     while (waitpid(pid, &stat, 0) < 0)
     
106.         if (errno != EINTR)
     
107.             return(-1); /* error other than EINTR from waitpid() */
     
108. 
     
109.     return(stat);   /* return child's termination status */
     
110. }
     
111. 
     

复制代码

内部实现需要这样
至于当做API函数使用就不需要考虑这些了

marco_hxj

原帖由 JohnBull 于 2009-6-1 17:39 发表


你不需要知道PID，stdio记住就行了，pclose的时候用得着。

我主要想知道这个子进程什么时候退出，看来得用7楼的方法。
7楼的方法第一次看到，我以为popen只有是自动调用fork+excel的

chary8088

Figure 15.12. The popen and pclose functions #include "apue.h" #include <errno.h> #include <fcntl.h> #include <sys/wait.h> /* * Pointer to array allocated at run-time. */ static pid_t    *childpid = NULL; /* * From our open_max(), Figure 2.16. */ static int      maxfd; FILE * popen(const char *cmdstring, const char *type) { &nbsp;&nbsp;&nbsp;&nbsp;int     i; &nbsp;&nbsp;&nbsp;&nbsp;int     pfd[2]; &nbsp;&nbsp;&nbsp;&nbsp;pid_t   pid; &nbsp;&nbsp;&nbsp;&nbsp;FILE    *fp; &nbsp;&nbsp;&nbsp;&nbsp;/* only allow "r" or "w" */ &nbsp;&nbsp;&nbsp;&nbsp;if ((type[0] != 'r' && type[0] != 'w') || type[1] != 0) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;errno = EINVAL;     /* required by POSIX */ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(NULL); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;if (childpid == NULL) {     /* first time through */ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/* allocate zeroed out array for child pids */ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;maxfd = open_max(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if ((childpid = calloc(maxfd, sizeof(pid_t))) == NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(NULL); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;if (pipe(pfd) < 0) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(NULL);   /* errno set by pipe() */ &nbsp;&nbsp;&nbsp;&nbsp;if ((pid = fork()) < 0) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(NULL);   /* errno set by fork() */ &nbsp;&nbsp;&nbsp;&nbsp;} else if (pid == 0) {                           /* child */ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (*type == 'r') { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(pfd[0]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (pfd[1] != STDOUT_FILENO) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dup2(pfd[1], STDOUT_FILENO); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(pfd[1]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(pfd[1]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (pfd[0] != STDIN_FILENO) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dup2(pfd[0], STDIN_FILENO); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(pfd[0]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/* close all descriptors in childpid[] */ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for (i = 0; i < maxfd; i++) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (childpid[i] > 0) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(i); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;execl("/bin/sh", "sh", "-c", cmdstring, (char *)0); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_exit(127); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/* parent continues... */ &nbsp;&nbsp;&nbsp;&nbsp;if (*type == 'r') { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(pfd[1]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if ((fp = fdopen(pfd[0], type)) == NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(NULL); &nbsp;&nbsp;&nbsp;&nbsp;} else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(pfd[0]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if ((fp = fdopen(pfd[1], type)) == NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(NULL); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;childpid[fileno(fp)] = pid; /* remember child pid for this fd */ &nbsp;&nbsp;&nbsp;&nbsp;return(fp); } int pclose(FILE *fp) { &nbsp;&nbsp;&nbsp;&nbsp;int     fd, stat; &nbsp;&nbsp;&nbsp;&nbsp;pid_t   pid; &nbsp;&nbsp;&nbsp;&nbsp;if (childpid == NULL) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;errno = EINVAL; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(-1);     /* popen() has never been called */ &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;fd = fileno(fp); &nbsp;&nbsp;&nbsp;&nbsp;if ((pid = childpid[fd]) == 0) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;errno = EINVAL; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(-1);     /* fp wasn't opened by popen() */ &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;childpid[fd] = 0; &nbsp;&nbsp;&nbsp;&nbsp;if (fclose(fp) == EOF) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(-1); &nbsp;&nbsp;&nbsp;&nbsp;while (waitpid(pid, &stat, 0) < 0) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (errno != EINTR) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return(-1); /* error other than EINTR from waitpid() */ &nbsp;&nbsp;&nbsp;&nbsp;return(stat);   /* return child's termination status */ }

APUE上也给出了这个代码。。