以下全部来自man epoll
页面:
函数 do_use_fd() 使用新的就绪文件描述符,直到 read(2) 或 write(2) 返回 EAGAIN。
ET 触发的代码示例:
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.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);
}
}
所以对于read/write
操作,我们应该通过循环直到EAGAIN
收到 a 来完成;但是为什么不是这样accept
呢?
IMO,当有多个客户端套接字等待接受时,上面的代码会丢失一些请求,因为它只接受1 个客户端套接字,我们还应该将它包装在一个循环中,直到EAGAIN
收到。
或者也许我错过了什么?