Home
last modified time | relevance | path

Searched refs:message_receive_queue_depth (Results 1 – 11 of 11) sorted by relevance

/NetX-Duo-v6.2.1/test/regression/azure_iot/
Dc2d_unit_test.c304 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in property_payload_test()
372 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in callback_test()
439 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in invalid_packet_test()
477 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in wait_timeout_test()
498 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in no_receiver_test()
Ddevice_twin_unit_test.c330 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_reported_properties_response()
346 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_reported_properties_throttled_response()
364 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_document_response()
380 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_document_throttled_response()
398 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_desired_properties_response()
Dnx_azure_iot_pnp_client_properties_unit_test.c371 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_send_response()
388 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_send_throttled_response()
407 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_all_properties()
425 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_all_properties_throttled()
444 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_desired_properties()
Dnx_azure_iot_pnp_client_command_unit_test.c316 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_component_command_message()
332 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_command_message()
Dnx_azure_iot_adu_agent_unit_test.c627 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_send_response()
650 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_new_update_send()
673 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_cancel_update_send()
Ddirect_method_unit_test.c305 … hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt.message_receive_queue_depth = 1; in generate_direct_method_response()
Diot_provisioning_client_unit_test.c495 …ent_ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt.message_receive_queue_depth = 1; in generate_response()
/NetX-Duo-v6.2.1/addons/mqtt/
Dnxd_mqtt_client.c1095 client_ptr -> message_receive_queue_depth--; in _nxd_mqtt_release_receive_packet()
1509 client_ptr -> message_receive_queue_depth++; in _nxd_mqtt_process_publish()
1524 …ent_ptr -> nxd_mqtt_client_receive_notify))(client_ptr, client_ptr -> message_receive_queue_depth); in _nxd_mqtt_process_publish()
2118 client_ptr -> message_receive_queue_depth = 0; in _nxd_mqtt_process_disconnect()
3026 client_ptr -> message_receive_queue_depth = 0; in _nxd_mqtt_client_event_process()
5437 while (client_ptr -> message_receive_queue_depth) in _nxd_mqtt_client_message_get()
5456 client_ptr -> message_receive_queue_depth--; in _nxd_mqtt_client_message_get()
Dnxd_mqtt_client.h369 UINT message_receive_queue_depth; member
/NetX-Duo-v6.2.1/addons/azure_iot/
Dnx_azure_iot_provisioning_client.c260 client_ptr -> message_receive_queue_depth = 0; in nx_azure_iot_provisioning_client_mqtt_receive_callback()
Dnx_azure_iot_hub_client.c2720 client_ptr -> message_receive_queue_depth = 0; in nx_azure_iot_hub_client_mqtt_receive_callback()