Linux下epoll的一些問題

contestjia

小弟使用EPOLLIN來觸發(fā)可讀事件，按照網(wǎng)上說的，ET模式下，只有緩沖區(qū)從不可讀變成可讀才會觸發(fā)EPOLLIN時間，可現(xiàn)在寫了一個測試程序，客戶端每次發(fā)多個字節(jié)，服務(wù)器每次只收一個字節(jié)，但每次都會觸發(fā)EPOLLIN事件，如果只收一個字節(jié)，緩沖區(qū)還有數(shù)據(jù)，下次發(fā)送就應(yīng)該不會再觸發(fā)EPOLLIN事件（ET模式下），服務(wù)端代碼如下：

1. #include <iostream>
   
2. #include <cstring>
   
3. #include <sys/epoll.h>
   
4. #include <unistd.h>
   
5. #include <sys/socket.h>
   
6. #include <arpa/inet.h>
   
7. #include <netinet/in.h>
   
8. #include <errno.h>
   
9. #include <fcntl.h>
   
10. 
    
11. int main(void)
    
12. {
    
13.     int serfd = socket(AF_INET, SOCK_STREAM, 0);
    
14.     int clifd;
    
15.     int ret;
    
16.     if(serfd < 0)
    
17.         std::cout << "Create serfd fail!\n";
    
18. 
    
19.     struct sockaddr_in cliaddr, seraddr;
    
20.     bzero(&seraddr, sizeof(seraddr));
    
21.     seraddr.sin_family = AF_INET;
    
22.     seraddr.sin_port = htons(12439);
    
23.     seraddr.sin_addr.s_addr = inet_addr("0.0.0.0");
    
24.     int on = 1;
    
25.     setsockopt(serfd, SOL_SOCKET, SO_REUSEADDR, (char *) &on, sizeof(on));
    
26.     bind(serfd, (struct sockaddr*)&seraddr, sizeof(seraddr));
    
27.     listen(serfd, 20);
    
28. 
    
29.     socklen_t len = sizeof(cliaddr);
    
30.     bzero(&cliaddr, sizeof(seraddr));
    
31.     clifd = accept(serfd, (struct sockaddr*)&cliaddr, &len);
    
32.     if(clifd < -1){
    
33.         std::cout << strerror(errno) << std::endl;
    
34.         close(serfd);
    
35.         return 0;
    
36.     }
    
37. 
    
38.     fcntl(clifd, F_SETFL, O_NONBLOCK);
    
39. 
    
40.     //Create epoll
    
41.     int epfd = epoll_create(1024);
    
42.     struct epoll_event ev;
    
43.     struct epoll_event events[1024];
    
44.     ev.events = EPOLLET | EPOLLIN ;
    
45.     ev.data.fd = clifd;
    
46.     epoll_ctl(epfd, EPOLL_CTL_ADD, clifd, &ev);
    
47. 
    
48.     while(1)
    
49.     {
    
50.         int num = epoll_wait(epfd, events, 1024, -1);
    
51.         char buf[1024] = {0};
    
52.         for(int i = 0; i < num; i++)
    
53.         {
    
54.             if(events[i].events & EPOLLIN){
    
55.                 std::cout << "Ready to read!\n";
    
56.                 std::cout << "size=" << read(events[i].data.fd, buf, 1)
    
57.                           << "\tbuf=[" << buf << ']' << std::endl;
    
58.             }
    
59.             if(events[i].events & EPOLLOUT){
    
60.                 std::cout << "Ready to write!\n";
    
61.             }
    
62.         }
    
63. 
    
64.     }
    
65.     return 0;
    
66. }
    
67. 
    

復(fù)制代碼

客戶端使用: nc 來連接，并發(fā)送數(shù)據(jù)，第一次發(fā)了abcd，觸發(fā)了EPOLLIN，但服務(wù)器只收一個字節(jié)，第二次發(fā)了ef，依然觸發(fā)了EPOLLIN。

服務(wù)器端的接收情況：

此外：如果我注冊的時候是EPOLLET|EPOLLOUT ，為什么這個EPOLLOUT每次都會觸發(fā)？
謝謝各位！

tc1989tc

hi,
按照EPOLLET 代碼實現(xiàn)，應(yīng)該是如果你沒有讀取完畢
并且底層驅(qū)動也沒有數(shù)據(jù)發(fā)送過來的哈。
這時候你的epoll_wait 是不能等待相關(guān)的事件啦。
例如，你在讀取一個字節(jié)后，你客服端不發(fā)送消息過來，那么你在epoll_wait
對應(yīng)的文件符 是一直沒有相應(yīng)的事件報告的(在EPOLLET模式下)
如果你不使用EPOLLET模式，那么你在讀取一個字節(jié)后，再次epoll_wait，
即使你的客服端不發(fā)送消息，也會有讀事件報告的（因為你還有數(shù)據(jù)沒讀完）

contestjia

回復(fù) 2# tc1989tc
嗯，是的，比如我客戶端傳了5個字節(jié)，epoll服務(wù)器第一次觸發(fā)EPOLLIN的時候，我只收了1個字節(jié)，
這樣的話，不是還有4個字節(jié)留在內(nèi)核緩沖區(qū)中嗎（網(wǎng)上說要觸發(fā)EPOLLIN，一直要讀到返回EAGAIN錯誤）？
下次客戶端再發(fā)數(shù)據(jù)，由于是EPOLLET的，但此時內(nèi)核緩沖區(qū)不為空（還有4個字節(jié)），沒有從不可讀變成可讀，那它應(yīng)該不會再次觸發(fā)EPOLLIN�。�
可我現(xiàn)在做的測試結(jié)果，剛好相反！
   

tc1989tc

看linux的evenepoll.c 里面的實現(xiàn)  
和你測試的結(jié)果是一致的。
它只保證啦一次報文的邊緣觸發(fā)
也就是驅(qū)動有報文來  有等待隊列 他還是會**的

contestjia

回復(fù) 4# tc1989tc
嗯勒，謝謝你！