Searched refs:message_receive_queue_head (Results 1 – 11 of 11) sorted by relevance
303 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in property_payload_test()371 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in callback_test()438 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in invalid_packet_test()476 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in wait_timeout_test()497 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in no_receiver_test()
329 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_head = packet_ptr; in generate_device_twin_reported_properties_response()345 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_head = packet_ptr; in generate_device_twin_reported_properties_throttled_response()363 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_head = packet_ptr; in generate_device_twin_document_response()379 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_head = packet_ptr; in generate_device_twin_document_throttled_response()397 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_head = packet_ptr; in generate_device_twin_desired_properties_response()
370 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_send_response()387 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_send_throttled_response()406 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_all_properties()424 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_all_properties_throttled()443 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_desired_properties()
315 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_component_command_message()331 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_command_message()
626 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_send_response()649 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_new_update_send()672 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_cancel_update_send()
304 …hub_client_ptr -> nx_azure_iot_hub_client_resource.resource_mqtt.message_receive_queue_head = pack… in generate_direct_method_response()
494 …ptr -> nx_azure_iot_provisioning_client_resource.resource_mqtt.message_receive_queue_head = packet… in generate_response()
1087 client_ptr -> message_receive_queue_head = packet_ptr -> nx_packet_queue_next; in _nxd_mqtt_release_receive_packet()1511 if (client_ptr -> message_receive_queue_head == NX_NULL) in _nxd_mqtt_process_publish()1513 client_ptr -> message_receive_queue_head = packet_ptr; in _nxd_mqtt_process_publish()2114 while (client_ptr -> message_receive_queue_head) in _nxd_mqtt_process_disconnect()2116 … _nxd_mqtt_release_receive_packet(client_ptr, client_ptr -> message_receive_queue_head, NX_NULL); in _nxd_mqtt_process_disconnect()3022 while (client_ptr -> message_receive_queue_head) in _nxd_mqtt_client_event_process()3024 … _nxd_mqtt_release_receive_packet(client_ptr, client_ptr -> message_receive_queue_head, NX_NULL); in _nxd_mqtt_client_event_process()5439 packet_ptr = client_ptr -> message_receive_queue_head; in _nxd_mqtt_client_message_get()5451 client_ptr -> message_receive_queue_head = packet_ptr -> nx_packet_queue_next; in _nxd_mqtt_client_message_get()
367 NX_PACKET *message_receive_queue_head; member
230 for (packet_ptr = client_ptr -> message_receive_queue_head; in nx_azure_iot_provisioning_client_mqtt_receive_callback()258 client_ptr -> message_receive_queue_head = NX_NULL; in nx_azure_iot_provisioning_client_mqtt_receive_callback()
2654 for (packet_ptr = client_ptr -> message_receive_queue_head; in nx_azure_iot_hub_client_mqtt_receive_callback()2718 client_ptr -> message_receive_queue_head = NX_NULL; in nx_azure_iot_hub_client_mqtt_receive_callback()
