FreeBSD平台kqueue非阻塞connect错误检测方法咨询

核心问题结论 #

1. 必须保留getsockopt(SO_ERROR)检测逻辑，无法仅靠kqueue返回的flags/fflags字段完成100%准确的错误判断
   你在Linux epoll下总结的经验在FreeBSD kqueue场景下依然成立：kqueue的事件标记是内核事件通知层的状态标记，不是socket层错误的权威来源。哪怕你测通了TIMEDOUT、CONNRESET、CONNREFUSED三类常见场景，依然存在边缘场景（比如路由瞬断、防火墙特殊规则静默丢弃报文、多路径路由切换触发的连接失败、内核socket资源临时耗尽导致的异步连接失败等）不会触发明确的EV_EOF或错误标记，仅会返回EVFILT_WRITE就绪事件，此时必须靠SO_ERROR拿到真实的连接结果。
2. 不能仅靠检测EV_EOF覆盖所有非阻塞connect错误场景
   kqueue在socket连接失败时确实会在多数常见场景下置位EV_EOF，同时在fflags中填充对应错误码（比如ECONNREFUSED、ETIMEDOUT、ECONNRESET），但这个行为不是强制的socket错误上报契约：
   • 部分FreeBSD内核版本下，三次握手最后一个ACK丢失触发的超时重传失败场景，只会触发EVFILT_WRITE事件，不会置位EV_EOF
   • 当socket设置了SO_OOBINLINE等特殊选项时，连接阶段的异步错误不会触发EV_EOF标记
   • 瞬态的内核协议栈资源不足导致的连接失败，可能仅在SO_ERROR中记录错误，不会在kqueue事件中上报特殊标记

适配kqueue的非阻塞connect实现逻辑 #

对应你原有epoll逻辑，迁移后的事件处理框架如下：

n = kevent(kq, NULL, 0, evs, YPOLL_KEVENT_NEVENTS, timeout_ts);
/* 先处理kevent返回值错误，比如EINTR场景的重试逻辑 */

for (i = 0; i < n; i++) {
    struct sock *sock = (struct sock*)evs[i].udata;
    int state = sock->state;
    short filter = evs[i].filter;
    u_short flags = evs[i].flags;
    intptr_t fflags = evs[i].fflags;

    /* 非连接中状态的socket先处理通用错误 */
    if (state != CONNECTION_IN_PROGRESS) {
        if (flags & EV_EOF) {
            /* 对端断开、读写通道关闭，取fflags里的错误做清理 */
            int err = (int)fflags;
            /* 执行socket关闭、资源回收逻辑 */
            continue;
        }
        if (flags & EV_ERROR) {
            /* kevent事件本身注册错误或者socket发生致命错误 */
            int err = (int)fflags;
            /* 执行错误处理、socket关闭逻辑 */
            continue;
        }
        /* 后续处理可读、可写等常规业务逻辑 */
        /* ... */
        continue;
    }

    /* 处理连接中状态的socket */
    if (state == CONNECTION_IN_PROGRESS) {
        int sock_err = 0;
        socklen_t errlen = sizeof(sock_err);

        /* 不管有没有EV_EOF/EV_ERROR标记，只要事件触发就先查SO_ERROR */
        if (getsockopt(sock->fd, SOL_SOCKET, SO_ERROR, &sock_err, &errlen) < 0) {
            /* getsockopt本身失败，直接判定连接异常 */
            /* 执行连接失败清理逻辑 */
            continue;
        }

        if (sock_err != 0) {
            /* 连接真实失败，sock_err为对应错误码 */
            /* 执行失败处理逻辑，比如打印错误、重连、回收资源 */
            continue;
        }

        /* SO_ERROR返回0，确认连接建立成功 */
        /* 注意：此时需要重新注册该socket的读/写事件，替换连接阶段的写监听标记 */
        sock->state = CONNECTION_PAIRED;
        /* 执行连接成功后的业务初始化逻辑 */
        continue;
    }
}

额外注意事项 #

• 连接成功后一定要记得重新修改kqueue上注册的该fd事件过滤器，不要一直监听EVFILT_WRITE，否则会持续触发可写事件占用CPU
• 不要依赖EV_EOF的fflags字段作为错误码的唯一来源，该字段只有在EV_EOF置位时才有效，未置位时读取到的值是无意义的
• 非阻塞connect发起后，不要在连接完成前调用send/recv等IO操作，否则可能拿到不符合预期的错误码干扰判断

内容的提问来源于stack exchange，提问作者jorge is not ai