Function udp_client_entry

components/net/utest/tc_lwip.c:486–587

}

static void udp_client_entry(void *parameter)
{
#define LWIP_UDP_TEST_BUF_SIZE 16

    rt_bool_t fail_flag = RT_TRUE;
    int ret, sock = -1, port;
    struct sockaddr_in server_addr;
    char send_buf[] = "hello";
    char recv_buf[LWIP_UDP_TEST_BUF_SIZE];
    socklen_t addr_len = sizeof(struct sockaddr_in);

    port = RT_UTEST_LWIP_UDP_PORT;

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

    /* bind to any port */
    struct sockaddr_in client_bind_addr;
    client_bind_addr.sin_family = AF_INET;
    client_bind_addr.sin_port = 0; /* let system assign port */
    client_bind_addr.sin_addr.s_addr = htonl(IPADDR_ANY);
    rt_memset(&(client_bind_addr.sin_zero), 0, sizeof(client_bind_addr.sin_zero));
    if (lwip_bind(sock, (struct sockaddr *)&client_bind_addr, sizeof(struct sockaddr)) == -1)
    {
        rt_kprintf("UDP client bind failed\n");
        uassert_true(RT_FALSE);
        goto __exit;
    }
    rt_kprintf("UDP client bound\n");

    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));

    /* wait for the server to enter the receive state */
    rt_thread_mdelay(10);

    /* send data to server */
    ret = lwip_sendto(sock, send_buf, rt_strlen(send_buf), 0, (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
    if (ret <= 0)
    {
        rt_kprintf("UDP client sendto failed: sent %d\n", ret);
        uassert_true(RT_FALSE);
        goto __exit;
    }
    rt_kprintf("UDP client sent %d bytes: %s\n", ret, send_buf);

    /* receive echo from server with timeout */