select() 在未连接的套接字上返回 1（不一致）

Question

我正在使用非阻塞套接字连接到服务器。
在特定的测试场景中，服务器宕机，这意味着一个 TCP SYN 出去了，但是没有响应，永远无法建立连接。

在此设置中，select 通常会在 2 秒后超时，返回 0。 这是大多数时候的行为，而且看起来是正确的。

但是，在大约 5% 的情况下，select 立即返回 1（表示套接字在掩码中是可读的）。
但是当我从套接字read(2) 时，-1 会返回 'Network is unreachable'

sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
// sockfd checked and > 0
// set non-blocking

struct timeval tv{};
tv.tv_sec = 2;

int ret = connect(sockfd, addr, addrlen ); // addr set elsewhere
if (ret < 0 && errno == EINPROGRESS)
{
    fd_set cset;
    FD_ZERO(&cset);
    FD_SET(sockfd, &cset);
    
    ret = select(sockfd + 1, &cset, nullptr, nullptr, &tv);
    // returns 1 sometimes
}

在第一篇文章中，我错误地表示在错误情况下，网络上只有一个 TCP SYN（没有重试）。
这不是真的;在错误和非错误情况下，网络上都有一个 TCP SYN 在 1 秒后重新发送。

什么可能导致这种情况，有没有办法获得与select 一致的行为？

Answer 1

确定非阻塞connect() 是否完成的正确方法是询问select() 可写性而不是可读性。这在connect() documentation中有明确说明：

EINPROGRESS
套接字是非阻塞的，连接不能立即完成。 （UNIX 域套接字以 EAGAIN 代替。）可以通过选择要写入的套接字来完成 select(2) 或 poll(2)。在select(2)表示可写性后，使用getsockopt(2)读取SOL_SOCKET级别的SO_ERROR选项，判断connect()是成功完成（SO_ERROR为零）还是失败（@987654334） @ 是这里列出的常见错误代码之一，解释了失败的原因）。

在您知道实际已首先建立连接之前，使用select()/poll() 测试套接字的可读性是未定义的行为。

试试这个：

sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
// sockfd checked and > 0
// set non-blocking

int ret = connect(sockfd, addr, addrlen); // addr set elsewhere
if (ret < 0)
{
    if (errno != EINPROGRESS)
    {
        close(sockfd);
        sockfd = -1;
    }
    else
    {
        fd_set cset;
        FD_ZERO(&cset);
        FD_SET(sockfd, &cset);
    
        struct timeval tv{};
        tv.tv_sec = 2;

        ret = select(sockfd + 1, nullptr, &cset, nullptr, &tv);
        if (ret <= 0)
        {
            close(sockfd);
            sockfd = -1;
        }
        else
        {
            int errCode = 0;
            socklen_t len = sizeof(errCode);
            getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &errCode, &len);

            if (errCode != 0)
            {
                close(sockfd);
                sockfd = -1;
            }
        }
    }
}

if (sockfd != -1)
{
    // use sockfd as needed (read(), etc) ...
    close(sockfd);
}