Home
last modified time | relevance | path

Searched refs:MQTT_CLIENT_GET (Results 1 – 6 of 6) sorted by relevance

/NetX-Duo-v6.2.1/test/regression/azure_iot/
Dc2d_unit_test.c53 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt) macro
199 assert_int_equal(_nxd_mqtt_client_set_fixed_header(&(MQTT_CLIENT_GET(&iot_client)), packet_ptr, in construct_c2d_packet()
303 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in property_payload_test()
304 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in property_payload_test()
306 test_receive_notify(&(MQTT_CLIENT_GET(&iot_client)), 1); in property_payload_test()
371 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in callback_test()
372 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in callback_test()
379 test_receive_notify(&(MQTT_CLIENT_GET(&iot_client)), 1); in callback_test()
438 MQTT_CLIENT_GET(&iot_client).message_receive_queue_head = packet_ptr; in invalid_packet_test()
439 MQTT_CLIENT_GET(&iot_client).message_receive_queue_depth = 1; in invalid_packet_test()
[all …]
Ddevice_twin_unit_test.c43 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt) macro
286 assert_int_equal(mqtt_client_set_fixed_header(&(MQTT_CLIENT_GET(hub_client_ptr)), packet_ptr, in construct_device_twin_response()
329 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_head = packet_ptr; in generate_device_twin_reported_properties_response()
330 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_reported_properties_response()
332 test_receive_notify(&(MQTT_CLIENT_GET(hub_client_ptr)), 1); 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()
346 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_reported_properties_throttled_response()
348 test_receive_notify(&(MQTT_CLIENT_GET(hub_client_ptr)), 1); 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()
364 MQTT_CLIENT_GET(hub_client_ptr).message_receive_queue_depth = 1; in generate_device_twin_document_response()
[all …]
Dnx_azure_iot_pnp_client_telemetry_unit_test.c45 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt) macro
233 …nx_tcp_socket_create(g_ip_ptr, &(MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket), "mqtt… in generate_test_telemetry_ack()
239 …MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket.nx_tcp_socket_reserved_ptr = (VOID *)iot… in generate_test_telemetry_ack()
241 …nx_tcp_client_socket_bind(&(MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket), NX_ANY_POR… in generate_test_telemetry_ack()
268 …MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket.nx_tcp_socket_receive_queue_head = packe… in generate_test_telemetry_ack()
269 …MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket.nx_tcp_socket_receive_queue_tail = packe… in generate_test_telemetry_ack()
270 MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket.nx_tcp_socket_receive_queue_count = 1; in generate_test_telemetry_ack()
271 MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_socket.nx_tcp_socket_state = 1; in generate_test_telemetry_ack()
272 …nx_cloud_module_event_set(&(MQTT_CLIENT_GET(iothub_client_ptr).nxd_mqtt_client_cloud_module), 0x00… in generate_test_telemetry_ack()
549 test_connect_notify(&(MQTT_CLIENT_GET(&hub_client)), in test_nx_azure_iot_hub_client_connect_async_success()
[all …]
Dnx_azure_iot_pnp_client_properties_unit_test.c47 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt) macro
328 assert_int_equal(mqtt_client_set_fixed_header(&(MQTT_CLIENT_GET(iothub_client_ptr)), packet_ptr, in construct_command_message()
370 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_send_response()
371 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_send_response()
373 test_receive_notify(&(MQTT_CLIENT_GET(iothub_client_ptr)), 1); 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()
388 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_send_throttled_response()
390 test_receive_notify(&(MQTT_CLIENT_GET(iothub_client_ptr)), 1); 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()
407 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_all_properties()
[all …]
Dnx_azure_iot_pnp_client_command_unit_test.c45 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt) macro
274 assert_int_equal(mqtt_client_set_fixed_header(&(MQTT_CLIENT_GET(iothub_client_ptr)), packet_ptr, in construct_command_message()
315 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_component_command_message()
316 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_component_command_message()
318 test_receive_notify(&(MQTT_CLIENT_GET(iothub_client_ptr)), 1); in generate_component_command_message()
331 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_command_message()
332 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_command_message()
334 test_receive_notify(&(MQTT_CLIENT_GET(iothub_client_ptr)), 1); in generate_command_message()
Dnx_azure_iot_adu_agent_unit_test.c46 #define MQTT_CLIENT_GET(c) ((c) -> nx_azure_iot_hub_client_resource.resource_mqtt) macro
562 assert_int_equal(mqtt_client_set_fixed_header(&(MQTT_CLIENT_GET(iothub_client_ptr)), packet_ptr, in construct_command_message()
626 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_head = packet_ptr; in generate_test_property_send_response()
627 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_send_response()
629 test_receive_notify(&(MQTT_CLIENT_GET(iothub_client_ptr)), 1); 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()
650 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_new_update_send()
652 test_receive_notify(&(MQTT_CLIENT_GET(iothub_client_ptr)), 1); 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()
673 MQTT_CLIENT_GET(iothub_client_ptr).message_receive_queue_depth = 1; in generate_test_property_cancel_update_send()
[all …]