| /NetX-Duo-v6.2.1/test/regression/mqtt_test/ |
| D | netx_mqtt_publish_non_zero_packet_id_test.c | 334 USHORT packet_id; in ntest_1_entry() local
468 … packet_id = packet_ptr->nx_packet_prepend_ptr[byte - content];/* Fill in packet ID MSB. */ in ntest_1_entry()
469 …packet_id = (packet_id << 8) | packet_ptr->nx_packet_prepend_ptr[byte - content + 1];/* Fill in pa… in ntest_1_entry()
470 *byte++ = ((packet_id >> 8) & 0xFF); in ntest_1_entry()
471 *byte++ = (packet_id & 0xFF); in ntest_1_entry()
473 if (packet_id == 0) in ntest_1_entry()
517 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
518 byte[3] = packet_id & 0xFF; in ntest_1_entry()
527 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
528 byte[3] = packet_id & 0xFF; in ntest_1_entry()
[all …]
|
| D | netx_mqtt_publish_qos2_test.c | 197 USHORT packet_id; in ntest_1_entry() local
264 packet_id = packet_ptr -> nx_packet_prepend_ptr[byte - content];/* Fill in packet ID MSB. */ in ntest_1_entry()
265 …packet_id = (packet_id << 8) | packet_ptr -> nx_packet_prepend_ptr[byte - content + 1];/* Fill in … in ntest_1_entry()
266 *byte++ += ((packet_id >> 8) & 0xFF ); in ntest_1_entry()
267 *byte++ += (packet_id & 0xFF); in ntest_1_entry()
297 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
298 byte[3] = packet_id & 0xFF; in ntest_1_entry()
307 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
308 byte[3] = packet_id & 0xFF; in ntest_1_entry()
325 …yte[0] != 0x60) || (byte[1] != 2) || (byte[2] != ((packet_id >> 8) & 0xFF)) || (byte[3] != (packet… in ntest_1_entry()
|
| D | netx_mqtt_publish_qos0_test.c | 320 USHORT packet_id; in ntest_1_entry() local
453 … packet_id = packet_ptr->nx_packet_prepend_ptr[byte - content];/* Fill in packet ID MSB. */ in ntest_1_entry()
454 …packet_id = (packet_id << 8) | packet_ptr->nx_packet_prepend_ptr[byte - content + 1];/* Fill in pa… in ntest_1_entry()
455 *byte++ = ((packet_id >> 8) & 0xFF); in ntest_1_entry()
456 *byte++ = (packet_id & 0xFF); in ntest_1_entry()
496 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
497 byte[3] = packet_id & 0xFF; in ntest_1_entry()
506 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
507 byte[3] = packet_id & 0xFF; in ntest_1_entry()
|
| D | netx_mqtt_publish_qos1_test.c | 318 USHORT packet_id; in ntest_1_entry() local
451 … packet_id = packet_ptr->nx_packet_prepend_ptr[byte - content];/* Fill in packet ID MSB. */ in ntest_1_entry()
452 …packet_id = (packet_id << 8) | packet_ptr->nx_packet_prepend_ptr[byte - content + 1];/* Fill in pa… in ntest_1_entry()
453 *byte++ = ((packet_id >> 8) & 0xFF); in ntest_1_entry()
454 *byte++ = (packet_id & 0xFF); in ntest_1_entry()
494 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
495 byte[3] = packet_id & 0xFF; in ntest_1_entry()
504 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
505 byte[3] = packet_id & 0xFF; in ntest_1_entry()
|
| D | netx_mqtt_keepalive_test.c | 325 USHORT packet_id; in ntest_1_entry() local
463 … packet_id = packet_ptr->nx_packet_prepend_ptr[byte - content];/* Fill in packet ID MSB. */ in ntest_1_entry()
464 …packet_id = (packet_id << 8) | packet_ptr->nx_packet_prepend_ptr[byte - content + 1];/* Fill in pa… in ntest_1_entry()
465 *byte++ = ((packet_id >> 8) & 0xFF); in ntest_1_entry()
466 *byte++ = (packet_id & 0xFF); in ntest_1_entry()
506 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
507 byte[3] = packet_id & 0xFF; in ntest_1_entry()
516 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
517 byte[3] = packet_id & 0xFF; in ntest_1_entry()
|
| D | netx_mqtt_keepalive_timeout_test.c | 337 USHORT packet_id; in ntest_1_entry() local
475 … packet_id = packet_ptr->nx_packet_prepend_ptr[byte - content];/* Fill in packet ID MSB. */ in ntest_1_entry()
476 …packet_id = (packet_id << 8) | packet_ptr->nx_packet_prepend_ptr[byte - content + 1];/* Fill in pa… in ntest_1_entry()
477 *byte++ = ((packet_id >> 8) & 0xFF); in ntest_1_entry()
478 *byte++ = (packet_id & 0xFF); in ntest_1_entry()
519 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
520 byte[3] = packet_id & 0xFF; in ntest_1_entry()
529 byte[2] = (packet_id >> 8) & 0xFF; in ntest_1_entry()
530 byte[3] = packet_id & 0xFF; in ntest_1_entry()
|
| D | netx_mqtt_subscribe_non_zero_packet_id_test.c | 326 USHORT packet_id; in ntest_1_entry() local
454 … packet_id = (packet_ptr->nx_packet_prepend_ptr[2] << 8) + (packet_ptr->nx_packet_prepend_ptr[3]); in ntest_1_entry()
468 if (packet_id == 0) in ntest_1_entry()
528 … packet_id = (packet_ptr->nx_packet_prepend_ptr[2] << 8) + (packet_ptr->nx_packet_prepend_ptr[3]); in ntest_1_entry()
542 if (packet_id != 0xFFFF) in ntest_1_entry()
603 … packet_id = (packet_ptr->nx_packet_prepend_ptr[2] << 8) + (packet_ptr->nx_packet_prepend_ptr[3]); in ntest_1_entry()
611 if (packet_id == 0) in ntest_1_entry()
|
| D | netx_mqtt_publish_packet_chain_test.c | 259 USHORT packet_id; in ntest_1_entry() local
357 packet_id = packet_buffer[len];/* Fill in packet ID MSB. */ in ntest_1_entry()
358 packet_id = (packet_id << 8) | packet_buffer[len + 1];/* Fill in packet ID MSB. */ in ntest_1_entry()
|
| /NetX-Duo-v6.2.1/common/src/ |
| D | nx_ipv6_fragment_process.c | 97 ULONG packet_id; in _nx_ipv6_fragment_process() local
131 packet_id = (ULONG)NX_RAND(); in _nx_ipv6_fragment_process()
133 packet_id = ip_ptr -> nx_ip_packet_id++; in _nx_ipv6_fragment_process()
137 NX_CHANGE_ULONG_ENDIAN(packet_id); in _nx_ipv6_fragment_process()
347 fragment_option -> nx_ipv6_header_fragment_option_packet_id = packet_id; in _nx_ipv6_fragment_process()
|
| /NetX-Duo-v6.2.1/samples/ |
| D | demo_netx_pppoe_server.c | 101 void PppTransmitDataReq(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id);
343 void PppTransmitDataReq(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id) in PppTransmitDataReq() argument
351 packet_ptr = (NX_PACKET *)(packet_id); in PppTransmitDataReq()
356 PppTransmitDataCnf(interfaceHandle, data, packet_id); in PppTransmitDataReq()
|
| /NetX-Duo-v6.2.1/addons/pppoe/ |
| D | nx_pppoe_server.h | 250 … (*nx_pppoe_data_receive_notify)(UINT session_index, ULONG length, UCHAR *data, UINT packet_id);
315 … VOID (* pppoe_data_receive_notify)(UINT session_index, ULONG length, UCHAR *data, UINT packet_id),
344 … VOID (* pppoe_data_receive_notify)(UINT session_index, ULONG length, UCHAR *data, UINT packet_id),
351 … VOID (* pppoe_data_receive_notify)(UINT session_index, ULONG length, UCHAR *data, UINT packet_id),
375 VOID PppTransmitDataCnf(UINT interfaceHandle, UCHAR *aData, UINT packet_id);
|
| D | nx_pppoe_server.c | 861 … VOID (* pppoe_data_receive_notify)(UINT session_index, ULONG length, UCHAR *data, UINT packet_id), in _nxe_pppoe_server_callback_notify_set() argument
942 … VOID (* pppoe_data_receive_notify)(UINT session_index, ULONG length, UCHAR *data, UINT packet_id), in _nx_pppoe_server_callback_notify_set() argument
4432 VOID PppTransmitDataCnf(UINT interfaceHandle, UCHAR *data_ptr, UINT packet_id) in PppTransmitDataCnf() argument
4452 if (packet_id) in PppTransmitDataCnf()
4454 packet_ptr = (NX_PACKET *)(packet_id); in PppTransmitDataCnf()
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.c | 57 … USHORT packet_id, UCHAR set_duplicate_flag, UINT wait_option);
915 … USHORT packet_id, UCHAR set_duplicate_flag, UINT wait_option) in _nxd_mqtt_copy_transmit_packet() argument
938 *((USHORT *)(*new_packet_ptr) -> nx_packet_data_start) = packet_id; in _nxd_mqtt_copy_transmit_packet()
1408 USHORT packet_id = 0; in _nxd_mqtt_process_publish() local
1460 packet_id = (USHORT)(((*bytes) << 8) | (*(bytes + 1))); in _nxd_mqtt_process_publish()
1469 if ((transmit_packet_id == packet_id) && in _nxd_mqtt_process_publish()
1547 pubresp_ptr -> mqtt_publish_response_packet_packet_identifier_msb = (UCHAR)(packet_id >> 8); in _nxd_mqtt_process_publish()
1548 pubresp_ptr -> mqtt_publish_response_packet_packet_identifier_lsb = (UCHAR)(packet_id & 0xFF); in _nxd_mqtt_process_publish()
1568 packet_id, NX_FALSE, NX_WAIT_FOREVER)) in _nxd_mqtt_process_publish()
1664 USHORT packet_id; in _nxd_mqtt_process_publish_response() local
[all …]
|
| /NetX-Duo-v6.2.1/addons/azure_iot/ |
| D | nx_azure_iot.c | 32 USHORT packet_id, UINT QoS, ULONG wait_option);
354 UINT topic_len, UCHAR *packet_id, UINT qos, UINT wait_option) in nx_azure_iot_publish_mqtt_packet() argument
368 id = (USHORT)((packet_id[0] << 8) | packet_id[1]); in nx_azure_iot_publish_mqtt_packet()
383 UINT nx_azure_iot_mqtt_packet_id_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *packet_id) in nx_azure_iot_mqtt_packet_id_get() argument
403 packet_id[0] = (UCHAR)(client_ptr -> nxd_mqtt_client_packet_identifier >> 8); in nx_azure_iot_mqtt_packet_id_get()
404 packet_id[1] = (UCHAR)(client_ptr -> nxd_mqtt_client_packet_identifier & 0xFF); in nx_azure_iot_mqtt_packet_id_get()
|
| D | nx_azure_iot.h | 303 UINT topic_len, UCHAR *packet_id, UINT qos, UINT wait_option);
306 UINT nx_azure_iot_mqtt_packet_id_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *packet_id);
|
| D | nx_azure_iot_hub_client.h | 140 USHORT packet_id);
517 USHORT packet_id));
|
| D | nx_azure_iot_provisioning_client.c | 631 UCHAR packet_id[2]; in nx_azure_iot_provisioning_client_send_req() local
650 packet_id); in nx_azure_iot_provisioning_client_send_req()
684 status = nx_packet_data_append(packet_ptr, packet_id, sizeof(packet_id), in nx_azure_iot_provisioning_client_send_req()
704 … packet_ptr, mqtt_topic_length, packet_id, NX_AZURE_IOT_MQTT_QOS_1, in nx_azure_iot_provisioning_client_send_req()
|
| D | nx_azure_iot_hub_client.c | 80 … USHORT packet_id, NX_PACKET *transmit_packet_ptr,
1209 UCHAR packet_id[2]; in nx_azure_iot_hub_client_telemetry_send_extended() local
1220 packet_id); in nx_azure_iot_hub_client_telemetry_send_extended()
1228 status = nx_packet_data_append(packet_ptr, packet_id, sizeof(packet_id), in nx_azure_iot_hub_client_telemetry_send_extended()
1252 … packet_ptr, topic_len, packet_id, NX_AZURE_IOT_HUB_CLIENT_TELEMETRY_QOS, in nx_azure_iot_hub_client_telemetry_send_extended()
1262 *packet_id_ptr = (USHORT)((packet_id[0] << 8) | packet_id[1]); in nx_azure_iot_hub_client_telemetry_send_extended()
1271 USHORT packet_id)) in nx_azure_iot_hub_client_telemetry_ack_callback_set() argument
1640 … USHORT packet_id, NX_PACKET *transmit_packet_ptr, in nx_azure_iot_hub_client_mqtt_ack_receive_notify() argument
1689 … hub_client_ptr -> nx_azure_iot_hub_client_telemetry_ack_callback(hub_client_ptr, packet_id); in nx_azure_iot_hub_client_mqtt_ack_receive_notify()
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | nx_azure_iot_pnp_client_telemetry_unit_test.c | 211 static VOID telemetry_ack_callback(NX_AZURE_IOT_HUB_CLIENT *hub_client_ptr, USHORT packet_id) in telemetry_ack_callback() argument
214 NX_PARAMETER_NOT_USED(packet_id); in telemetry_ack_callback()
225 …atic VOID generate_test_telemetry_ack(NX_AZURE_IOT_HUB_CLIENT *iothub_client_ptr, USHORT packet_id) in generate_test_telemetry_ack() argument
260 bytes[0] = (UCHAR)(packet_id >> 8); in generate_test_telemetry_ack()
261 bytes[1] = (UCHAR)(packet_id & 0xFF); in generate_test_telemetry_ack()
794 USHORT packet_id; in test_nx_azure_iot_hub_client_telemetry_send_extended_success() local
834 &packet_id, in test_nx_azure_iot_hub_client_telemetry_send_extended_success()
839 generate_test_telemetry_ack(&hub_client, packet_id); in test_nx_azure_iot_hub_client_telemetry_send_extended_success()
|
| /NetX-Duo-v6.2.1/test/regression/pppoe_test/ |
| D | netx_pppoe_api_extended_test.c | 53 …id pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id);
433 …oid pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id) in pppoe_server_packet_receive() argument
441 packet_ptr = (NX_PACKET *)(packet_id); in pppoe_server_packet_receive()
|
| D | netx_pppoe_api_test.c | 53 …id pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id);
426 …oid pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id) in pppoe_server_packet_receive() argument
434 packet_ptr = (NX_PACKET *)(packet_id); in pppoe_server_packet_receive()
|
| D | netx_pppoe_basic_test.c | 62 …id pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id);
420 …oid pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id) in pppoe_server_packet_receive() argument
428 packet_ptr = (NX_PACKET *)(packet_id); in pppoe_server_packet_receive()
|
| D | netx_pppoe_ac_name_test.c | 62 …id pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id);
436 …oid pppoe_server_packet_receive(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id) in pppoe_server_packet_receive() argument
444 packet_ptr = (NX_PACKET *)(packet_id); in pppoe_server_packet_receive()
|
| D | netx_pppoe_session_control_test.c | 75 static void PppTransmitDataReq(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id);
483 static void PppTransmitDataReq(UINT interfaceHandle, ULONG length, UCHAR *data, UINT packet_id) in PppTransmitDataReq() argument
491 packet_ptr = (NX_PACKET *)(packet_id); in PppTransmitDataReq()
|
| /NetX-Duo-v6.2.1/addons/azure_iot/samples/ |
| D | sample_azure_iot_embedded_sdk_pnp.c | 350 static VOID telemetry_ack_callback(NX_AZURE_IOT_HUB_CLIENT *hub_client_ptr, USHORT packet_id) in telemetry_ack_callback() argument
354 printf("Telemetry message ack received with packet id %d.\r\n", packet_id); in telemetry_ack_callback()
796 USHORT packet_id; in sample_telemetry_action() local
836 &packet_id, SAMPLE_WAIT_OPTION))) in sample_telemetry_action()
843 …printf("Telemetry message send with packet id %d : %.*s.\r\n", packet_id, buffer_length, scratch_b… in sample_telemetry_action()
|
