| /NetX-Duo-v6.2.1/test/regression/mqtt_test/ |
| D | netx_mqtt_publish_packet_chain_test.c | 141 static UINT retain; variable
191 retain = 0; in ntest_0_entry()
204 …status = nxd_mqtt_client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, … in ntest_0_entry()
209 …status = nxd_mqtt_client_publish(client_ptr, topic, 195, message, MESSAGE_LEN, retain, QoS, NX_IP_… in ntest_0_entry()
214 …status = nxd_mqtt_client_publish(client_ptr, topic, 66, message, MESSAGE_LEN, retain, QoS, NX_IP_P… in ntest_0_entry()
224 …status = nxd_mqtt_client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, … in ntest_0_entry()
377 if (retain) in ntest_1_entry()
|
| D | netx_mqtt_transmit_queue_depth_test.c | 141 static UINT retain; variable
190 retain = 0; in ntest_0_entry()
197 …status = nxd_mqtt_client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, … in ntest_0_entry()
203 …status = nxd_mqtt_client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, … in ntest_0_entry()
|
| D | netx_mqtt_publish_qos2_test.c | 125 static UINT retain; variable
160 retain = 0; in ntest_0_entry()
162 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 2); in ntest_0_entry()
276 if(retain) in ntest_1_entry()
|
| D | netx_mqtt_publish_non_zero_packet_id_test.c | 220 static UINT retain; variable
282 retain = 0; in ntest_0_entry()
284 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
292 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE2, strlen(MESSAGE2), retain, QoS, 1); in ntest_0_entry()
297 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE3, strlen(MESSAGE3), retain, QoS, 1); in ntest_0_entry()
486 if (retain) in ntest_1_entry()
592 if (retain) in ntest_1_entry()
697 if (retain) in ntest_1_entry()
|
| D | netx_mqtt_publish_qos0_test.c | 220 static UINT retain; variable
280 retain = 0; in ntest_0_entry()
283 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
465 if (retain) in ntest_1_entry()
|
| D | netx_mqtt_publish_qos1_test.c | 219 static UINT retain; variable
279 retain = 0; in ntest_0_entry()
281 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
463 if (retain) in ntest_1_entry()
|
| D | netx_mqtt_keepalive_test.c | 220 static UINT retain; variable
278 retain = 0; in ntest_0_entry()
287 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
475 if (retain) in ntest_1_entry()
|
| D | netx_mqtt_keepalive_timeout_test.c | 220 static UINT retain; variable
280 retain = 0; in ntest_0_entry()
289 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
488 if (retain) in ntest_1_entry()
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.h | 466 UINT retain, UINT QoS, ULONG timeout);
501 … CHAR *message, UINT message_length, UINT retain, UINT QoS, ULONG timeout);
533 … CHAR *message, UINT message_length, UINT retain, UINT QoS, ULONG timeout);
|
| D | nxd_mqtt_client.c | 4842 … CHAR *message, UINT message_length, UINT retain, UINT QoS, ULONG wait_option) in _nxd_mqtt_client_publish() argument
4873 if (retain) in _nxd_mqtt_client_publish()
5823 … CHAR *message, UINT message_length, UINT retain, UINT QoS, ULONG wait_option) in _nxde_mqtt_client_publish() argument
5849 …lish(client_ptr, topic_name, topic_name_length, message, message_length, retain, QoS, wait_option)… in _nxde_mqtt_client_publish()
|
