Function udp_server_entry

components/net/utest/tc_lwip.c:589–705

}

static void udp_server_entry(void *parameter)
{
#define LWIP_UDP_RECV_BUF    16

    fd_set fdread;
    struct timeval timeout;
    rt_bool_t fail_flag = RT_TRUE;
    char recv_data[LWIP_UDP_RECV_BUF];
    int sock = -1, bytes_received, ret, port, maxsock;
    socklen_t client_len, timeout_len;
    struct sockaddr_in server_addr, client_addr;

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

    /* set timeout */
    timeout_len = sizeof(timeout);
    timeout.tv_sec = 5;
    timeout.tv_usec = 0;
    ret = lwip_setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, (void *) &timeout, timeout_len);
    uassert_true(ret == 0);

    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    /* server addr:0.0.0.0 for UDP to work with external IP */
    server_addr.sin_addr.s_addr = htonl(IPADDR_ANY);
    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("UDP server bind failed\n");
        uassert_true(RT_FALSE);
        goto __exit;
    }
    else
    {
        rt_kprintf("UDP server bound to 0.0.0.0:%d\n", port);
        uassert_true(RT_TRUE);
    }

    maxsock = sock;
    FD_ZERO(&fdread);
    FD_SET(sock, &fdread);
    /* wait for recv data */
    ret = lwip_select(maxsock + 1, &fdread, NULL, NULL, &timeout);
    if (ret <= 0)
    {