| /NetX-Duo-v6.2.1/test/regression/websocket_test/ |
| D | netx_websocket_one_packet_with_multi_frames_test.c | 246 NX_PACKET *packet_ptr1; in thread_client_entry() local
382 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
387 packet_ptr1 -> nx_packet_append_ptr = packet_ptr1 -> nx_packet_prepend_ptr; in thread_client_entry()
388 packet_ptr1 -> nx_packet_length = 0; in thread_client_entry()
389 …status = nx_packet_data_append(packet_ptr1, client_test_data, sizeof(client_test_data), &client_po… in thread_client_entry()
392 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
397 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 5*NX_IP_PERIODIC_RATE… in thread_client_entry()
402 if (packet_ptr1 -> nx_packet_length != 4) in thread_client_entry()
405 if (packet_ptr1 -> nx_packet_next || packet_ptr1 -> nx_packet_last) in thread_client_entry()
410 if (*(packet_ptr1 -> nx_packet_prepend_ptr + i) != (i + 1)) in thread_client_entry()
[all …]
|
| D | netx_websocket_16_bit_payload_length_test.c | 280 NX_PACKET *packet_ptr1; in thread_client_entry() local
370 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
375 packet_ptr1 -> nx_packet_append_ptr = packet_ptr1 -> nx_packet_prepend_ptr; in thread_client_entry()
376 packet_ptr1 -> nx_packet_length = 0; in thread_client_entry()
377 …status = nx_packet_data_append(packet_ptr1, client_test_data, sizeof(client_test_data), &client_po… in thread_client_entry()
380 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
385 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 5 * NX_IP_PERIODIC_RA… in thread_client_entry()
390 if (packet_ptr1 -> nx_packet_length != 256) in thread_client_entry()
397 if (*(packet_ptr1 -> nx_packet_prepend_ptr + i) != (i % 32)) in thread_client_entry()
403 nx_packet_release(packet_ptr1); in thread_client_entry()
[all …]
|
| D | netx_websocket_fin_test.c | 191 NX_PACKET *packet_ptr1; in thread_client_entry() local
270 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
275 …status = nx_packet_data_append(packet_ptr1, client_test_data, sizeof(client_test_data), &client_po… in thread_client_entry()
278 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
283 … status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, NX_IP_PERIODIC_RATE); in thread_client_entry()
290 nx_packet_release(packet_ptr1); in thread_client_entry()
293 … status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, NX_IP_PERIODIC_RATE); in thread_client_entry()
300 nx_packet_release(packet_ptr1); in thread_client_entry()
303 … status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, NX_IP_PERIODIC_RATE); in thread_client_entry()
310 nx_packet_release(packet_ptr1); in thread_client_entry()
|
| D | netx_websocket_one_frame_in_packets_test.c | 191 NX_PACKET *packet_ptr1; in thread_client_entry() local
270 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
275 packet_ptr1 -> nx_packet_append_ptr = packet_ptr1 -> nx_packet_prepend_ptr; in thread_client_entry()
276 packet_ptr1 -> nx_packet_length = 0; in thread_client_entry()
277 …status = nx_packet_data_append(packet_ptr1, client_test_data, sizeof(client_test_data), &client_po… in thread_client_entry()
280 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
285 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, NX_NO_WAIT); in thread_client_entry()
290 if (packet_ptr1 -> nx_packet_length != 4) in thread_client_entry()
293 nx_packet_release(packet_ptr1); in thread_client_entry()
|
| D | netx_websocket_send_chain_packets_test.c | 221 NX_PACKET *packet_ptr1; in thread_client_entry() local
274 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
285 …memcpy((void *)&packet_ptr1 -> nx_packet_prepend_ptr[0], (void *)client_send_frame_packet_1, sizeo… in thread_client_entry()
286 packet_ptr1 -> nx_packet_append_ptr += sizeof(client_send_frame_packet_1); in thread_client_entry()
287 …packet_ptr1 -> nx_packet_length = sizeof(client_send_frame_packet_1) + sizeof(client_send_frame_pa… in thread_client_entry()
297 packet_ptr1 -> nx_packet_next = packet_ptr2; in thread_client_entry()
300 packet_ptr1 -> nx_packet_last = packet_ptr3; in thread_client_entry()
302 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
|
| D | netx_websocket_mask_test.c | 193 NX_PACKET *packet_ptr1; in thread_client_entry() local
272 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
277 …status = nx_packet_data_append(packet_ptr1, client_test_data, sizeof(client_test_data), &client_po… in thread_client_entry()
280 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
285 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
292 nx_packet_release(packet_ptr1); in thread_client_entry()
295 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
302 nx_packet_release(packet_ptr1); in thread_client_entry()
305 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
|
| D | netx_websocket_opcode_test.c | 191 NX_PACKET *packet_ptr1; in thread_client_entry() local
270 status = nx_packet_allocate(&client_pool, &packet_ptr1, NX_TCP_PACKET, NX_IP_PERIODIC_RATE); in thread_client_entry()
275 …status = nx_packet_data_append(packet_ptr1, client_test_data, sizeof(client_test_data), &client_po… in thread_client_entry()
278 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
283 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
290 nx_packet_release(packet_ptr1); in thread_client_entry()
293 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
297 nx_packet_release(packet_ptr1); in thread_client_entry()
304 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
|
| D | netx_websocket_delete_test.c | 177 NX_PACKET *packet_ptr1; in thread_client_entry() local
|
| D | netx_websocket_disconnect_test.c | 182 NX_PACKET *packet_ptr1; in thread_client_entry() local
|
| D | netx_websocket_connect_test.c | 275 NX_PACKET *packet_ptr1; in thread_client_entry() local
|
| D | netx_websocket_non_block_test.c | 278 NX_PACKET *packet_ptr1; in thread_client_entry() local
|
