询问父进程传递一个sockfd给子进程的问题 ：Bad file descriptor

AssassinPig

rt， 父进程 创建子进程池， 然后父进程accept一个newconnfd，然后使用pipe传给子进程， 子进程无法对这个newconnfd 进行recv也无法send， 总是报Bad file descriptor...
我把这个newconnfd的值在父进程accept的时候打印了出来， 在子进程从pipe里面读出来的时候也打印了一下，发现他们的值是一样的...
(ps:查看了下unpv2的一个例子，他是用msg来传递的...难道是不能这样用pipe传递使用么？ 求高人指点下啊 )

AssassinPig

再加一句， 所有的recv和send 代码移动到父进程中就正确了回复 1# AssassinPig


   

AssassinPig

再加一句， 所有的recv和send 代码移动到父进程中就正确了回复 1# AssassinPig


   

tc1989tc

回复 3# AssassinPig


    因为你的子进程并没有继承父进程的fd。原因就是你先创建子进程池的时候，，那哈还没有accept，，所以就不能继承了

AssassinPig

我也想过是这个原因，但是我参考的代码就是在这么干的...所以我很迷惑啊...回复 4# tc1989tc


   

tc1989tc

把你参考的代码贴出来

AssassinPig

1. /* include serv05a */
   
2. #include        "unp.h"
   
3. #include        "child.h"
   
4. 
   
5. static int                nchildren;
   
6. 
   
7. int
   
8. main(int argc, char **argv)
   
9. {
   
10.         int                        listenfd, i, navail, maxfd, nsel, connfd, rc;
    
11.         void                sig_int(int);
    
12.         pid_t                child_make(int, int, int);
    
13.         ssize_t                n;
    
14.         fd_set                rset, masterset;
    
15.         socklen_t        addrlen, clilen;
    
16.         struct sockaddr        *cliaddr;
    
17. 
    
18.         if (argc == 3)
    
19.                 listenfd = Tcp_listen(NULL, argv[1], &addrlen);
    
20.         else if (argc == 4)
    
21.                 listenfd = Tcp_listen(argv[1], argv[2], &addrlen);
    
22.         else
    
23.                 err_quit("usage: serv05 [ <host> ] <port#> <#children>");
    
24. 
    
25.         FD_ZERO(&masterset);
    
26.         FD_SET(listenfd, &masterset);
    
27.         maxfd = listenfd;
    
28.         cliaddr = Malloc(addrlen);
    
29. 
    
30.         nchildren = atoi(argv[argc-1]);
    
31.         navail = nchildren;
    
32.         cptr = Calloc(nchildren, sizeof(Child));
    
33. 
    
34.                 /* 4prefork all the children */
    
35.         for (i = 0; i < nchildren; i++) {
    
36.                 child_make(i, listenfd, addrlen);        /* parent returns */
    
37.                 FD_SET(cptr[i].child_pipefd, &masterset);
    
38.                 maxfd = max(maxfd, cptr[i].child_pipefd);
    
39.         }
    
40. 
    
41.         Signal(SIGINT, sig_int);
    
42. 
    
43.         for ( ; ; ) {
    
44.                 rset = masterset;
    
45.                 if (navail <= 0)
    
46.                         FD_CLR(listenfd, &rset);        /* turn off if no available children */
    
47.                 nsel = Select(maxfd + 1, &rset, NULL, NULL, NULL);
    
48. 
    
49.                         /* 4check for new connections */
    
50.                 if (FD_ISSET(listenfd, &rset)) {
    
51.                         clilen = addrlen;
    
52.                         connfd = Accept(listenfd, cliaddr, &clilen);
    
53. 
    
54.                         for (i = 0; i < nchildren; i++)
    
55.                                 if (cptr[i].child_status == 0)
    
56.                                         break;                                /* available */
    
57. 
    
58.                         if (i == nchildren)
    
59.                                 err_quit("no available children");
    
60.                         cptr[i].child_status = 1;        /* mark child as busy */
    
61.                         cptr[i].child_count++;
    
62.                         navail--;
    
63. 
    
64.                         n = Write_fd(cptr[i].child_pipefd, "", 1, connfd);
    
65.                         Close(connfd);
    
66.                         if (--nsel == 0)
    
67.                                 continue;        /* all done with select() results */
    
68.                 }
    
69. 
    
70.                         /* 4find any newly-available children */
    
71.                 for (i = 0; i < nchildren; i++) {
    
72.                         if (FD_ISSET(cptr[i].child_pipefd, &rset)) {
    
73.                                 if ( (n = Read(cptr[i].child_pipefd, &rc, 1)) == 0)
    
74.                                         err_quit("child %d terminated unexpectedly", i);
    
75.                                 cptr[i].child_status = 0;
    
76.                                 navail++;
    
77.                                 if (--nsel == 0)
    
78.                                         break;        /* all done with select() results */
    
79.                         }
    
80.                 }
    
81.         }
    
82. }
    
83. /* end serv05a */
    
84. 
    
85. void
    
86. sig_int(int signo)
    
87. {
    
88.         int                i;
    
89.         void        pr_cpu_time(void);
    
90. 
    
91.                 /* 4terminate all children */
    
92.         for (i = 0; i < nchildren; i++)
    
93.                 kill(cptr[i].child_pid, SIGTERM);
    
94.         while (wait(NULL) > 0)                /* wait for all children */
    
95.                 ;
    
96.         if (errno != ECHILD)
    
97.                 err_sys("wait error");
    
98. 
    
99.         pr_cpu_time();
    
100. 
     
101.         for (i = 0; i < nchildren; i++)
     
102.                 printf("child %d, %ld connections\n", i, cptr[i].child_count);
     
103. 
     
104.         exit(0);
     
105. }
     

复制代码

AssassinPig

1. /* include child_make */
   
2. #include        "unp.h"
   
3. #include        "child.h"
   
4. 
   
5. pid_t
   
6. child_make(int i, int listenfd, int addrlen)
   
7. {
   
8.         int                sockfd[2];
   
9.         pid_t        pid;
   
10.         void        child_main(int, int, int);
    
11. 
    
12.         Socketpair(AF_LOCAL, SOCK_STREAM, 0, sockfd);
    
13. 
    
14.         if ( (pid = Fork()) > 0) {
    
15.                 Close(sockfd[1]);
    
16.                 cptr[i].child_pid = pid;
    
17.                 cptr[i].child_pipefd = sockfd[0];
    
18.                 cptr[i].child_status = 0;
    
19.                 return(pid);                /* parent */
    
20.         }
    
21. 
    
22.         Dup2(sockfd[1], STDERR_FILENO);                /* child's stream pipe to parent */
    
23.         Close(sockfd[0]);
    
24.         Close(sockfd[1]);
    
25.         Close(listenfd);                                        /* child does not need this open */
    
26.         child_main(i, listenfd, addrlen);        /* never returns */
    
27. }
    
28. /* end child_make */
    
29. 
    
30. /* include child_main */
    
31. void
    
32. child_main(int i, int listenfd, int addrlen)
    
33. {
    
34.         char                        c;
    
35.         int                                connfd;
    
36.         ssize_t                        n;
    
37.         void                        web_child(int);
    
38. 
    
39.         printf("child %ld starting\n", (long) getpid());
    
40.         for ( ; ; ) {
    
41.                 if ( (n = Read_fd(STDERR_FILENO, &c, 1, &connfd)) == 0)
    
42.                         err_quit("read_fd returned 0");
    
43.                 if (connfd < 0)
    
44.                         err_quit("no descriptor from read_fd");
    
45. 
    
46.                 web_child(connfd);                                /* process request */
    
47.                 Close(connfd);
    
48. 
    
49.                 Write(STDERR_FILENO, "", 1);        /* tell parent we're ready again */
    
50.         }
    
51. }
    
52. /* end child_main */
    

复制代码

AssassinPig

1. #include        "unp.h"
   
2. 
   
3. #define        MAXN        16384                /* max # bytes client can request */
   
4. 
   
5. void
   
6. web_child(int sockfd)
   
7. {
   
8.         int                        ntowrite;
   
9.         ssize_t                nread;
   
10.         char                line[MAXLINE], result[MAXN];
    
11. 
    
12.         for ( ; ; ) {
    
13.                 if ( (nread = Readline(sockfd, line, MAXLINE)) == 0)
    
14.                         return;                /* connection closed by other end */
    
15. 
    
16.                         /* 4line from client specifies #bytes to write back */
    
17.                 ntowrite = atol(line);
    
18.                 if ((ntowrite <= 0) || (ntowrite > MAXN))
    
19.                         err_quit("client request for %d bytes", ntowrite);
    
20. 
    
21.                 Writen(sockfd, result, ntowrite);
    
22.         }
    
23. }
    

复制代码

AssassinPig

unp代码里面 server/serv05.c child05.c web_child.c