| /NetX-Duo-v6.2.1/test/regression/mqtt_test/ |
| D | netx_mqtt_publish_packet_chain_test.c | 140 static UINT QoS; variable
190 QoS = 1; in ntest_0_entry()
204 …client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, NX_IP_PERIODIC_RAT… 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 …client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, 5 * NX_IP_PERIODIC… in ntest_0_entry()
376 control_header = control_header | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_subscribe_non_zero_packet_id_test.c | 216 static UINT QoS; variable
276 QoS = 1; in ntest_0_entry()
278 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC1, strlen(TOPIC1), QoS); in ntest_0_entry()
286 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC1, strlen(TOPIC1), QoS); in ntest_0_entry()
291 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC1, strlen(TOPIC1), QoS); in ntest_0_entry()
466 *byte++ = QoS & 0x3; in ntest_1_entry()
494 byte[4] = QoS & 0x3; in ntest_1_entry()
540 *byte++ = QoS & 0x3; in ntest_1_entry()
568 byte[4] = QoS & 0x3; in ntest_1_entry()
619 *byte++ = QoS & 0x3; in ntest_1_entry()
[all …]
|
| D | netx_mqtt_subscribe_packet_chain_test.c | 140 static UINT QoS; variable
185 QoS = 1; in ntest_0_entry()
201 status = nxd_mqtt_client_subscribe(client_ptr, topic, TOPIC_LEN, QoS); in ntest_0_entry()
212 status = nxd_mqtt_client_subscribe(client_ptr, topic, TOPIC_LEN, QoS); in ntest_0_entry()
347 if ((packet_buffer[0] != control_header) || (packet_buffer[packet_len -1] != (QoS & 0x3))) in ntest_1_entry()
|
| D | netx_mqtt_transmit_queue_depth_test.c | 140 static UINT QoS; variable
189 QoS = 1; in ntest_0_entry()
197 …client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, 5 * NX_IP_PERIODIC… in ntest_0_entry()
203 …client_publish(client_ptr, topic, TOPIC_LEN, message, MESSAGE_LEN, retain, QoS, 5 * NX_IP_PERIODIC… in ntest_0_entry()
|
| D | netx_mqtt_publish_qos2_test.c | 124 static UINT QoS; variable
159 QoS = 2; in ntest_0_entry()
162 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 2); in ntest_0_entry()
275 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_publish_non_zero_packet_id_test.c | 219 static UINT QoS; variable
281 QoS = 1; 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()
485 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
591 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
696 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_packet_leak_test.c | 216 static UINT QoS; variable
274 QoS = 1; in ntest_0_entry()
277 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC1, strlen(TOPIC1), QoS); in ntest_0_entry()
452 *byte++ = QoS & 0x3; in ntest_1_entry()
482 byte[4] = QoS & 0x3; in ntest_1_entry()
|
| D | netx_mqtt_subscribe_test.c | 216 static UINT QoS; variable
274 QoS = 1; in ntest_0_entry()
277 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC1, strlen(TOPIC1), QoS); in ntest_0_entry()
449 *byte++ = QoS & 0x3; in ntest_1_entry()
478 byte[4] = QoS & 0x3; in ntest_1_entry()
|
| D | netx_mqtt_unsubscribe_test.c | 217 static UINT QoS; variable
276 QoS = 1; in ntest_0_entry()
278 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC1, strlen(TOPIC1), QoS); in ntest_0_entry()
458 *byte++ = QoS & 0x3; in ntest_1_entry()
487 byte[4] = QoS & 0x3; in ntest_1_entry()
|
| D | netx_mqtt_publish_qos0_test.c | 219 static UINT QoS; variable
279 QoS = 0; in ntest_0_entry()
283 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
464 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_publish_qos1_test.c | 218 static UINT QoS; variable
278 QoS = 1; in ntest_0_entry()
281 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
462 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_keepalive_test.c | 219 static UINT QoS; variable
277 QoS = 1; in ntest_0_entry()
287 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
474 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_keepalive_timeout_test.c | 219 static UINT QoS; variable
279 QoS = 1; in ntest_0_entry()
289 …qtt_client_publish(client_ptr, TOPIC1, strlen(TOPIC1), MESSAGE1, strlen(MESSAGE1), retain, QoS, 1); in ntest_0_entry()
487 content[0] = content[0] | (QoS << 1); in ntest_1_entry()
|
| D | netx_mqtt_branch_test.c | 233 static UINT QoS; variable
298 QoS = 1; in ntest_0_entry()
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.c | 317 USHORT *packet_id_ptr, UINT QoS) in _nxd_mqtt_client_sub_unsub() argument
418 temp_data[0] = QoS & 0x3; in _nxd_mqtt_client_sub_unsub()
1289 UCHAR QoS; in _nxd_mqtt_process_publish_packet() local
1297 QoS = (UCHAR)((*(packet_ptr -> nx_packet_prepend_ptr) & MQTT_PUBLISH_QOS_LEVEL_FIELD) >> 1); in _nxd_mqtt_process_publish_packet()
1327 if ((QoS == 1) || (QoS == 2)) in _nxd_mqtt_process_publish_packet()
1409 UCHAR QoS; in _nxd_mqtt_process_publish() local
1421 QoS = (UCHAR)((*(packet_ptr -> nx_packet_prepend_ptr) & MQTT_PUBLISH_QOS_LEVEL_FIELD) >> 1); in _nxd_mqtt_process_publish()
1447 if (QoS == 0) in _nxd_mqtt_process_publish()
1529 if (QoS == 0) in _nxd_mqtt_process_publish()
1550 if (QoS == 1) in _nxd_mqtt_process_publish()
[all …]
|
| D | nxd_mqtt_client.h | 466 UINT retain, UINT QoS, ULONG timeout);
467 …ent_subscribe(NXD_MQTT_CLIENT *mqtt_client_pr, CHAR *topic_name, UINT topic_name_length, UINT QoS);
499 USHORT packet_id, UINT QoS, ULONG wait_option);
501 … CHAR *message, UINT message_length, UINT retain, UINT QoS, ULONG timeout);
506 … CHAR *topic_name, UINT topic_name_length, USHORT *packet_id_ptr, UINT QoS);
507 …_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length, UINT QoS);
533 … CHAR *message, UINT message_length, UINT retain, UINT QoS, ULONG timeout);
537 …_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length, UINT QoS);
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | direct_method_unit_test.c | 101 USHORT *packet_id_ptr, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
109 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_unsubscribe() argument
148 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
167 assert_int_equal(QoS, 0); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | device_twin_unit_test.c | 129 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
139 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_unsubscribe() argument
178 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
190 assert_int_equal(QoS, 0); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | d2c_unit_test.c | 327 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
349 assert_int_equal(QoS, 1); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | nx_azure_iot_pnp_client_command_unit_test.c | 115 USHORT *packet_id_ptr, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
155 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
174 assert_int_equal(QoS, 0); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | c2d_unit_test.c | 525 USHORT *packet_id_ptr, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
532 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_unsubscribe() argument
|
| D | user_agent_string_unit_test.c | 276 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
|
| D | iot_provisioning_client_unit_test.c | 239 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
261 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
305 assert_int_equal(QoS, 1); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | nx_azure_iot_pnp_client_properties_unit_test.c | 168 USHORT *packet_id_ptr, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
210 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
229 assert_int_equal(QoS, 0); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | nx_azure_iot_adu_agent_unit_test.c | 357 USHORT *packet_id_ptr, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
399 USHORT packet_id, UINT QoS, ULONG wait_option) in __wrap__nxd_mqtt_client_publish_packet_send() argument
|
