Home
last modified time | relevance | path

Searched refs:resource_mqtt (Results 1 – 16 of 16) sorted by relevance

/NetX-Duo-v6.2.1/test/regression/azure_iot/
Dd2c_unit_test.c103 iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_use_tls = NX_TRUE; in demo_entry()
106 iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_use_tls = NX_FALSE; in demo_entry()
157 iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_use_tls = NX_TRUE; in demo_entry()
158 …iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_packet_pool_ptr = iot.nx… in demo_entry()
162 iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_use_tls = NX_FALSE; in demo_entry()
163 …iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_packet_pool_ptr = iot.nx… in demo_entry()
242 …iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_socket.nx_tcp_socket_sta… in demo_entry()
270 …iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_socket.nx_tcp_socket_sta… in demo_entry()
Ddirect_method_unit_test.c263 …t_set_fixed_header(&(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt), packet_ptr, in construct_direct_method_response()
304 …hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt.message_receive_queue_head = pack… in generate_direct_method_response()
305 … hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt.message_receive_queue_depth = 1; in generate_direct_method_response()
307 test_receive_notify(&(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt), 1); in generate_direct_method_response()
Diot_provisioning_client_unit_test.c417 …d_header(&(prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt), packet_ptr, in construct_provisioning_service_response()
494 …prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt.message_receive_queue_h… in generate_response()
495 …prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt.message_receive_queue_d… in generate_response()
502 …test_receive_notify(&prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt, 1… in generate_response()
977 … test_connect_notify(&iot_prov_client.nx_azure_iot_provisioning_client_resource.resource_mqtt, in test_nx_azure_iot_provisioning_client_register_receive_failed()
1557 … test_connect_notify(&iot_prov_client.nx_azure_iot_provisioning_client_resource.resource_mqtt, in test_nx_azure_iot_provisioning_client_register_receive_blocking_failed()
1752 … test_disconnect_notify(&iot_prov_client.nx_azure_iot_provisioning_client_resource.resource_mqtt); in test_nx_azure_iot_provisioning_client_register_disconnect_failed()
Dc2d_property_unit_test.c165 …t_client_set_fixed_header(&(iot_client.nx_azure_iot_hub_client_resource.resource_mqtt), packet_ptr, in construct_c2d_packet()
Duser_agent_string_unit_test.c174 …iot_client.nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_client_socket.nx_tcp_socket_sta… in demo_entry()
Dc2d_unit_test.c53 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt)
Dnx_azure_iot_pnp_client_command_unit_test.c45 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt)
Dnx_azure_iot_pnp_client_telemetry_unit_test.c45 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt)
Ddevice_twin_unit_test.c43 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt)
Dnx_azure_iot_adu_agent_unit_test.c46 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt)
Dnx_azure_iot_pnp_client_properties_unit_test.c47 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt)
/NetX-Duo-v6.2.1/addons/azure_iot/
Dnx_azure_iot_hub_client.c204 status = _nxd_mqtt_client_cloud_create(&(resource_ptr -> resource_mqtt), in nx_azure_iot_hub_client_initialize()
217 status = nxd_mqtt_client_receive_notify_set(&(resource_ptr -> resource_mqtt), in nx_azure_iot_hub_client_initialize()
222 nxd_mqtt_client_delete(&(resource_ptr -> resource_mqtt)); in nx_azure_iot_hub_client_initialize()
254 …t_client_disconnect_notify_set(&(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt), in nx_azure_iot_hub_client_connection_status_callback_set()
367 …return(nxd_mqtt_client_websocket_set(&(resource_ptr -> resource_mqtt), (UCHAR *)resource_ptr -> re… in nx_azure_iot_hub_client_websocket_enable()
517 mqtt_client_ptr = &(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt); in nx_azure_iot_hub_client_connect()
524 status = nxd_mqtt_client_login_set(&(resource_ptr -> resource_mqtt), in nx_azure_iot_hub_client_connect()
754 … = nxd_mqtt_client_disconnect(&(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt)); in nx_azure_iot_hub_client_disconnect()
852 …atus = nxd_mqtt_client_delete(&(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt)); in nx_azure_iot_hub_client_deinitialize()
1077 … &(hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt), in nx_azure_iot_hub_client_telemetry_message_create()
[all …]
Dnx_azure_iot_provisioning_client.c151 mqtt_client_ptr = &(resource_ptr -> resource_mqtt); in nx_azure_iot_provisioning_client_connect_internal()
397 … context -> nx_azure_iot_provisioning_client_resource.resource_mqtt.nxd_mqtt_connect_notify = in nx_azure_iot_provisioning_client_process_connect()
399 …context -> nx_azure_iot_provisioning_client_resource.resource_mqtt.nxd_mqtt_connect_context = cont… in nx_azure_iot_provisioning_client_process_connect()
445 … = nxd_mqtt_client_subscribe(&(context -> nx_azure_iot_provisioning_client_resource.resource_mqtt), in nx_azure_iot_provisioning_client_subscribe()
637 … &prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt, in nx_azure_iot_provisioning_client_send_req()
649 …t_mqtt_packet_id_get(&(prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt), in nx_azure_iot_provisioning_client_send_req()
703 …_publish_mqtt_packet(&(prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt), in nx_azure_iot_provisioning_client_send_req()
849 mqtt_client_ptr = &(prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt); in nx_azure_iot_provisioning_client_initialize()
1011 …qtt_client_disconnect(&prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt); in nx_azure_iot_provisioning_client_deinitialize()
1014 …xd_mqtt_client_delete(&prov_client_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt); in nx_azure_iot_provisioning_client_deinitialize()
[all …]
Dnx_azure_iot.h173 NXD_MQTT_CLIENT resource_mqtt; member
Dnx_azure_iot.c180 if (&(resource_ptr -> resource_mqtt) == client_ptr) in nx_azure_iot_resource_search()
526 if (&(resource_ptr -> resource_mqtt.nxd_mqtt_tls_session) == session) in nx_azure_iot_certificate_verify()
Dnx_azure_iot_adu_agent.c240 …tls_session = &(iothub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt.nxd_mqtt_tls_s… in nx_azure_iot_adu_agent_start()