文章 经验实在太重要了:epoll的一些补充 提到几个Epoll的关键问题,这里借鉴作者的说法,记录一下,感谢作者的文章。
默认使用的是ET模式,即,边沿触发,类似于电平触发,epoll中的边沿触发的意思是只对新到的数据进行通知,而内核缓冲区中如果是旧数据则不进行通知,所以在do_use_fd函数中应该使用如下循环,才能将内核缓冲区中的数据读完。
- while(1){
- len=recv(*******);
- if(len==-1){
- if(errno==EAGAIN)
- break;
- perror("recv");
- break;
- }
- dosomethingwiththerecveddata........
- }
在上面例子中没有说明对于listen socket fd该如何处理,有的时候会使用两个线程, 一个用来监听accept另一个用来监听epoll_wait,如果是这样使用的话,则listen socket fd使用默认的阻塞方式就行了,而如果epoll_wait和accept处于一个线程中,即,全部由epoll_wait进行监听,则,需将listen socket fd也设置成非阻塞的,这样,对accept也应该使用while包起来(类似于上面的recv),因为,epoll_wait返回时只是说有连接到来了,并没有说有几个连接,而且在ET模式下epoll_wait不会再因为上一次的连接还没读完而返回,这种情况确实存在,我因为这个问题而耗费了一天多的时间,这里需要说明的是,每调用一次accept将从内核中的已连接队列中的队头读取一个连接,因为在并发访问的环境下,有可能有多个连接“同时”到达,而epoll_wait只返回了一次。
Reactor模型关键处理代码如下:
- while(_run){
- update();
- }
- voidCEpollReactor::update()
- {
- intepret=epoll_wait(_epollHandle,_epollEvents,EVENT_COUNT,200);
- if(epret==-1)
- {
- debug::send(NETWORK,"epoll_waiterrorerrno=%d.",errno);
- debug::send(NETWORK,"%s.",strerror(errno));
- //break;
- return;
- }
- updateTimerList();
- if(epret==0)
- {
- //debug::send(NETWORK,"EPOLLtimeouted.");
- //timeout
- }
- if(epret>0)
- {
- for(inti=0;i<epret;++i)
- {
- CSocket*socket=(CSocket*)(_epollEvents[i].data.ptr);
- if(_epollEvents[i].events&(EPOLLERR|EPOLLHUP))
- {
- debug::send(NETWORK,"EPOLLERRonfd%d.",socket->getHandle());
- socket->handleClose();
- socket->setReactor(NULL);
- socket->close();
- continue;
- }
- intret=0;
- if(_epollEvents[i].events&EPOLLIN)
- {
- debug::send(NETWORK,"EPOLLINonfd%d.",socket->getHandle());
- ret=socket->handleRead();
- }
- if(ret==-1)
- {
- socket->handleClose();
- socket->setReactor(NULL);
- socket->close();
- continue;
- }
- if(_epollEvents[i].events&EPOLLOUT)
- {
- debug::send(NETWORK,"EPOLLOUTonfd%d",socket->getHandle());
- ret=socket->handleWrite();
- }
- if(ret==-1)
- {
- socket->handleClose();
- socket->setReactor(NULL);
- socket->close();
- continue;
- }
- }
- }
- }