根據(jù)epoll的manual ， epoll在ET模式下觸發(fā)可讀信號后必須一直讀取直到出現(xiàn)EAGAIN ，一般在應(yīng)用中會預(yù)先分布至少足夠一個完整報文大小的緩沖區(qū)，接收到可讀信號后可以一次性讀取所有數(shù)據(jù)，但是當(dāng)單個報文足夠大時，很可能出現(xiàn)系統(tǒng)緩沖空間不足，從之導(dǎo)致無法一次性讀取所有數(shù)據(jù)，雖然數(shù)據(jù)已經(jīng)到達 。也就是說，一個數(shù)據(jù)可讀信號觸發(fā)的讀取操作很可能無法讀取所有數(shù)據(jù)，需要循環(huán)讀取直到遇到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
測試結(jié)果：
[215745][tcp_handler.cpp:59]read fd=8 num=3426
[215745][tcp_handler.cpp:61]total read fd=8 num=3426 //一次完成讀取所有數(shù)據(jù)
[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 //兩次才完成讀取所有數(shù)據(jù)
[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