Method bind

src/utils/socket_server_tcp.cpp:24–74

}

int SocketServerTCP::bind ()
{
    if (wsa_initialized)
    {
        return (int)SocketServerTCPReturnCodes::SOCKET_ALREADY_CREATED_ERROR;
    }
    WSADATA wsadata;
    int res = WSAStartup (MAKEWORD (2, 2), &wsadata);
    if (res != 0)
    {
        return (int)SocketServerTCPReturnCodes::WSA_STARTUP_ERROR;
    }
    wsa_initialized = true;
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons (local_port);
    if (inet_pton (AF_INET, local_ip, &server_addr.sin_addr) == 0)
    {
        return (int)SocketServerTCPReturnCodes::PTON_ERROR;
    }
    server_socket = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (server_socket == INVALID_SOCKET)
    {
        return (int)SocketServerTCPReturnCodes::CREATE_SOCKET_ERROR;
    }

    if (::bind (server_socket, (const struct sockaddr *)&server_addr, sizeof (server_addr)) != 0)
    {
        return (int)SocketServerTCPReturnCodes::CONNECT_ERROR;
    }

    // ensure that library will not hang in blocking recv/send call
    DWORD timeout = 3000;
    DWORD value = 1;
    DWORD buf_size = 65536 * 4;
    setsockopt (server_socket, IPPROTO_TCP, TCP_NODELAY, (const char *)&value, sizeof (value));
    setsockopt (server_socket, SOL_SOCKET, SO_RCVTIMEO, (const char *)&timeout, sizeof (timeout));
    setsockopt (server_socket, SOL_SOCKET, SO_SNDTIMEO, (const char *)&timeout, sizeof (timeout));
    setsockopt (server_socket, SOL_SOCKET, SO_RCVBUF, (const char *)&buf_size, sizeof (buf_size));
    // set linger timeout to 1s to handle time_wait state gracefully
    struct linger sl;
    sl.l_onoff = 1;
    sl.l_linger = 1;
    setsockopt (server_socket, SOL_SOCKET, SO_LINGER, (const char *)&sl, sizeof (sl));

    if ((listen (server_socket, 1)) != 0)
    {
        return (int)SocketServerTCPReturnCodes::CONNECT_ERROR;
    }

    return (int)SocketServerTCPReturnCodes::STATUS_OK;
}

int SocketServerTCP::accept ()
{