Function tcp_client_entry

components/net/utest/tc_lwip.c:104–252

}

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

    rt_tick_t old_tick = 0;
    rt_bool_t fail_flag = RT_TRUE;
    int sock = -1, mode, port, ret, i, flag;
    struct sockaddr_in server_addr;
    char *send_buf = RT_NULL;
    char *recv_buf = RT_NULL;

    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 no-blocking mode */
    flag = lwip_fcntl(sock, F_GETFL, 0);
    lwip_fcntl(sock, F_SETFL, flag | O_NONBLOCK);
    flag = lwip_fcntl(sock, F_GETFL, 0);
    uassert_true(flag & O_NONBLOCK);

    /* Set blocking mode */
    mode = 0;
    lwip_ioctl(sock, FIONBIO, &mode);

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

    old_tick = rt_tick_get();
    /* connect to server */
    while (1)
    {
        if (lwip_connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
        {
            /* timeout: 5s */
            if (rt_tick_get() - old_tick > 5 * RT_TICK_PER_SECOND)
            {
                rt_kprintf("TCP client connect timeout\n");
                uassert_true(RT_FALSE);
                goto __exit;
            }
            else
            {
                rt_thread_mdelay(RT_TICK_PER_SECOND);
                continue;
            }