| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | nx_azure_iot_unit_test.c | 110 static NXD_MQTT_CLIENT mqtt_client; variable
149 mqtt_client.nxd_mqtt_client_ip_ptr = &ip_0; in test_nx_azure_iot_publish_packet_get()
150 mqtt_client.nxd_mqtt_client_packet_pool_ptr = &pool_0; in test_nx_azure_iot_publish_packet_get()
151 mqtt_client.nxd_mqtt_client_use_websocket = NX_FALSE; in test_nx_azure_iot_publish_packet_get()
152 mqtt_client.nxd_mqtt_client_use_tls = NX_FALSE; in test_nx_azure_iot_publish_packet_get()
153 mqtt_client.nxd_mqtt_tls_session.nx_secure_tls_id = NX_SECURE_TLS_ID; in test_nx_azure_iot_publish_packet_get()
154 … 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()
155 mqtt_client.nxd_mqtt_tls_session.nx_secure_tls_local_session_active = NX_TRUE; in test_nx_azure_iot_publish_packet_get()
156 mqtt_client.nxd_mqtt_tls_session.nx_secure_tls_session_ciphersuite = &test_ciphersuite; in test_nx_azure_iot_publish_packet_get()
157 mqtt_client.nxd_mqtt_tls_session.nx_secure_tls_crypto_table = &test_crypto_table; in test_nx_azure_iot_publish_packet_get()
[all …]
|
| /NetX-Duo-v6.2.1/samples/ |
| D | demo_mqtt_client.c | 49 static NXD_MQTT_CLIENT mqtt_client; variable
104 …status = nxd_mqtt_client_create(&mqtt_client, "my_client", CLIENT_ID_STRING, STRLEN(CLIENT_ID_STRI… in thread_mqtt_entry()
115 …status = nxd_mqtt_client_websocket_set(&mqtt_client, (UCHAR *)"test.mosquitto.org", sizeof("test.m… in thread_mqtt_entry()
125 nxd_mqtt_client_disconnect_notify_set(&mqtt_client, my_disconnect_func); in thread_mqtt_entry()
138 status = nxd_mqtt_client_connect(&mqtt_client, &server_ip, NXD_MQTT_PORT, in thread_mqtt_entry()
144 status = nxd_mqtt_client_subscribe(&mqtt_client, TOPIC_NAME, STRLEN(TOPIC_NAME), QOS0); in thread_mqtt_entry()
149 status = nxd_mqtt_client_receive_notify_set(&mqtt_client, my_notify_func); in thread_mqtt_entry()
154 status = nxd_mqtt_client_publish(&mqtt_client, TOPIC_NAME, STRLEN(TOPIC_NAME), in thread_mqtt_entry()
163 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in thread_mqtt_entry()
174 nxd_mqtt_client_unsubscribe(&mqtt_client, TOPIC_NAME, STRLEN(TOPIC_NAME)); in thread_mqtt_entry()
[all …]
|
| /NetX-Duo-v6.2.1/test/regression/interoperability_test/mqtt_test/ |
| D | netx_mqtt_subscriber_empty_message_test.c | 105 static NXD_MQTT_CLIENT mqtt_client; variable
141 …status = nxd_mqtt_client_create(&mqtt_client, "my_client", CLIENT_ID_STRING, strlen(CLIENT_ID_STRI… in client_thread_entry()
154 status = nxd_mqtt_client_connect(&mqtt_client, &server_ip, MQTT_PORT, in client_thread_entry()
159 status = nxd_mqtt_client_subscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME), QOS0); in client_thread_entry()
167 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
178 status = nxd_mqtt_client_unsubscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME)); in client_thread_entry()
182 status = nxd_mqtt_client_disconnect(&mqtt_client); in client_thread_entry()
186 status = nxd_mqtt_client_delete(&mqtt_client); in client_thread_entry()
|
| D | netx_mqtt_subscriber_test.c | 105 static NXD_MQTT_CLIENT mqtt_client; variable
141 …status = nxd_mqtt_client_create(&mqtt_client, "my_client", CLIENT_ID_STRING, strlen(CLIENT_ID_STRI… in client_thread_entry()
154 status = nxd_mqtt_client_connect(&mqtt_client, &server_ip, MQTT_PORT, in client_thread_entry()
159 status = nxd_mqtt_client_subscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME), QOS0); in client_thread_entry()
167 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
183 status = nxd_mqtt_client_unsubscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME)); in client_thread_entry()
187 status = nxd_mqtt_client_disconnect(&mqtt_client); in client_thread_entry()
191 status = nxd_mqtt_client_delete(&mqtt_client); in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_twice_test.c | 115 static NXD_MQTT_CLIENT mqtt_client; variable
191 …status = nxd_mqtt_client_create(&mqtt_client, "my_client", CLIENT_ID_STRING, strlen(CLIENT_ID_STRI… in client_thread_entry()
215 status = nxd_mqtt_client_secure_connect(&mqtt_client, &server_ip, 443, in client_thread_entry()
229 status = nxd_mqtt_client_secure_connect(&mqtt_client, &server_ip, MQTT_PORT, in client_thread_entry()
236 status = nxd_mqtt_client_subscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME), QOS0); in client_thread_entry()
246 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
262 status = nxd_mqtt_client_unsubscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME)); in client_thread_entry()
266 status = nxd_mqtt_client_disconnect(&mqtt_client); in client_thread_entry()
273 status = nxd_mqtt_client_delete(&mqtt_client); in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_test.c | 115 static NXD_MQTT_CLIENT mqtt_client; variable
195 …status = nxd_mqtt_client_create(&mqtt_client, "my_client", CLIENT_ID_STRING, strlen(CLIENT_ID_STRI… in client_thread_entry()
212 status = nxd_mqtt_client_secure_connect(&mqtt_client, &server_ip, MQTT_PORT, in client_thread_entry()
218 status = nxd_mqtt_client_secure_connect(&mqtt_client, &server_ip, MQTT_PORT, in client_thread_entry()
224 status = nxd_mqtt_client_subscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME), QOS0); in client_thread_entry()
234 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
250 status = nxd_mqtt_client_unsubscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME)); in client_thread_entry()
254 status = nxd_mqtt_client_disconnect(&mqtt_client); in client_thread_entry()
258 status = nxd_mqtt_client_delete(&mqtt_client); in client_thread_entry()
|
| D | netx_mqtt_double_subscribers_test.c | 115 static NXD_MQTT_CLIENT mqtt_client; variable
200 …status = nxd_mqtt_client_create(&mqtt_client, "my_client", CLIENT_ID_STRING, strlen(CLIENT_ID_STRI… in client_thread_entry()
214 status = nx_secure_tls_session_create(&(mqtt_client.nxd_mqtt_tls_session), in client_thread_entry()
218 …status += nx_secure_tls_session_packet_buffer_set(&(mqtt_client.nxd_mqtt_tls_session), tls_packet_… in client_thread_entry()
240 status = nxd_mqtt_client_secure_connect(&mqtt_client, &server_ip, MQTT_PORT, in client_thread_entry()
246 status = nxd_mqtt_client_subscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME), QOS0); in client_thread_entry()
270 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
304 status = nxd_mqtt_client_unsubscribe(&mqtt_client, TOPIC_NAME, strlen(TOPIC_NAME)); in client_thread_entry()
310 status = nxd_mqtt_client_disconnect(&mqtt_client); in client_thread_entry()
316 status = nxd_mqtt_client_delete(&mqtt_client); in client_thread_entry()
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.c | 2952 static VOID _nxd_mqtt_client_event_process(VOID *mqtt_client, ULONG common_events, ULONG module_own… in _nxd_mqtt_client_event_process() argument
2954 NXD_MQTT_CLIENT *client_ptr = (NXD_MQTT_CLIENT *)mqtt_client; in _nxd_mqtt_client_event_process()
3096 static VOID _nxd_mqtt_thread_entry(ULONG mqtt_client) in _nxd_mqtt_thread_entry() argument
3101 client_ptr = (NXD_MQTT_CLIENT *)mqtt_client; in _nxd_mqtt_thread_entry()
|
