| /NetX-Duo-v6.2.1/addons/azure_iot/ |
| D | nx_azure_iot_hub_client.c | 63 USHORT topic_length);
67 USHORT topic_length);
70 USHORT topic_length, UINT *request_id_ptr,
1064 UINT topic_length; in nx_azure_iot_hub_client_telemetry_message_create() local
1085 topic_length = (UINT)(packet_ptr -> nx_packet_data_end - packet_ptr -> nx_packet_prepend_ptr); in nx_azure_iot_hub_client_telemetry_message_create()
1088 … topic_length, (size_t *)&topic_length); in nx_azure_iot_hub_client_telemetry_message_create()
1096 packet_ptr -> nx_packet_append_ptr = packet_ptr -> nx_packet_prepend_ptr + topic_length; in nx_azure_iot_hub_client_telemetry_message_create()
1097 packet_ptr -> nx_packet_length = topic_length; in nx_azure_iot_hub_client_telemetry_message_create()
1384 UINT topic_length; in nx_azure_iot_hub_client_process_publish_packet() local
1408 topic_length = (UINT)(*(byte) << 8) | (*(byte + 1)); in nx_azure_iot_hub_client_process_publish_packet()
[all …]
|
| D | nx_azure_iot_hub_client.h | 112 NX_PACKET *packet_ptr, ULONG topic_offset, USHORT topic_length);
|
| D | nx_azure_iot_provisioning_client.c | 64 USHORT topic_length; in nx_azure_iot_provisioning_client_process_message() local
72 status = _nxd_mqtt_process_publish_packet(packet_ptr, &topic_offset, &topic_length, in nx_azure_iot_provisioning_client_process_message()
86 …ived_topic = az_span_create(packet_ptr -> nx_packet_prepend_ptr + topic_offset, (INT)topic_length); in nx_azure_iot_provisioning_client_process_message()
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | c2d_property_unit_test.c | 144 ULONG topic_length = sizeof(C2D_TOPIC) - 1; in construct_c2d_packet() local
154 … topic_length += properties[i].name_length + properties[i].value_length + 2; /* '=' and '&' */ in construct_c2d_packet()
159 topic_length--; /* Reduce by one since last '&' is not needed. */ in construct_c2d_packet()
161 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_c2d_packet()
171 bytes[0] = (topic_length >> 8) & 0xFF; in construct_c2d_packet()
172 bytes[1] = topic_length & 0xFF; in construct_c2d_packet()
|
| D | c2d_unit_test.c | 178 ULONG topic_length = sizeof(C2D_TOPIC) - 1; in construct_c2d_packet() local
188 … topic_length += properties[i].name_length + properties[i].value_length + 2; /* '=' and '&' */ in construct_c2d_packet()
193 topic_length--; /* Reduce by one since last '&' is not needed. */ in construct_c2d_packet()
195 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_c2d_packet()
205 bytes[0] = (topic_length >> 8) & 0xFF; in construct_c2d_packet()
206 bytes[1] = topic_length & 0xFF; in construct_c2d_packet()
335 NX_PACKET *packet_ptr, ULONG topic_offset, USHORT topic_length);
|
| D | direct_method_unit_test.c | 253 ULONG topic_length = topic_len; in construct_direct_method_response() local
259 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_direct_method_response()
269 bytes[0] = (topic_length >> 8) & 0xFF; in construct_direct_method_response()
270 bytes[1] = topic_length & 0xFF; in construct_direct_method_response()
|
| D | iot_provisioning_client_unit_test.c | 397 ULONG topic_length = topic_len; in construct_provisioning_service_response() local
406 … topic_length += properties[i].name_length + properties[i].value_length + 2; /* '=' and '&' */ in construct_provisioning_service_response()
411 topic_length--; /* Reduce by one since last '&' is not needed. */ in construct_provisioning_service_response()
413 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_provisioning_service_response()
423 bytes[0] = (topic_length >> 8) & 0xFF; in construct_provisioning_service_response()
424 bytes[1] = topic_length & 0xFF; in construct_provisioning_service_response()
470 const UCHAR *topic, ULONG topic_length, in generate_response() argument
489 &packet_ptr, topic, topic_length, in generate_response()
|
| D | nx_azure_iot_pnp_client_command_unit_test.c | 264 ULONG topic_length = topic_len; in construct_command_message() local
270 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_command_message()
280 bytes[0] = (topic_length >> 8) & 0xFF; in construct_command_message()
281 bytes[1] = topic_length & 0xFF; in construct_command_message()
|
| D | device_twin_unit_test.c | 276 ULONG topic_length = topic_len; in construct_device_twin_response() local
282 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_device_twin_response()
292 bytes[0] = (topic_length >> 8) & 0xFF; in construct_device_twin_response()
293 bytes[1] = topic_length & 0xFF; in construct_device_twin_response()
|
| D | nx_azure_iot_adu_agent_unit_test.c | 552 ULONG topic_length = topic_len; in construct_command_message() local
558 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_command_message()
568 bytes[0] = (topic_length >> 8) & 0xFF; in construct_command_message()
569 bytes[1] = topic_length & 0xFF; in construct_command_message()
|
| D | nx_azure_iot_pnp_client_properties_unit_test.c | 318 ULONG topic_length = topic_len; in construct_command_message() local
324 …total_length = topic_length + 2 + 2 + message_payload_length; /* Two bytes for fixed topic_length … in construct_command_message()
334 bytes[0] = (topic_length >> 8) & 0xFF; in construct_command_message()
335 bytes[1] = topic_length & 0xFF; in construct_command_message()
|
| /NetX-Duo-v6.2.1/samples/ |
| D | demo_mqtt_client.c | 101 UINT topic_length, message_length; in thread_mqtt_entry() local
163 …tus = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_length, in thread_mqtt_entry()
167 topic_buffer[topic_length] = 0; in thread_mqtt_entry()
|
| /NetX-Duo-v6.2.1/test/regression/mqtt_test/ |
| D | netx_mqtt_multiple_receive_test.c | 248 UINT topic_length, message_length; in ntest_0_entry() local
310 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
315 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
322 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
326 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
335 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
340 …if ((topic_length != strlen(TOPIC)) || strncmp(TOPIC, topic, topic_length) || (message_length != s… in ntest_0_entry()
|
| D | netx_mqtt_receive_span_test.c | 244 UINT topic_length, message_length; in ntest_0_entry() local
307 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
312 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
319 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
324 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
|
| D | netx_mqtt_receive_qos2_test.c | 156 UINT topic_length, message_length; in ntest_0_entry() local
195 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
200 …if ((topic_length != strlen(TOPIC)) || strncmp(TOPIC, topic, topic_length) || (message_length != s… in ntest_0_entry()
|
| D | netx_mqtt_receive_qos0_test.c | 248 UINT topic_length, message_length; in ntest_0_entry() local
311 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
316 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
|
| D | netx_mqtt_receive_qos1_test.c | 244 UINT topic_length, message_length; in ntest_0_entry() local
306 …status = nxd_mqtt_client_message_get(client_ptr, topic, sizeof(topic), &topic_length, message, siz… in ntest_0_entry()
311 …if (topic_length != strlen(TOPIC) || strncmp(TOPIC, topic, topic_length) || (message_length != str… in ntest_0_entry()
|
| /NetX-Duo-v6.2.1/test/regression/interoperability_test/mqtt_test/ |
| D | netx_mqtt_subscriber_empty_message_test.c | 133 UINT status, topic_length, message_length = 0xFFFFFFFF; in client_thread_entry() local
167 …tus = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_length, in client_thread_entry()
|
| D | netx_mqtt_subscriber_test.c | 133 UINT status, topic_length, message_length; in client_thread_entry() local
167 …tus = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_length, in client_thread_entry()
|
| D | netx_mqtt_double_subscribers_test.c | 192 UINT status, topic_length, message_length; in client_thread_entry() local
270 …tus = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_length, in client_thread_entry()
287 …s = nxd_mqtt_client_message_get(&mqtt_client_0, topic_buffer, sizeof(topic_buffer), &topic_length, in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_twice_test.c | 182 UINT status, topic_length, message_length; in client_thread_entry() local
246 …tus = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_length, in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_test.c | 187 UINT status, topic_length, message_length; in client_thread_entry() local
234 …tus = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_length, in client_thread_entry()
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.c | 1291 UINT topic_length; in _nxd_mqtt_process_publish_packet() local
1316 topic_length = (UINT)(*(bytes) << 8) | (*(bytes + 1)); in _nxd_mqtt_process_publish_packet()
1318 if (topic_length > remaining_length - 2u) in _nxd_mqtt_process_publish_packet()
1324 *topic_length_ptr = (USHORT)topic_length; in _nxd_mqtt_process_publish_packet()
1326 remaining_length = remaining_length - topic_length - 2; in _nxd_mqtt_process_publish_packet()
1329 offset += 2 + 2 + topic_length; in _nxd_mqtt_process_publish_packet()
1339 offset += 2 + topic_length; in _nxd_mqtt_process_publish_packet()
1416 UINT topic_length; in _nxd_mqtt_process_publish() local
1440 topic_length = (UINT)(*(bytes) << 8) | (*(bytes + 1)); in _nxd_mqtt_process_publish()
1442 if (topic_length > remaining_length - 2u) in _nxd_mqtt_process_publish()
[all …]
|
