Function tcp_server_entry

components/net/utest/tc_lwip.c:254–419

}

static void tcp_server_entry(void *parameter)
{
#define LWIP_TCP_TEST_BUF_SIZE           2048

    rt_bool_t fail_flag = RT_TRUE;
    char *recv_data = RT_NULL;
    int sock = -1, bytes_received, ret, i, port, connected = 0, mode;
    socklen_t sin_size, listend_addr_len, peer_len;
    struct sockaddr_in server_addr, client_addr, listend_addr, peer_addr;

    recv_data = rt_malloc(LWIP_TCP_TEST_BUF_SIZE);
    if (recv_data == RT_NULL)
    {
        uassert_true(RT_FALSE);
        goto __exit;
    }

    port = RT_UTEST_LWIP_TCP_PORT;

    /* create socket */
    if ((sock = lwip_socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
        uassert_true(RT_FALSE);
        goto __exit;
    }
    else
    {
        uassert_true(RT_TRUE);
    }

    /* set Repeat bind port and address */
    mode = 1;
    lwip_setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &mode, sizeof(int));
    lwip_setsockopt(sock, SOL_SOCKET, SO_REUSEPORT, &mode, sizeof(int));

    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    /* server addr:127.0.0.1 for loopback test */
    server_addr.sin_addr.s_addr = htonl(IPADDR_LOOPBACK);
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

    /* bind socket */
    if (lwip_bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
    {
        rt_kprintf("TCP server bind failed\n");
        uassert_true(RT_FALSE);
        goto __exit;
    }
    else
    {
        rt_kprintf("TCP server bound to 127.0.0.1:%d\n", port);
        uassert_true(RT_TRUE);
    }

    /* listen socket */
    if (lwip_listen(sock, 5) == -1)
    {
        rt_kprintf("TCP server listen failed\n");