Function client_thread_entry

components/net/utest/tc_sal_socket.c:279–345

Client thread function */

/* Client thread function */
static void client_thread_entry(void *parameter)
{
    int port = (int)parameter;
    int client_sock = -1;
    struct sockaddr_in connect_addr;
    int ret;

    LOG_I("Starting client thread for port %d", port);

    /* Wait for server to be ready */
    ret = rt_event_recv(&test_event, 0x02, RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
                        THREAD_WAIT_TIMEOUT, RT_NULL);
    if (ret != RT_EOK)
    {
        LOG_E("Failed to receive server ready signal: %d", ret);
        rt_event_send(&test_event, 0x10);
        return;
    }
    LOG_D("Received server ready signal");

    if (!server_ready)
    {
        LOG_W("Server not ready, skipping connection");
        rt_event_send(&test_event, 0x10);
        return;
    }

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

    /* Setup connect address */
    memset(&connect_addr, 0, sizeof(connect_addr));
    connect_addr.sin_family = AF_INET;
    connect_addr.sin_addr.s_addr = inet_addr(local_ip);
    connect_addr.sin_port = htons(port);
    LOG_D("Configured client connect address: %s:%d", local_ip, port);

    /* Connect to server */
    LOG_I("Attempting to connect to server %s:%d", local_ip, port);
    ret = sal_connect(client_sock, (struct sockaddr *)&connect_addr, sizeof(connect_addr));
    LOG_I("Connect result: %d", ret);

    if (ret == 0)
    {
        LOG_I("Connection to server successful");
        rt_thread_mdelay(CLIENT_DELAY_MS);
    }
    else
    {
        LOG_E("Connection to server failed: return=%d, errno=%d", ret, errno);
    }