| /NetX-Duo-v6.2.1/test/regression/websocket_test/ |
| D | netx_websocket_one_packet_with_multi_frames_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
262 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
265 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
292 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
298 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
314 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
315 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
321 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, 5*NX_IP_PERIODIC_RATE); in thread_client_entry()
322 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
325 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_FALSE) || (code != NX_WEBSOCKET_O… in thread_client_entry()
[all …]
|
| D | netx_websocket_non_block_test.c | 36 static NX_WEBSOCKET_CLIENT client_websocket; variable
289 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
290 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
297 …nx_websocket_client_connection_status_callback_set(&client_websocket, NX_NULL, connection_status_c… in thread_client_entry()
298 if (client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
324 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
329 …if (status != NX_IN_PROGRESS || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_coun… in thread_client_entry()
336 status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, NX_NO_WAIT); in thread_client_entry()
349 …if (i == 5 || connect_succeed == NX_FALSE || client_websocket.nx_websocket_client_mutex.tx_mutex_o… in thread_client_entry()
352 status = nx_websocket_client_delete(&client_websocket); in thread_client_entry()
[all …]
|
| D | netx_websocket_disconnect_test.c | 34 static NX_WEBSOCKET_CLIENT client_websocket; variable
193 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
223 status = nx_websocket_client_disconnect(&client_websocket, 0); in thread_client_entry()
224 …if (status != NX_WEBSOCKET_INVALID_STATE || client_websocket.nx_websocket_client_mutex.tx_mutex_ow… in thread_client_entry()
228 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
248 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
253 status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, NX_NO_WAIT); in thread_client_entry()
257 if (client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE) in thread_client_entry()
262 status = nx_websocket_client_disconnect(&client_websocket, 0); in thread_client_entry()
263 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
[all …]
|
| D | netx_websocket_fin_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
202 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
232 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
254 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
259 … status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, NX_IP_PERIODIC_RATE); in thread_client_entry()
263 if (client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE) 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()
287 if (client_websocket.nx_websocket_client_frame_fragmented == NX_FALSE) in thread_client_entry()
293 … status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, NX_IP_PERIODIC_RATE); in thread_client_entry()
[all …]
|
| D | netx_websocket_16_bit_payload_length_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
291 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
321 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
343 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
348 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, 5 * NX_IP_PERIODIC_RAT… in thread_client_entry()
351 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE) || (code != NX_WEBSOCKET_OP… 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()
388 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_FALSE) && (code != NX_WEBSOCKET_O… in thread_client_entry()
406 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 5 * NX_IP_PERIODIC_RA… in thread_client_entry()
[all …]
|
| D | netx_websocket_connect_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
286 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
287 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
313 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
320 …if (status != NX_WEBSOCKET_INVALID_PACKET || client_websocket.nx_websocket_client_mutex.tx_mutex_o… in thread_client_entry()
324 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
329 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
332 status = nx_websocket_client_delete(&client_websocket); in thread_client_entry()
333 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
338 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
[all …]
|
| D | netx_websocket_mask_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
204 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
234 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
256 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
261 status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, 500); in thread_client_entry()
265 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE) || (code != NX_WEBSOCKET_OP… 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()
289 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_FALSE) || (code != NX_WEBSOCKET_O… in thread_client_entry()
295 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
[all …]
|
| D | netx_websocket_opcode_test.c | 37 static NX_WEBSOCKET_CLIENT client_websocket; variable
202 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
232 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
254 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
259 status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, 500); in thread_client_entry()
263 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE) || (code != NX_WEBSOCKET_OP… 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()
287 …if ((client_websocket.nx_websocket_client_frame_fragmented == NX_FALSE) || (code != NX_WEBSOCKET_O… in thread_client_entry()
293 status = nx_websocket_client_receive(&client_websocket, &packet_ptr1, &code, 500); in thread_client_entry()
[all …]
|
| D | netx_websocket_delete_test.c | 34 static NX_WEBSOCKET_CLIENT client_websocket; variable
189 status = nx_websocket_client_delete(&client_websocket); in thread_client_entry()
190 …if (status != NX_PTR_ERROR || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count … in thread_client_entry()
195 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
225 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
245 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
250 status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, NX_NO_WAIT); in thread_client_entry()
258 status = nx_websocket_client_delete(&client_websocket); in thread_client_entry()
259 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
262 if (client_websocket.nx_websocket_client_processing_packet != NX_NULL) in thread_client_entry()
|
| D | netx_websocket_multi_instance_test.c | 34 static NX_WEBSOCKET_CLIENT client_websocket; variable
262 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
265 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
292 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
298 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
310 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
311 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
315 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, 5 * NX_IP_PERIODIC_RAT… in thread_client_entry()
316 if (status || client_websocket.nx_websocket_client_mutex.tx_mutex_ownership_count != 0) in thread_client_entry()
326 nx_websocket_client_delete(&client_websocket); in thread_client_entry()
[all …]
|
| D | netx_websocket_one_frame_in_packets_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
202 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
232 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
254 …status = nx_websocket_client_send(&client_websocket, packet_ptr, NX_WEBSOCKET_OPCODE_BINARY_FRAME,… in thread_client_entry()
259 status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, NX_NO_WAIT); in thread_client_entry()
263 if (client_websocket.nx_websocket_client_frame_fragmented == NX_TRUE) 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()
|
| D | netx_websocket_send_chain_packets_test.c | 33 static NX_WEBSOCKET_CLIENT client_websocket; variable
234 status = nx_websocket_client_create(&client_websocket, (UCHAR *)" ", &client_ip, &client_pool); in thread_client_entry()
264 status = nx_websocket_client_connect(&client_websocket, &test_client, in thread_client_entry()
302 …status = nx_websocket_client_send(&client_websocket, packet_ptr1, NX_WEBSOCKET_OPCODE_BINARY_FRAME… in thread_client_entry()
307 …status = nx_websocket_client_receive(&client_websocket, &packet_ptr, &code, 5 * NX_IP_PERIODIC_RAT… in thread_client_entry()
|
