根據(jù)epoll的manual ， epoll在ET模式下觸發(fā)可讀信號(hào)后必須一直讀取直到出現(xiàn)EAGAIN ，一般在應(yīng)用中會(huì)預(yù)先分布至少足夠一個(gè)完整報(bào)文大小的緩沖區(qū)，接收到可讀信號(hào)后可以一次性讀取所有數(shù)據(jù)，但是當(dāng)單個(gè)報(bào)文足夠大時(shí)，很可能出現(xiàn)系統(tǒng)緩沖空間不足，從之導(dǎo)致無(wú)法一次性讀取所有數(shù)據(jù)，雖然數(shù)據(jù)已經(jīng)到達(dá) 。也就是說(shuō)，一個(gè)數(shù)據(jù)可讀信號(hào)觸發(fā)的讀取操作很可能無(wú)法讀取所有數(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
測(cè)試結(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