| /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 UINT nxd_mqtt_client_subscribe(NXD_MQTT_CLIENT *mqtt_client_pr, CHAR *topic_name, UINT topic_name_l…
468 UINT nxd_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *mqtt_client_pr, CHAR *topic_name, UINT topic_name…
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 UINT _nxd_mqtt_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_leng…
508 UINT _nxd_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_le…
532 UINT _nxde_mqtt_client_publish(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_lengt…
537 UINT _nxde_mqtt_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_len…
538 UINT _nxde_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_l…
|
| D | nxd_mqtt_client.c | 316 CHAR *topic_name, UINT topic_name_length, in _nxd_mqtt_client_sub_unsub() argument
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
4911 …ret = _nxd_mqtt_client_append_message(client_ptr, packet_ptr, topic_name, topic_name_length, wait_… in _nxd_mqtt_client_publish()
5044 UINT _nxd_mqtt_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_leng… in _nxd_mqtt_client_subscribe() argument
5053 topic_name, topic_name_length, NX_NULL, QoS)); in _nxd_mqtt_client_subscribe()
5106 UINT _nxd_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_le… in _nxd_mqtt_client_unsubscribe() argument
5109 topic_name, topic_name_length, NX_NULL, 0)); in _nxd_mqtt_client_unsubscribe()
5822 UINT _nxde_mqtt_client_publish(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, UINT topic_name_lengt… in _nxde_mqtt_client_publish() argument
5832 if ((topic_name == NX_NULL) || (topic_name_length == 0)) in _nxde_mqtt_client_publish()
[all …]
|
| /NetX-Duo-v6.2.1/addons/azure_iot/ |
| D | nx_azure_iot_hub_client.c | 1576 UCHAR *topic_name; in nx_azure_iot_hub_client_cloud_message_property_get() local
1598 topic_name = packet_ptr -> nx_packet_data_start + topic_offset; in nx_azure_iot_hub_client_cloud_message_property_get()
1601 if ((ULONG)(packet_ptr -> nx_packet_append_ptr - topic_name) < (ULONG)topic_size) in nx_azure_iot_hub_client_cloud_message_property_get()
1607 receive_topic = az_span_create(topic_name, (INT)topic_size); in nx_azure_iot_hub_client_cloud_message_property_get()
2786 UCHAR *topic_name; in nx_azure_iot_hub_client_c2d_process() local
2796 topic_name = &(packet_ptr -> nx_packet_prepend_ptr[topic_offset]); in nx_azure_iot_hub_client_c2d_process()
2799 if ((ULONG)(packet_ptr -> nx_packet_append_ptr - topic_name) < topic_length) in nx_azure_iot_hub_client_c2d_process()
2805 receive_topic = az_span_create(topic_name, topic_length); in nx_azure_iot_hub_client_c2d_process()
2838 UCHAR *topic_name; in nx_azure_iot_hub_client_command_process() local
2848 topic_name = &(packet_ptr -> nx_packet_prepend_ptr[topic_offset]); in nx_azure_iot_hub_client_command_process()
[all …]
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | c2d_unit_test.c | 524 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
531 UINT __wrap__nxde_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxde_mqtt_client_unsubscribe() argument
|
| D | direct_method_unit_test.c | 100 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
108 UINT __wrap__nxde_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxde_mqtt_client_unsubscribe() argument
|
| D | device_twin_unit_test.c | 128 UINT __wrap__nxde_mqtt_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxde_mqtt_client_subscribe() argument
138 UINT __wrap__nxde_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxde_mqtt_client_unsubscribe() argument
|
| 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
|
| D | nx_azure_iot_pnp_client_telemetry_unit_test.c | 203 UINT __wrap__nxd_mqtt_client_sub_unsub(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxd_mqtt_client_sub_unsub() argument
|
| D | nx_azure_iot_adu_agent_unit_test.c | 356 CHAR *topic_name, UINT topic_name_length, in __wrap__nxde_mqtt_client_subscribe() argument
|
| D | iot_provisioning_client_unit_test.c | 238 UINT __wrap__nxde_mqtt_client_subscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxde_mqtt_client_subscribe() argument
|
| 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
|
