Home
last modified time | relevance | path

Searched refs:nxd_mqtt_client_socket (Results 1 – 14 of 14) sorted by relevance

/NetX-Duo-v6.2.1/test/regression/azure_iot/
Dnx_azure_iot_unit_test.c154 … mqtt_client.nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &(mqtt_client.nxd_mqtt_client_socket); in test_nx_azure_iot_publish_packet_get()
162 …_socket_create(mqtt_client.nxd_mqtt_client_ip_ptr, &(mqtt_client.nxd_mqtt_client_socket), "test_cl… in test_nx_azure_iot_publish_packet_get()
167 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in test_nx_azure_iot_publish_packet_get()
176 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V6; in test_nx_azure_iot_publish_packet_get()
187 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in test_nx_azure_iot_publish_packet_get()
197 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V6; in test_nx_azure_iot_publish_packet_get()
211 …t.nxd_mqtt_client_websocket.nx_websocket_client_socket_ptr = &(mqtt_client.nxd_mqtt_client_socket); in test_nx_azure_iot_publish_packet_get()
214 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in test_nx_azure_iot_publish_packet_get()
224 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V6; in test_nx_azure_iot_publish_packet_get()
238 mqtt_client.nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in test_nx_azure_iot_publish_packet_get()
[all …]
Dnx_azure_iot_pnp_client_telemetry_unit_test.c172 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
173 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
174 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
185 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
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()
[all …]
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()
252 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
253 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
254 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
262 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Dd2c_unit_test.c242 …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()
312 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
313 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
314 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
Dc2d_unit_test.c550 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
551 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
552 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
561 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Ddirect_method_unit_test.c187 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
188 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
189 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
198 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Dnx_azure_iot_pnp_client_command_unit_test.c202 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
203 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
204 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
213 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Ddevice_twin_unit_test.c210 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
211 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
212 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
221 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Dnx_azure_iot_adu_agent_unit_test.c447 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
448 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
449 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
458 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Diot_provisioning_client_unit_test.c212 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
213 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
214 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
256 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
Dnx_azure_iot_pnp_client_properties_unit_test.c257 …lient_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socket; in __wrap__nxde_mqtt_client_secure_connect()
258 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
259 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
268 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_CLOSED; in __wrap__nxde_mqtt_client_disconnect()
/NetX-Duo-v6.2.1/addons/mqtt/
Dnxd_mqtt_client.c574 …if (client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version == NX_IP_VERSION_… in _nxd_mqtt_client_packet_allocate()
657 status = nx_tcp_socket_send(&client_ptr -> nxd_mqtt_client_socket, packet_ptr, wait_option); in _nxd_mqtt_packet_send()
731 … status = nx_tcp_socket_receive(&(client_ptr -> nxd_mqtt_client_socket), packet_ptr, wait_option); in _nxd_mqtt_packet_receive()
785 if (&(client_ptr -> nxd_mqtt_client_socket) == socket_ptr) in _nxd_mqtt_tcp_establish_notify()
848 if (&(client_ptr -> nxd_mqtt_client_socket) == socket_ptr) in _nxd_mqtt_receive_callback()
2478 …ion_start(&(client_ptr -> nxd_mqtt_tls_session), &(client_ptr -> nxd_mqtt_client_socket), NX_NO_WA… in _nxd_mqtt_tcp_establish_process()
2507 …client_connect(&(client_ptr -> nxd_mqtt_client_websocket), &(client_ptr -> nxd_mqtt_client_socket), in _nxd_mqtt_tcp_establish_process()
2803 nx_tcp_socket_disconnect(&(client_ptr -> nxd_mqtt_client_socket), wait_option); in _nxd_mqtt_client_connection_end()
2804 nx_tcp_client_socket_unbind(&(client_ptr -> nxd_mqtt_client_socket)); in _nxd_mqtt_client_connection_end()
3043 nx_tcp_socket_delete(&client_ptr -> nxd_mqtt_client_socket); in _nxd_mqtt_client_event_process()
[all …]
Dnxd_mqtt_client.h358 NX_TCP_SOCKET nxd_mqtt_client_socket; member
/NetX-Duo-v6.2.1/test/regression/mqtt_test/
Dnetx_mqtt_branch_test.c360 UINT old_tcp_socket_state = client_ptr -> nxd_mqtt_client_socket . nx_tcp_socket_state; in ntest_0_entry()
361 client_ptr -> nxd_mqtt_client_socket . nx_tcp_socket_state = NX_TCP_SYN_SENT; in ntest_0_entry()
374 client_ptr -> nxd_mqtt_client_socket . nx_tcp_socket_state = old_tcp_socket_state; in ntest_0_entry()