关于epoll的一个疑问

yang_crystal

for ( ; ; ) {         //等待epoll事件的发生         nfds=epoll_wait(epfd,events,20,500);         //处理所发生的所有事件              for(i=0;i<nfds;++i)         {             if(events.data.fd==listenfd)             {                 connfd = accept(listenfd,(sockaddr *)&clientaddr, &clilen);                 if(connfd<0){                     perror("connfd<0");                     exit(1);                 }                 //setnonblocking(connfd);                 char *str = inet_ntoa(clientaddr.sin_addr);                 cout << "accapt a connection from " << str << endl;                 //设置用于读操作的文件描述符                 ev.data.fd=connfd;                 //设置用于注测的读操作事件                 ev.events=EPOLLIN|EPOLLET;                 //ev.events=EPOLLIN;                 //注册ev                 epoll_ctl(epfd,EPOLL_CTL_ADD,connfd,&ev);             }             else if(events.events&EPOLLIN)             {                 cout << "EPOLLIN" << endl;                 if ( (sockfd = events.data.fd) < 0)                     continue;                 if ( (n = read(sockfd, line, MAXLINE)) < 0) {                     if (errno == ECONNRESET) {                         close(sockfd);                         events.data.fd = -1;                     } else                         std::cout<<"readline error"<<std::endl;                 } else if (n == 0) {                     close(sockfd);                     events.data.fd = -1;                 }                 line[n] = '\0';                 cout << "read " << line << endl;                 //设置用于写操作的文件描述符                 ev.data.fd=sockfd;                 //设置用于注测的写操作事件                 ev.events=EPOLLOUT|EPOLLET;                 //修改sockfd上要处理的事件为EPOLLOUT                 //epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);             }             else if(events.events&EPOLLOUT)             {                    sockfd = events.data.fd;                 write(sockfd, line, n);                 //设置用于读操作的文件描述符                 ev.data.fd=sockfd;                 //设置用于注测的读操作事件                 ev.events=EPOLLIN|EPOLLET;                 //修改sockfd上要处理的事件为EPOLIN                 epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);             }         }

在看的时候想到这么一个问题，epoll在ET模式下当收到通知一个套接字可读时候需要把该读的数据一次读完，因为假设读不完的话epoll不会再通知，这时候需要你继续读，直到read返回EAGAIN，这时候假设有个连接成功之后就不停地发数据，发的比你读的还快，这时候服务进程不是一直在read这一个连接上的数据啦，而其他的链接上的数据就一直在等待啊？这时候不就是拒绝服务啦？
不知道我说清楚问题没

cookis

你的怀疑很对，这就会倒致其他连接出现饥渴的问题，手册里有说明

1. 
   
2. o Starvation (edge-triggered)
   
3. 
   
4.        If  there is a large amount of I/O space, it is possible that by trying to drain it the other files will not get processed causing starvation.  (This problem is
   
5.        not specific to epoll.)
   
6. 
   
7.        The solution is to maintain a ready list and mark the file descriptor as ready in its associated data structure, thereby allowing the  application  to  remember
   
8.        which files need to be processed but still round robin amongst all the ready files.  This also supports ignoring subsequent events you receive for file descrip-
   
9.        tors that are already ready.
   
10. 
    

复制代码

cookis

我一直用水平触发模式，同时也是 非阻塞式接收直到 EAGAIN, 如果数据超过缓冲区大小，就退出循环

yang_crystal

哦，知道了，谢谢，听说LT模式在连接比较多的时候CPU占用会很高，不知道大家都怎么用的

yang_crystal

还有个疑问，就是当你判断到有可读的，加到连表里后需要从epoll中把这个套接字删掉么，就是调用epoll_ctl(epfd,EPOLL_CTL_DEL,sockfd,&ev) 么