[轉(zhuǎn)]epoll程序都使用下面的框架

hy0kl

1. epoll程序都使用下面的框架：
   
2. 
   
3. for( ; ; )
   
4. {
   
5.     nfds = epoll_wait(epfd, events, 20, 500);
   
6.     for(i = 0; i < nfds; ++i)
   
7.     {
   
8.         if(events[i].data.fd == listenfd) //有新的連接
   
9.         {
   
10.             connfd = accept(listenfd, (sockaddr *)&clientaddr, &clilen); //accept這個(gè)連接
    
11.             ev.data.fd = connfd;
    
12.             ev.events = EPOLLIN | EPOLLET;
    
13.             epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, &ev); //將新的fd添加到epoll的監(jiān)聽隊(duì)列中
    
14.         }
    
15.         else if( events[i].events & EPOLLIN ) //接收到數(shù)據(jù)，讀socket
    
16.         {
    
17.             n = read(sockfd, line, MAXLINE)) < 0    //讀
    
18.             ev.data.ptr = md;     //md為自定義類型，添加數(shù)據(jù)
    
19.             ev.events = EPOLLOUT | EPOLLET;
    
20.             epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, &ev);//修改標(biāo)識符，等待下一個(gè)循環(huán)時(shí)發(fā)送數(shù)據(jù)，異步處理的 精髓
    
21.         }
    
22.         else if(events[i].events & EPOLLOUT) //有數(shù)據(jù)待發(fā)送，寫socket
    
23.         {
    
24.             struct myepoll_data* md = (myepoll_data*)events[i].data.ptr;    //取數(shù)據(jù)
    
25.             sockfd = md->fd;
    
26.             send( sockfd, md->ptr, strlen((char*)md->ptr), 0 );        //發(fā)送數(shù)據(jù)
    
27.             ev.data.fd = sockfd;
    
28.             ev.events = EPOLLIN | EPOLLET;
    
29.             epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, &ev); //修改標(biāo)識符，等待下一個(gè)循環(huán)時(shí)接收數(shù)據(jù)
    
30.         }
    
31.         else
    
32.         {
    
33.             //其他的處理
    
34.         }
    
35.     }
    
36. }

復(fù)制代碼

hellioncu

沒法保證一次都能send完成，所以實(shí)際不會這么簡單的

teng0210

EAGAIN

LaoLiulaoliu

挺好，還有SIGPIPE 等問題

fm971

如果每次返回的數(shù)據(jù)很小，其實(shí)完全可以直接調(diào)用 send()，避免了epoll_ctl()的開銷
epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, &ev);//