管道破裂、關(guān)閉，epoll無事件返回，求高人指點(diǎn)

79hy

問題：
1 我建立了一對(duì)管道，
2. 用fork了一個(gè)子進(jìn)程，父進(jìn)程讀，子進(jìn)程寫。
3. 父進(jìn)程用epoll監(jiān)聽管道，

但是子進(jìn)程關(guān)閉寫端，或退出。epoll沒事件返回給我。怎么辦呢？

1. #include <unistd.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <sys/epoll.h>
   
5. 
   
6. int main()
   
7. {
   
8.         int fds[2];
   
9.         pid_t pid;
   
10. 
    
11.         pipe(fds);
    
12. 
    
13.         pid = fork();
    
14.         if (pid == 0) {
    
15.                 /* child */
    
16.                 sleep(2);
    
17.                 close(fds[1]);
    
18.                 close(fds[0]);
    
19.                 printf("exit!\n");
    
20.                 exit(0);
    
21.         } else if (pid > 0) {
    
22.                 /* father */
    
23.                 struct epoll_event ev, events[10];
    
24.                 ev.data.fd = fds[0];
    
25.                 ev.events = EPOLLIN|EPOLLOUT|EPOLLHUP;
    
26.                 int epfd = epoll_create(10);
    
27.                 epoll_ctl(epfd, EPOLL_CTL_ADD, fds[0], &ev);
    
28.                 for (;;) {
    
29.                         int ret = epoll_wait(epfd, events, 10, 3000);
    
30.                         printf("epoll returns %d\n", ret);
    
31.                         if (ret == 0) {
    
32.                                 close(fds[0]);
    
33.                                 close(fds[1]);
    
34.                                 continue;
    
35.                         }
    
36. 
    
37.                         int i = 0;
    
38.                         for (i = 0; i < ret; i++) {
    
39.                                 if (events[i].events & EPOLLIN)
    
40.                                         printf("EPOLLIN");
    
41.                                 else if (events[i].events & EPOLLOUT)
    
42.                                         printf("EPOLLOUT");
    
43.                                 else if (events[i].events & EPOLLHUP)
    
44.                                         printf("EPOLLHUP");
    
45.                                 else
    
46.                                         printf("lsdkfsdlfksljf");
    
47.                                 printf("\n");
    
48. 
    
49.                         }
    
50.                 }
    
51.         }
    
52. 
    
53.         return 0;
    
54. }
    

復(fù)制代碼

79hy

在線等。謝謝

1226ehziy

你覺得你子進(jìn)程關(guān)閉管道描述符會(huì)通知你的父進(jìn)程么？這不合理吧
close(fds[1]);
int ret = epoll_wait(epfd, events, 10, 3000);
你這樣修改試一下  
子進(jìn)程那塊應(yīng)該沒關(guān)系吧     @newbie@

梅川內(nèi)依酷

回復(fù) 1# 79hy


    管道有一端關(guān)閉的時(shí)候   epoll另一端會(huì)收到0，此時(shí)可以把這個(gè)fd刪除監(jiān)聽了

79hy

回復(fù) 3# 1226ehziy


    那你覺得socket對(duì)端關(guān)閉了，怎么epoll怎么就能捕獲到呢？呵呵。

79hy

回復(fù) 4# 梅川內(nèi)依酷


    你測(cè)試了嗎？連事件都沒有，怎么可能去觸發(fā)讀呢？

梅川內(nèi)依酷

回復(fù) 7# 79hy


   =

1226ehziy

回復(fù) 6# 79hy


    你可以測(cè)試一下嘛！看看是不是想要的結(jié)果。改為write試試。@newbie@

rain_fish

看來管道關(guān)閉，除了主動(dòng)去讀取，沒有別的辦法了？

79hy

只能在epoll中超時(shí)去讀下管道，失敗就干掉。呵呵。謝謝大家了。