Home
last modified time | relevance | path

Searched refs:mqtt_app_flag (Results 1 – 6 of 6) sorted by relevance

/NetX-Duo-v6.4.1/samples/
Ddemo_mqtt_client.c68 TX_EVENT_FLAGS_GROUP mqtt_app_flag; variable
88 tx_event_flags_set(&mqtt_app_flag, DEMO_MESSAGE_EVENT, TX_OR); in my_notify_func()
128 status = tx_event_flags_create(&mqtt_app_flag, "my app event"); in thread_mqtt_entry()
160 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in thread_mqtt_entry()
/NetX-Duo-v6.4.1/test/regression/mqtt_test/
Dnetx_mqtt_receive_qos2_test.c136 TX_EVENT_FLAGS_GROUP mqtt_app_flag; variable
141 tx_event_flags_set(&mqtt_app_flag, DEMO_MESSAGE_EVENT, TX_OR); in my_notify_func()
162 status = tx_event_flags_create(&mqtt_app_flag, "my app event"); in ntest_0_entry()
193 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
Dnetx_mqtt_receive_span_test.c224 TX_EVENT_FLAGS_GROUP mqtt_app_flag; variable
229 tx_event_flags_set(&mqtt_app_flag, DEMO_MESSAGE_EVENT, TX_OR); in my_notify_func()
250 status = tx_event_flags_create(&mqtt_app_flag, "my app event"); in ntest_0_entry()
305 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
317 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
Dnetx_mqtt_multiple_receive_test.c223 TX_EVENT_FLAGS_GROUP mqtt_app_flag; variable
228 tx_event_flags_set(&mqtt_app_flag, DEMO_MESSAGE_EVENT, TX_OR); in my_notify_func()
254 status = tx_event_flags_create(&mqtt_app_flag, "my app event"); in ntest_0_entry()
308 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
320 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
332 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
Dnetx_mqtt_receive_qos0_test.c228 TX_EVENT_FLAGS_GROUP mqtt_app_flag; variable
233 tx_event_flags_set(&mqtt_app_flag, DEMO_MESSAGE_EVENT, TX_OR); in my_notify_func()
254 status = tx_event_flags_create(&mqtt_app_flag, "my app event"); in ntest_0_entry()
309 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()
Dnetx_mqtt_receive_qos1_test.c223 TX_EVENT_FLAGS_GROUP mqtt_app_flag; variable
228 tx_event_flags_set(&mqtt_app_flag, DEMO_MESSAGE_EVENT, TX_OR); in my_notify_func()
250 status = tx_event_flags_create(&mqtt_app_flag, "my app event"); in ntest_0_entry()
304 tx_event_flags_get(&mqtt_app_flag, DEMO_ALL_EVENTS, TX_OR_CLEAR, &events, TX_WAIT_FOREVER); in ntest_0_entry()