各位做網(wǎng)絡(luò)框架的注意啦，發(fā)現(xiàn)epoll有驚群！

yulihua49

發(fā)現(xiàn)epoll有驚群，即使使用了EPOLLONESHOT。
很偶然，今天又被撲捉到一次。程序新增的防驚群代碼：

1. 
   
2.             fds = epoll_wait(g_epoll_fd, &event, 1 , -1);
   
3.             task = (TCB *)event.data.ptr;
   
4.             if(task->events) {//在加入epoll前清0
   
5.                 ShowLog(1,"%s:task->events=%08X,conflict!",__FUNCTION__,task->events);//發(fā)現(xiàn)驚群
   
6.                 continue;//丟掉它
   
7.             }
   
8.             task->events=event.events;
   

復(fù)制代碼

wlmqgzm

ShowLog(1,"%s:epoll_wait err=%d,%s",__FUNCTION__,errno,strerror(errno));

完全可以簡化,  warn_message_str(str_msg), 只需要一個(gè)參數(shù) 呵呵呵

#define warn_message_str(str_msg)      warning_message1((__FILE__),(__LINE__),(__FUNCTION__),(str_msg.c_str()))

void append_str_msg_error(std::string &str_msg, int int_errno)
{
  if( int_errno==0)   return;

  std::string str_error =  strerror( int_errno ) ;
  if( str_error.length()>0)  {
    str_msg += "error=";
    str_msg += str_error;
    str_msg += ", errno=";
    str_msg += std::to_string(int_errno);
    return;
    }
  str_msg += "errno=";
  str_msg += std::to_string(int_errno);
  return;
}

wlmqgzm

不錯(cuò),  這兩天剛開始做一個(gè)網(wǎng)絡(luò)程序,  還正在完善代碼, 謝謝了

yulihua49

wlmqgzm 發(fā)表于 2015-10-12 19:25
ShowLog(1,"%s:epoll_wait err=%d,%s",__FUNCTION__,errno,strerror(errno));

完全可以簡化,  warn_mes ...

這個(gè)。。。。。。似乎與本主題無關(guān)。
今天測試了幾個(gè)小時(shí)，沒事了，再也沒有捕捉到驚群。不過大家應(yīng)該注意一下。
想測一下這樣處理驚群行不行，可是它不出了。

hanxin83

yulihua49 發(fā)表于 2015-10-12 20:04
這個(gè)。。。。。。似乎與本主題無關(guān)。
今天測試了幾個(gè)小時(shí)，沒事了，再也沒有捕捉到驚群。不過大家應(yīng)該注 ...

是不是瞅一下內(nèi)核代碼去, 看看有沒有觸發(fā)驚群的分枝?

lwhjava

頂，老爺子就是厲害！

pandaiam

回復(fù) 1# yulihua49


    余總..
你的sdbc qq群號是?
上次qq問題,批量退群了..再加下吧..

windoze

如果用EPOLLET呢？

yulihua49

pandaiam 發(fā)表于 2015-10-13 14:16
回復(fù) 1# yulihua49

SDBC:100807652