詢問父進程傳遞一個sockfd給子進程的問題 ：Bad file descriptor

AssassinPig

rt， 父進程 創(chuàng)建子進程池， 然后父進程accept一個newconnfd，然后使用pipe傳給子進程， 子進程無法對這個newconnfd 進行recv也無法send， 總是報Bad file descriptor...
我把這個newconnfd的值在父進程accept的時候打印了出來， 在子進程從pipe里面讀出來的時候也打印了一下，發(fā)現(xiàn)他們的值是一樣的...
(ps:查看了下unpv2的一個例子，他是用msg來傳遞的...難道是不能這樣用pipe傳遞使用么？ 求高人指點下啊 )

AssassinPig

再加一句， 所有的recv和send 代碼移動到父進程中就正確了回復 1# AssassinPig


   

AssassinPig

再加一句， 所有的recv和send 代碼移動到父進程中就正確了回復 1# AssassinPig


   

tc1989tc

回復 3# AssassinPig


    因為你的子進程并沒有繼承父進程的fd。原因就是你先創(chuàng)建子進程池的時候，，那哈還沒有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