理解TCP中的kqueue

Question

我正在学习关于kqueue (特别是http://eradman.com/posts/kqueue-tcp.html和tutorial/)的教程，有些部分我不明白。下面是我的(编辑)代码：

// assume internal_socket is listening
void run_server(int internal_socket) {
    const int nchanges = 1;
    const int nevents = BACKLOG;

    struct kevent change_list[nchanges];
    struct kevent event_list[nevents];

    int kq = kqueue();

    if (kq == -1) {
        // error
    }

    EV_SET(&change_list, sock_internal, EVFILT_READ, EV_ADD, 0, 0, 0);

    while (true) {
        int nev = kevent(kq, change_list, nchanges, event_list, nevents, NULL);

        if (nev == -1) {
            // error
        }

        for (int i = 0; i < nev; ++i) {
            if (event_list[i].flags & EV_EOF) {
                int fd = event_list[i].ident;
                EV_SET(&change_list, fd, EVFILT_READ, EV_DELETE, 0, 0, NULL);
                if (kevent(kq, &change_list, nchanges, NULL, 0, NULL) == -1) {
                    // error
                }
                close(fd);
            } else if (event_list[i].ident == sock_internal) {
                int fd = accept(event_list[i].ident, ...);
                // do stuff
            } else if (event_list[i].flags == EVFILT_READ) {
                int bytes_read = recv(event_list[i].ident, ...);
                // do stuff
            }
        } // for
    } // while (true)
} // func

我不明白：

1. 设置nevents = BACKLOG (即并发连接的数量)是正确的吗？如果不是，新教徒应该是什么？
2. 为什么我要检查event_list[i].flags & EV_EOF？我的最佳猜测是，如果连接在套接字处于队列中时失败，那么我想从队列中删除该套接字吗？但我为什么要再打电话给kevent？
3. 在与前一点相同的部分中，我称之为close(fd)。对吗？根除者教程有一些额外的巫术，但我不明白为什么。
4. 如果理解正确，则当我准备读取部分消息时，kqueue可能会返回。我怎么知道消息什么时候完成？

如果是相关的话，我正在研究OS。

Answer 1

对代码/问题的快速思考：

1. 不是的。 不需要BACKLOG == nevents。 您可以一次一次地从队列中选择事件，或者一次从几十个事件中选择事件，这主要取决于您的偏好和最小化系统调用与内存/堆栈空间之间的关系。 也不是很经常你会有所有的连接同时触发事件..。花费那么多内存是没有意义的--特别是当您考虑大并发时，这可能意味着大内存可能会导致缓存丢失，并可能导致性能损失。
2. EV_EOF 过滤器可以设置此标志以指示特定于筛选器的EOF条件。

这意味着您必须指定一个可能引发此标志的筛选器。哪个过滤器能做到这一点？你在听这些活动吗？

您可以在 page中找到这些

例如，在套接字中，客户端断开read容量，而保留套接字的write容量。EVFILT_WRITE过滤器(如果设置)将调用EV_EOF标志。

就我个人而言，我认为在write失败时可以检查这些边缘情况，而不是引发事件。

1. 打电话给close是合理的..。取决于你想要什么。我可能只为了读取数据而保持连接。或者调用shutdown，因为它被认为更有礼貌(但现在可能并不那么重要)。
2. 你不需要。这不是TCP/IP的问题。 消息包装应该由正在实现的协议(即Websockets / HTTP)执行。每个协议都有不同的消息包装/完成设计。 TCP/IP层封装数据包。在野外，这些通常限制在1500个字节，而互联网的许多部分运行在576字节。你可以谷歌MTU获得更多信息。

备注：

• 您可能希望向kqueue添加新客户端。
• 我会考虑每个循环重置nchanges值。