4

epoll的手册页有一个边缘触发的示例代码，如下所示：

for (;;) {
    nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);
    if (nfds == -1) {
        perror("epoll_pwait");
        exit(EXIT_FAILURE);
    }

    for (n = 0; n < nfds; ++n) {
        if (events[n].data.fd == listen_sock) {
            conn_sock = accept(listen_sock,
                        (struct sockaddr *) &local, &addrlen);
            if (conn_sock == -1) {
                perror("accept");
                exit(EXIT_FAILURE);
            }
            setnonblocking(conn_sock);
            ev.events = EPOLLIN | EPOLLET;
            ev.data.fd = conn_sock;
            if (epoll_ctl(epollfd, EPOLL_CTL_ADD, conn_sock,
                    &ev) == -1) {
                perror("epoll_ctl: conn_sock");
                exit(EXIT_FAILURE);
            }
        } else {
            do_use_fd(events[n].data.fd);
        }
    }
}

在函数 do_use_fd 中，我在 while 循环中调用 nonblocked recv 直到 EAGAIN，示例代码工作正常。

我对这个示例代码有疑问，假设现在我有 50 个套接字客户端连接，突然有 10 个客户端同时写入数据，所以 epoll_wait() 将返回 10 然后进入 for 循环：

for (n = 0; n < nfds; ++n)

它将调用 do_use_fd(events[n].data.fd); 这 10 个客户端，假设 n=5 已完成，而 n=6 尚未完成，突然事件 n=3 的文件描述已收到新数据，在所有这 10 个事件完成后返回 epoll_wait ，我会收到通知我有客户有新数据要读取的事件吗？否则我会错过它，因为当事件发生时，代码不在 epoll_wait 中！

4

2 回答 2

13

只要你一直读到EAGAIN报错，下次调用时就会得到事件epoll_wait。

该事件仅在空和非空（或满和非满EPOLLOUT）之间发生变化时触发，但该状态会一直保持到通过 传递事件epoll_wait。

在一个有点相关的说明：如果您注册EPOLLIN和EPOLLOUT事件并假设您从未填满发送缓冲区，您仍然会在每次触发EPOLLOUT返回的事件中设置标志- 请参阅https://lkml.org/lkml/2011 /11/17/234以获得更详细的解释。epoll_waitEPOLLIN

最后，边缘触发模式的确切行为实际上取决于所使用的套接字类型，并且在任何地方都没有真正记录。我前段时间做了一些测试，并在这里记录了我的发现：http: //cmeerw.org/blog/753.html#753 - 简而言之，对于数据报套接字，您可能会收到比预期更多的事件。

于 2012-10-15T14:04:04.563 回答
2

当你在 epoll 下使用 Edge Triggered 时，读一些东西，可以这样

int n = -1;
while (1)
{
    n = recv(fd, iobuf, init_buff_size, MSG_DONTWAIT);
    if (n > 0)
    {
        LOG(glogfd, LOG_TRACE, "fd[%d] recv len %d\n", fd, n);
        mybuff_setdata(&(curcon->recv_buff), iobuf, n); // this is my func
        if (n == init_buff_size)
        {
            LOG(glogfd, LOG_DEBUG, "fd[%d] need recv nextloop %d\n", fd, n);
            continue;
        }
        break;
    }
    if (n == 0)
    {
        LOG(glogfd, LOG_ERROR, "fd[%d] close %s:%d!\n", fd, ID, LN);
        return do_close(fd);
    }
    if (errno == EINTR)
    {
        LOG(glogfd, LOG_TRACE, "fd[%d] need recv again!\n", fd);
        continue;
    }
    else if (errno == EAGAIN)
    {
        LOG(glogfd, LOG_TRACE, "fd[%d] need recv next!\n", fd);
        modify_fd_event(fd, EPOLLIN);   // this is the KEY, add read again
        break;
    }
    else
    {
        LOG(glogfd, LOG_ERROR, "fd[%d] close %s:%d!\n", fd, ID, LN);
        return do_close(fd);
    }
}
于 2013-08-01T10:21:26.830 回答