| /NetX-Duo-v6.4.1/test/regression/interoperability_test/mqtt_test/ |
| D | netx_mqtt_double_subscribers_test.c | 149 static UCHAR message_buffer[NXD_MQTT_MAX_MESSAGE_LENGTH]; variable
271 message_buffer, sizeof(message_buffer), &message_length); in client_thread_entry()
279 add_error_counter_if_fail( 'h' == message_buffer[0], test_result); in client_thread_entry()
280 add_error_counter_if_fail( 'e' == message_buffer[1], test_result); in client_thread_entry()
281 add_error_counter_if_fail( 'l' == message_buffer[2], test_result); in client_thread_entry()
282 add_error_counter_if_fail( 'l' == message_buffer[3], test_result); in client_thread_entry()
283 add_error_counter_if_fail( 'o' == message_buffer[4], test_result); in client_thread_entry()
288 message_buffer, sizeof(message_buffer), &message_length); in client_thread_entry()
296 add_error_counter_if_fail( 'h' == message_buffer[0], test_result); in client_thread_entry()
297 add_error_counter_if_fail( 'e' == message_buffer[1], test_result); in client_thread_entry()
[all …]
|
| D | netx_mqtt_subscriber_test.c | 128 static UCHAR message_buffer[NXD_MQTT_MAX_MESSAGE_LENGTH]; variable
168 message_buffer, sizeof(message_buffer), &message_length); in client_thread_entry()
175 add_error_counter_if_fail( 'h' == message_buffer[0], test_result); in client_thread_entry()
176 add_error_counter_if_fail( 'e' == message_buffer[1], test_result); in client_thread_entry()
177 add_error_counter_if_fail( 'l' == message_buffer[2], test_result); in client_thread_entry()
178 add_error_counter_if_fail( 'l' == message_buffer[3], test_result); in client_thread_entry()
179 add_error_counter_if_fail( 'o' == message_buffer[4], test_result); in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_test.c | 144 static UCHAR message_buffer[NXD_MQTT_MAX_MESSAGE_LENGTH]; variable
235 message_buffer, sizeof(message_buffer), &message_length); in client_thread_entry()
242 add_error_counter_if_fail( 'h' == message_buffer[0], test_result); in client_thread_entry()
243 add_error_counter_if_fail( 'e' == message_buffer[1], test_result); in client_thread_entry()
244 add_error_counter_if_fail( 'l' == message_buffer[2], test_result); in client_thread_entry()
245 add_error_counter_if_fail( 'l' == message_buffer[3], test_result); in client_thread_entry()
246 add_error_counter_if_fail( 'o' == message_buffer[4], test_result); in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_twice_test.c | 144 static UCHAR message_buffer[NXD_MQTT_MAX_MESSAGE_LENGTH]; variable
247 … message_buffer, sizeof(message_buffer), &message_length); in client_thread_entry()
254 add_error_counter_if_fail( 'h' == message_buffer[0], test_result); in client_thread_entry()
255 add_error_counter_if_fail( 'e' == message_buffer[1], test_result); in client_thread_entry()
256 add_error_counter_if_fail( 'l' == message_buffer[2], test_result); in client_thread_entry()
257 add_error_counter_if_fail( 'l' == message_buffer[3], test_result); in client_thread_entry()
258 add_error_counter_if_fail( 'o' == message_buffer[4], test_result); in client_thread_entry()
|
| D | netx_mqtt_subscriber_empty_message_test.c | 128 static UCHAR message_buffer[NXD_MQTT_MAX_MESSAGE_LENGTH]; variable
168 message_buffer, sizeof(message_buffer), &message_length); in client_thread_entry()
|
| /NetX-Duo-v6.4.1/samples/ |
| D | demo_mqtt_client.c | 73 static UCHAR message_buffer[NXD_MQTT_MAX_MESSAGE_LENGTH]; variable
164 … message_buffer, sizeof(message_buffer), &message_length); in thread_mqtt_entry()
168 message_buffer[message_length] = 0; in thread_mqtt_entry()
169 printf("topic = %s, message = %s\n", topic_buffer, message_buffer); in thread_mqtt_entry()
|
| /NetX-Duo-v6.4.1/test/regression/azure_iot/ |
| D | api_unit_test.c | 64 UCHAR message_buffer[1024]; variable
241 … message_buffer, message_length, in api_no_model_id_test()
465 … message_buffer, message_length, in api_model_id_test()
|
| /NetX-Duo-v6.4.1/addons/mqtt/ |
| D | nxd_mqtt_client.h | 472 … UCHAR *message_buffer, UINT message_buffer_size, UINT *actual_message_length);
496 … UCHAR *message_buffer, UINT message_buffer_size, UINT *actual_message_length);
531 … UCHAR *message_buffer, UINT message_buffer_size, UINT *actual_message_length);
|
| D | nxd_mqtt_client.c | 5426 … UCHAR *message_buffer, UINT message_buffer_size, UINT *actual_message_length) in _nxd_mqtt_client_message_get() argument
5466 nx_packet_data_extract_offset(packet_ptr, message_offset, message_buffer, in _nxd_mqtt_client_message_get()
6096 … UCHAR *message_buffer, UINT message_buffer_size, UINT *actual_message_length) in _nxde_mqtt_client_message_get() argument
6108 if ((message_buffer == NX_NULL) || (topic_buffer == NX_NULL)) in _nxde_mqtt_client_message_get()
6115 … message_buffer, message_buffer_size, actual_message_length)); in _nxde_mqtt_client_message_get()
|
| /NetX-Duo-v6.4.1/addons/azure_iot/ |
| D | nx_azure_iot_hub_client.h | 816 … const UCHAR *message_buffer, UINT message_length,
|
| D | nx_azure_iot_hub_client.c | 1937 … const UCHAR *message_buffer, UINT message_length, UINT message_type, in nx_azure_iot_hub_client_properties_request_response() argument
1943 if ((message_buffer != NX_NULL) && (message_length != 0)) in nx_azure_iot_hub_client_properties_request_response()
1947 status = nx_packet_data_append(packet_ptr, (VOID *)message_buffer, message_length, in nx_azure_iot_hub_client_properties_request_response()
2410 … const UCHAR *message_buffer, UINT message_length, in nx_azure_iot_hub_client_device_twin_reported_properties_send() argument
2502 … request_id, packet_ptr, topic_length, message_buffer, message_length, in nx_azure_iot_hub_client_device_twin_reported_properties_send()
|
| /NetX-Duo-v6.4.1/test/regression/nx_secure_test/ |
| D | nx_secure_pkcs1_v1_5_test.c | 109 static UCHAR message_buffer[512*2]; variable
|
| /NetX-Duo-v6.4.1/addons/azure_iot/docs/ |
| D | azure_rtos_iot_hub_client.md | 1424 … const UCHAR *message_buffer, UINT message_length,
1437 | message_buffer [in] | JSON document containing the reported properties. |
|
