Posted on 2012-03-14 17:47
S.l.e!ep.￠% 閱讀(589)
評論(0) 編輯 收藏 引用 所屬分類:
epoll
man中給出了epoll的用法，example程序如下：
for(;;) {
nfds = epoll_wait(kdpfd, events, maxevents, -1);
for(n = 0; n < nfds; ++n) {
if(events[n].data.fd == listener) {
client = accept(listener, (struct sockaddr *) &local,
&addrlen);
if(client < 0){
perror("accept");
continue;
}
setnonblocking(client);
ev.events = EPOLLIN | EPOLLET;
ev.data.fd = client;
if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, client, &ev) < 0) {
fprintf(stderr, "epoll set insertion error: fd=%d\n",
client);
return -1;
}
}
else
do_use_fd(events[n].data.fd);
}
}
此時使用的是ET模式，即，邊沿觸發，類似于電平觸發，epoll中的邊沿觸發的意思是只對新到的數據進行通知，而內核緩沖區中如果是舊數據則不進行通知，所以在do_use_fd函數中應該使用如下循環，才能將內核緩沖區中的數據讀完。
while (1) {
len = recv(*******);
if (len == -1) {
if(errno == EAGAIN)
break;
perror("recv");
break;
}
do something with the recved data........
}
在上面例子中沒有說明對于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只返回了一次。
其實是很簡單的問題，對于有經驗的人來說根本不會犯這樣的錯誤，而我卻耗費了一天多的時間，經驗確實太重要了。