Function server_thread_entry

components/net/utest/tc_sal_socket.c:168–276

Server thread function */

/* Server thread function */
static void server_thread_entry(void *parameter)
{
    int port = (int)parameter;
    int server_sock = -1;
    struct sockaddr_in bind_addr;
    int ret;

    LOG_I("Starting server thread on port %d", port);

    /* Create server socket */
    server_sock = create_test_socket(AF_INET, SOCK_STREAM, 0);
    if (server_sock < 0)
    {
        LOG_E("Failed to create server socket");
        rt_event_send(&test_event, 0x01);
        return;
    }

    /* Setup bind address */
    memset(&bind_addr, 0, sizeof(bind_addr));
    bind_addr.sin_family = AF_INET;
    bind_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    bind_addr.sin_port = htons(port);
    LOG_D("Configured server bind address: port %d", port);

    /* Bind server socket */
    ret = sal_bind(server_sock, (struct sockaddr *)&bind_addr, sizeof(bind_addr));
    if (ret != 0)
    {
        LOG_E("Failed to bind server socket %d: return=%d, errno=%d", server_sock, ret, errno);
        close_test_socket(server_sock);
        rt_event_send(&test_event, 0x01);
        return;
    }
    LOG_I("Server socket %d bound to port %d", server_sock, port);

    /* Listen on server socket */
    ret = sal_listen(server_sock, 5);
    if (ret != 0)
    {
        LOG_E("Failed to listen on server socket %d: return=%d, errno=%d", server_sock, ret, errno);
        close_test_socket(server_sock);
        rt_event_send(&test_event, 0x01);
        return;
    }
    LOG_I("Server socket %d listening with backlog 5", server_sock);

    server_ready = 1;
    rt_event_send(&test_event, 0x02);
    LOG_I("Server ready and signaled on port %d", port);

    /* Wait for client connection */
    ret = rt_event_recv(&test_event, 0x04, RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
                        RT_WAITING_FOREVER, RT_NULL);
    if (ret != RT_EOK)
    {
        LOG_E("Failed to receive client connect signal: %d", ret);
        rt_event_send(&test_event, 0x01);