| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.h | 465 UINT nxd_mqtt_client_publish(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length,…
467 …ent_subscribe(NXD_MQTT_CLIENT *mqtt_client_pr, CHAR *topic_name, UINT topic_name_length, UINT QoS);
468 …mqtt_client_unsubscribe(NXD_MQTT_CLIENT *mqtt_client_pr, CHAR *topic_name, UINT topic_name_length);
500 UINT _nxd_mqtt_client_publish(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length,
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);
508 …nxd_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length);
532 …NT _nxde_mqtt_client_publish(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length,
537 …_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length, UINT QoS);
538 …xde_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length);
|
| D | nxd_mqtt_client.c | 316 CHAR *topic_name, UINT topic_name_length, in _nxd_mqtt_client_sub_unsub() argument
354 length += (2 + topic_name_length); in _nxd_mqtt_client_sub_unsub()
401 …ret = _nxd_mqtt_client_append_message(client_ptr, packet_ptr, topic_name, topic_name_length, NX_WA… in _nxd_mqtt_client_sub_unsub()
4841 UINT _nxd_mqtt_client_publish(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length, in _nxd_mqtt_client_publish() argument
4883 length = topic_name_length + 2; in _nxd_mqtt_client_publish()
4911 …ret = _nxd_mqtt_client_append_message(client_ptr, packet_ptr, topic_name, topic_name_length, wait_… in _nxd_mqtt_client_publish()
5044 …t_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length, UINT QoS) in _nxd_mqtt_client_subscribe() argument
5053 topic_name, topic_name_length, NX_NULL, QoS)); in _nxd_mqtt_client_subscribe()
5106 …_nxd_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_length) in _nxd_mqtt_client_unsubscribe() argument
5109 topic_name, topic_name_length, NX_NULL, 0)); in _nxd_mqtt_client_unsubscribe()
[all …]
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | d2c_unit_test.c | 329 UINT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
343 topic_name_length = (buffer_ptr[5] << 8) | (buffer_ptr[6]); in __wrap__nxd_mqtt_client_publish_packet_send()
344 message_length = packet_ptr -> nx_packet_length - (9 + topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
345 assert_int_equal(topic_name_length, strlen(expected_topic)); in __wrap__nxd_mqtt_client_publish_packet_send()
346 assert_memory_equal(&buffer_ptr[7], expected_topic, topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
348 assert_memory_equal(&buffer_ptr[9 + topic_name_length], expected_message, message_length); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | direct_method_unit_test.c | 100 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
109 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_unsubscribe() argument
150 UINT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
164 topic_name_length = (buffer_ptr[5] << 8) | (buffer_ptr[6]); in __wrap__nxd_mqtt_client_publish_packet_send()
165 message_length = packet_ptr -> nx_packet_length - (9 + topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
166 assert_memory_equal(&buffer_ptr[7 + topic_name_length], g_expected_message, message_length); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | nx_azure_iot_pnp_client_command_unit_test.c | 114 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
157 UINT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
171 topic_name_length = (buffer_ptr[5] << 8) | (buffer_ptr[6]); in __wrap__nxd_mqtt_client_publish_packet_send()
172 message_length = packet_ptr -> nx_packet_length - (7 + topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
173 assert_memory_equal(&buffer_ptr[7 + topic_name_length], g_expected_message, message_length); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | iot_provisioning_client_unit_test.c | 239 UINT topic_name_length, UINT QoS) in __wrap__nxde_mqtt_client_subscribe() argument
263 INT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
277 topic_name_length = (buffer_ptr[5] << 8) | (buffer_ptr[6]); in __wrap__nxd_mqtt_client_publish_packet_send()
278 message_length = packet_ptr -> nx_packet_length - (9 + topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
296 assert_memory_equal(&buffer_ptr[9 + topic_name_length], in __wrap__nxd_mqtt_client_publish_packet_send()
302 assert_memory_equal(&buffer_ptr[9 + topic_name_length], expected_message, message_length); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | nx_azure_iot_adu_agent_unit_test.c | 356 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
401 UINT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
411 topic_name_length = (buffer_ptr[5] << 8) | (buffer_ptr[6]); in __wrap__nxd_mqtt_client_publish_packet_send()
412 message_length = packet_ptr -> nx_packet_length - (7 + topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
413 assert_memory_equal(&buffer_ptr[7 + topic_name_length], g_expected_message, message_length); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | nx_azure_iot_pnp_client_properties_unit_test.c | 167 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
212 UINT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
226 topic_name_length = (buffer_ptr[5] << 8) | (buffer_ptr[6]); in __wrap__nxd_mqtt_client_publish_packet_send()
227 message_length = packet_ptr -> nx_packet_length - (7 + topic_name_length); in __wrap__nxd_mqtt_client_publish_packet_send()
228 assert_memory_equal(&buffer_ptr[7 + topic_name_length], g_expected_message, message_length); in __wrap__nxd_mqtt_client_publish_packet_send()
|
| D | c2d_unit_test.c | 524 CHAR *topic_name, UINT topic_name_length, 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 | 278 UINT topic_name_length; in __wrap__nxd_mqtt_client_publish_packet_send() local
|
| 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
|
| D | nx_azure_iot_pnp_client_telemetry_unit_test.c | 204 UINT topic_name_length, UINT QoS) in __wrap__nxd_mqtt_client_sub_unsub() argument
|
