Home
last modified time | relevance | path

Searched refs:semaphore_client_stop (Results 1 – 25 of 27) sorted by relevance

12

/NetX-Duo-v6.2.1/test/regression/mqtt_test/
Dnetx_mqtt_connect_packet_send_failure_test.c53 static TX_SEMAPHORE semaphore_client_stop; variable
106 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
266 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
348 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_packet_leak_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
103 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
259 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
283 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
518 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_publish_qos0_test.c56 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
263 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
289 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
546 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_publish_qos1_test.c56 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
263 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
287 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
544 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_receive_qos0_test.c65 static TX_SEMAPHORE semaphore_client_stop; variable
112 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
292 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
322 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
550 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_subscribe_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
103 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
259 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
283 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
559 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connack_error_test.c53 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
275 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
452 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_non_block_test.c54 static TX_SEMAPHORE semaphore_client_stop; variable
101 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
288 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
465 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
107 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
282 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
467 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_v6_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
113 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
345 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
519 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_keepalive_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
262 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
296 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
620 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_keepalive_timeout_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
105 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
264 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
301 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
605 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_receive_qos1_test.c60 static TX_SEMAPHORE semaphore_client_stop; variable
107 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
287 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
319 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
570 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_receive_span_test.c60 static TX_SEMAPHORE semaphore_client_stop; variable
108 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
288 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
330 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
545 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_unsubscribe_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
260 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
292 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
590 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_will_message_test.c53 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
287 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
489 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_will_topic_only_test.c53 static TX_SEMAPHORE semaphore_client_stop; variable
104 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
292 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
491 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_subscribe_non_zero_packet_id_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
103 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
260 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
297 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
687 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_with_auth_will_test.c55 static TX_SEMAPHORE semaphore_client_stop; variable
107 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
293 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
517 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_websocket_block_test.c41 static TX_SEMAPHORE semaphore_client_stop; variable
110 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
294 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
689 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_multiple_receive_test.c60 static TX_SEMAPHORE semaphore_client_stop; variable
107 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
291 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
349 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
714 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_publish_non_zero_packet_id_test.c57 static TX_SEMAPHORE semaphore_client_stop; variable
105 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
265 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
303 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
779 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
Dnetx_mqtt_connect_auth_empty_test.c53 static TX_SEMAPHORE semaphore_client_stop; variable
98 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
304 tx_semaphore_put(&semaphore_client_stop); in ntest_0_entry()
626 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in ntest_1_entry()
/NetX-Duo-v6.2.1/test/regression/web_test/
Dnetx_web_client_receive_no_packet_test.c77 static TX_SEMAPHORE semaphore_client_stop; variable
102 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
290 tx_semaphore_put(&semaphore_client_stop); in thread_client_entry()
387 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in thread_server_entry()
Dnetx_web_client_send_fail_test.c76 static TX_SEMAPHORE semaphore_client_stop; variable
101 tx_semaphore_create(&semaphore_client_stop, "semaphore client stop", 0); in test_application_define()
304 tx_semaphore_put(&semaphore_client_stop); in thread_client_entry()
394 tx_semaphore_get(&semaphore_client_stop, NX_WAIT_FOREVER); in thread_server_entry()

12