| /NetX-Duo-v6.2.1/test/regression/mqtt_test/ |
| D | netx_mqtt_publish_packet_chain_test.c | 142 static UCHAR *topic; variable
174 topic = packet_buffer; in ntest_0_entry()
179 topic[i] = i & 0xff; 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()
|
| D | netx_mqtt_transmit_queue_depth_test.c | 142 static UCHAR *topic; variable
173 topic = packet_buffer; in ntest_0_entry()
178 topic[i] = i & 0xff; 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_subscribe_packet_chain_test.c | 141 static UCHAR *topic; variable
171 topic = packet_buffer; in ntest_0_entry()
175 topic[i] = i & 0xff; 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()
|
| D | netx_mqtt_multiple_receive_test.c | 233 static UCHAR topic[100], message[100]; variable
310 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
315 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
322 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
326 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
335 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
340 …if ((topic_length != strlen(TOPIC)) || strncmp(TOPIC, topic, topic_length) || (message_length != s… in ntest_0_entry()
|
| D | netx_mqtt_receive_span_test.c | 234 static UCHAR topic[100], message[100]; variable
307 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
312 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
319 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
324 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
|
| D | netx_mqtt_receive_qos2_test.c | 146 static UCHAR topic[100], message[100]; variable
195 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
200 …if ((topic_length != strlen(TOPIC)) || strncmp(TOPIC, topic, topic_length) || (message_length != s… in ntest_0_entry()
|
| D | netx_mqtt_receive_qos0_test.c | 238 static UCHAR topic[100], message[100]; variable
311 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
316 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
|
| D | netx_mqtt_receive_qos1_test.c | 234 static UCHAR topic[100], message[100]; variable
306 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
311 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
|
| /NetX-Duo-v6.2.1/test/regression/interoperability_test/mqtt_test/test_scripts/ |
| D | mosquitto-bridge.conf | 501 topic # both 0
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | direct_method_unit_test.c | 247 const UCHAR *topic, ULONG topic_len, in construct_direct_method_response() argument
276 assert_int_equal(__real__nx_packet_data_append(packet_ptr, (VOID *)topic, topic_len, in construct_direct_method_response()
|
| D | iot_provisioning_client_unit_test.c | 391 const UCHAR *topic, ULONG topic_len, in construct_provisioning_service_response() argument
430 assert_int_equal(__real__nx_packet_data_append(packet_ptr, (VOID *)topic, topic_len, in construct_provisioning_service_response()
470 const UCHAR *topic, ULONG topic_length, in generate_response() argument
489 &packet_ptr, topic, topic_length, in generate_response()
|
| D | nx_azure_iot_pnp_client_command_unit_test.c | 258 const UCHAR *topic, ULONG topic_len, in construct_command_message() argument
287 assert_int_equal(__real__nx_packet_data_append(packet_ptr, (VOID *)topic, topic_len, in construct_command_message()
|
| D | device_twin_unit_test.c | 270 const UCHAR *topic, ULONG topic_len, in construct_device_twin_response() argument
299 assert_int_equal(__real__nx_packet_data_append(packet_ptr, (VOID *)topic, topic_len, in construct_device_twin_response()
|
| D | nx_azure_iot_adu_agent_unit_test.c | 546 const UCHAR *topic, ULONG topic_len, in construct_command_message() argument
575 assert_int_equal(__real__nx_packet_data_append(packet_ptr, (VOID *)topic, topic_len, in construct_command_message()
|
| D | nx_azure_iot_pnp_client_properties_unit_test.c | 312 const UCHAR *topic, ULONG topic_len, in construct_command_message() argument
341 assert_int_equal(__real__nx_packet_data_append(packet_ptr, (VOID *)topic, topic_len, in construct_command_message()
|
| /NetX-Duo-v6.2.1/docs/ |
| D | revision_history.txt | 4611 … Checked topic name and message lengths in runtime.
|
