Has anyone successfully used NetX Duo websockets?

[robmilne]

I lifted regression test code from the netxduo stack to attempt a websocket client, but the best I can achieve is a 400 response from the server.  Has anyone successfully using websockets with STM32 + netxduo?

The following code resides inside app_netxduo.c.  The thread is created TX_DONT_START and is resumed in the nx_app_thread_entry thread.  It dies on line 59 with a  NX_WEBSOCKET_INVALID_STATUS_CODE return.  I am trying to connect with a flask-socketio project running on a Ubuntu system.

#include "nx_websocket_client.h"

#define DEMO_STACK_SIZE      4096
#define TEST_SERVER_ADDRESS  IP_ADDRESS(192,168,100,2)
#define TEST_SERVER_PORT     8000
#define TEST_HOST_NAME       "192.168.100.2"
#define TEST_URI_PATH        "/ws"
#define TEST_PROTOCOL        " "

static UCHAR client_test_data[4] = { 0x11, 0x22, 0x33, 0x44 };

void thread_client_entry(ULONG thread_input)
{
    UINT            status;
    NX_PACKET       *packet_ptr;
    NXD_ADDRESS     server_ip_address;
    UINT            code;

    /* Create client socket.  */
    status = nx_tcp_socket_create(&NetXDuoEthIpInstance, &test_client,
                                  "Client Socket", NX_IP_NORMAL,
                                  NX_FRAGMENT_OKAY, NX_IP_TIME_TO_LIVE,
                                  WINDOW_SIZE, NX_NULL, NX_NULL);
    assert(NX_SUCCESS == status);

    /* Create WebSocket.  */
    status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ",
                                        &NetXDuoEthIpInstance, &NxAppPool);
    assert(NX_SUCCESS == status);

    /* Give IP task and driver a chance to initialize the system.  */
    tx_thread_sleep(NX_IP_PERIODIC_RATE);

    /* Bind and connect to server.  */
    status = nx_tcp_client_socket_bind(&test_client, TEST_SERVER_PORT,
                                       NX_IP_PERIODIC_RATE);
    assert(NX_SUCCESS == status);

    /* Wait test server started.
    while (!test_server_start)
    { */
        tx_thread_sleep(NX_IP_PERIODIC_RATE * 10);
    //}

    /* Set server IP address.  */
    server_ip_address.nxd_ip_address.v4 = TEST_SERVER_ADDRESS;
    server_ip_address.nxd_ip_version = NX_IP_VERSION_V4;

    status = nxd_tcp_client_socket_connect(&test_client, &server_ip_address,
                                           TEST_SERVER_PORT, NX_IP_PERIODIC_RATE);
    assert(NX_SUCCESS == status);

    /* Upgrade to websocket */
    status = nx_websocket_client_connect(&client_websocket, &test_client,
                                         (UCHAR *)TEST_HOST_NAME, sizeof(TEST_HOST_NAME) - 1,
                                         (UCHAR *)TEST_URI_PATH, sizeof(TEST_URI_PATH) - 1,
                                         (UCHAR *)TEST_PROTOCOL, sizeof(TEST_PROTOCOL) - 1,
                                         NX_WAIT_FOREVER);
    assert(NX_SUCCESS == status);

    status = nx_packet_allocate(&NxAppPool, &packet_ptr, NX_TCP_PACKET,
                                NX_IP_PERIODIC_RATE);
    assert(NX_SUCCESS == status);

    /* Append and send data.  */
    packet_ptr -> nx_packet_append_ptr = packet_ptr -> nx_packet_prepend_ptr;
    packet_ptr -> nx_packet_length = 0;
    status = nx_packet_data_append(packet_ptr, client_test_data,
                                   sizeof(client_test_data), &NxAppPool,
                                   NX_IP_PERIODIC_RATE);
    assert(NX_SUCCESS == status);
    status = nx_websocket_client_send(&client_websocket, packet_ptr,
                                      NX_WEBSOCKET_OPCODE_BINARY_FRAME,
                                      NX_TRUE, NX_WAIT_FOREVER);
    assert(NX_SUCCESS == status);

    /* Receive the responsed data from server.  */
    status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code,
                                         NX_IP_PERIODIC_RATE);
    assert(NX_SUCCESS == status);
    /* The first response from the server shall be an unfragmented frame  */
    if (client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE)
        assert(NX_SUCCESS == status);

    nx_packet_release(packet_ptr);

    status = nx_websocket_client_delete(&client_websocket);
    if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0)
        assert(0);

    /* TCP Disconnect.  */
    status = nx_tcp_socket_disconnect(&test_client, NX_IP_PERIODIC_RATE);
    assert(NX_SUCCESS == status);

    nx_tcp_client_socket_unbind(&test_client);
    nx_tcp_socket_delete(&test_client);
}

[STea]

Hello @robmilne ,

this is clearly not a hardware related issue, but a problem related to software implementation of  websocket client.

I would recommend you check the availability of the server manually when this problem happens and i would not recommend setting delays like this in your thread try implementing this example using callbacks to make it easier to debug and upgrade as well. use Wireshark to inspect the traffic will help you understand what is happening. 

Regards