Function ServerThread

engine/dlib/src/test/test_socket.cpp:73–126

}

static void ServerThread(void* arg)
{
    struct ServerThreadInfo* info = (struct ServerThreadInfo *) arg;
    dmSocket::Result result = dmSocket::RESULT_OK;
    dmSocket::Socket server_sock = -1;
    dmSocket::Address server_addr;
    dmSocket::Socket client_sock = -1;
    dmSocket::Address client_addr;

#define T_ASSERT_EQ(_A, _B) \
    if ( (_A) != (_B) ) { \
        printf("%s:%d: ASSERT: %s != %s: %d != %d", __FILE__, __LINE__, #_A, #_B, (_A), (_B)); \
    } \
    assert( (_A) == (_B) );

    // Setup server socket and listen for a client to connect
    result = dmSocket::New(info->domain, dmSocket::TYPE_STREAM, dmSocket::PROTOCOL_TCP, &server_sock);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    result = dmSocket::SetReuseAddress(server_sock, true);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    const char* hostname = dmSocket::IsSocketIPv4(server_sock) ? DM_LOOPBACK_ADDRESS_IPV4 : DM_LOOPBACK_ADDRESS_IPV6;
    result = dmSocket::GetHostByName(hostname, &server_addr, dmSocket::IsSocketIPv4(server_sock), dmSocket::IsSocketIPv6(server_sock));
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    result = dmSocket::Bind(server_sock, server_addr, info->port);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    result = dmSocket::Listen(server_sock, 1000); // Backlog = 1000
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    // Wait for a client to connect
    dmAtomicStore32(&info->listening, 1);
    result = dmSocket::Accept(server_sock, &client_addr, &client_sock);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    // Send data to the client for verification
    int value = 0x00def01d;
    int written = 0;

    result = dmSocket::Send(client_sock, &value, sizeof(value), &written);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);
    T_ASSERT_EQ((int) sizeof(value), written);

    dmAtomicStore32(&info->sent, 1);

    // Teardown
    result = dmSocket::Delete(client_sock);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);

    result = dmSocket::Delete(server_sock);
    T_ASSERT_EQ(dmSocket::RESULT_OK, result);
}

inline dmSocket::Socket GetSocket(dmSocket::Domain domain)
{