Method connect

src/fl/stl/asio/ip/tcp.cpp.hpp:177–238

bool socket::is_open() const { return mFd != -1; }

error_code socket::connect(const endpoint &ep) {
    // Clean up existing
    close_fd();

#ifdef FL_IS_WIN
    if (!initialize_winsock()) {
        return error_code(errc::unknown, "winsock init failed");
    }
#endif

    // Resolve hostname
    struct addrinfo hints {};
    struct addrinfo *result = nullptr;

    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_protocol = IPPROTO_TCP;

    char portStr[16];
    fl::snprintf(portStr, sizeof(portStr), "%u", ep.port);

    int ret = getaddrinfo(ep.host.c_str(), portStr, &hints, &result);
    if (ret != 0 || result == nullptr) {
        return error_code(errc::host_not_found, "getaddrinfo failed");
    }

    error_code ec(errc::connection_refused, "no addresses succeeded");

    for (struct addrinfo *addr = result; addr != nullptr; addr = addr->ai_next) {
        int sock =
            plat_socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol);
        if (sock < 0)
            continue;

        mFd = sock;
        // Keep socket BLOCKING for connect() — non-blocking connect
        // returns EINPROGRESS/WSAEWOULDBLOCK which is racy: subsequent
        // send() can fail with ENOTCONN if the TCP handshake hasn't
        // completed yet.  A blocking connect on loopback completes in
        // microseconds; on real networks, the timeout is the OS default
        // (typically 75-120 s), which is acceptable for a "synchronous
        // connect" API.

        ret = plat_connect(mFd, addr->ai_addr,
                           static_cast<socklen_t>(addr->ai_addrlen));

        if (ret == 0) {
            // Connected — now switch to non-blocking for all I/O
            set_nonblocking(mFd, true);
            mNonBlocking = true;
            ec = error_code();
            break;
        }

        // Failed — try next address
        plat_close(mFd);
        mFd = -1;
    }