根據epoll的manual , epoll在ET模式下觸發可讀信號后必須一直讀取直到出現EAGAIN ,一般在應用中會預先分布至少足夠一個完整報文大小的緩沖區,接收到可讀信號后可以一次性讀取所有數據,但是當單個報文足夠大時,很可能出現系統緩沖空間不足,從之導致無法一次性讀取所有數據,雖然數據已經到達 。也就是說,一個數據可讀信號觸發的讀取操作很可能無法讀取所有數據,需要循環讀取直到遇到EAGAIN 。
while(1)
{
int ret = read(fd,buf+pos,sizeof(buf)-pos) ;
if ( ret == 0 )
{ // client disconnect
}
else if ( ret < 0 )
{
if ( errno == EAGAIN ) break ;
else if ( errno == EINTR ) continue ;
// some error occurs
}
pos += ret ;
//check if buffer full or do request
//**************note : sometimes the FIN and data arrive at the same time
}
// do request
測試結果:
[215745][tcp_handler.cpp:59]read fd=8 num=3426
[215745][tcp_handler.cpp:61]total read fd=8 num=3426 //一次完成讀取所有數據
[215750][tcp_handler.cpp:53]disconnect fd=8
[215751][server_app.cpp:169]new connection , fd=8
[215751][tcp_handler.cpp:59]read fd=8 num=57538
[215751][tcp_handler.cpp:59]read fd=8 num=3426
[215751][tcp_handler.cpp:61]total read fd=8 num=60964 //兩次才完成讀取所有數據
[215756][tcp_handler.cpp:53]disconnect fd=8
[215758][server_app.cpp:169]new connection , fd=8
[215758][tcp_handler.cpp:59]read fd=8 num=57538
[215758][tcp_handler.cpp:59]read fd=8 num=3426
[215758][tcp_handler.cpp:61]total read fd=8 num=60964
[215803][tcp_handler.cpp:53]disconnect fd=8
[215806][server_app.cpp:169]new connection , fd=8
[215806][tcp_handler.cpp:59]read fd=8 num=57538
[215806][tcp_handler.cpp:59]read fd=8 num=3426
[215806][tcp_handler.cpp:61]total read fd=8 num=60964
[215811][tcp_handler.cpp:53]disconnect fd=8