| /NetX-Duo-v6.2.1/test/regression/mqtt_test/ |
| D | netx_mqtt_connect_auth_empty_test.c | 325 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
415 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
417 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xF; in ntest_1_entry()
418 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xF); in ntest_1_entry()
419 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
421 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
430 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
519 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xFF; in ntest_1_entry()
520 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xFF); in ntest_1_entry()
521 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
[all …]
|
| D | netx_mqtt_connect_auth_test.c | 327 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
418 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
420 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xF; in ntest_1_entry()
421 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xF); in ntest_1_entry()
422 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
424 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
433 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
523 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xFF; in ntest_1_entry()
524 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xFF); in ntest_1_entry()
525 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
[all …]
|
| D | netx_mqtt_connect_with_auth_will_test.c | 314 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
405 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
407 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xF; in ntest_1_entry()
408 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xF); in ntest_1_entry()
429 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xFF; in ntest_1_entry()
430 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xFF); in ntest_1_entry()
431 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
432 buf = content + sizeof(fixed_header) + 2 + strlen(CLIENT_ID); in ntest_1_entry()
452 …content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID) + 4 + strlen(USERNAME) + strlen(PASS… in ntest_1_entry()
|
| D | netx_mqtt_connack_error_test.c | 295 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
385 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
387 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
388 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
389 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
391 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
400 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_connect_non_block_2_test.c | 200 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
337 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_0_entry()
339 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_0_entry()
340 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_0_entry()
341 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_0_entry()
343 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_0_entry()
352 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_0_entry()
|
| D | netx_mqtt_connect_non_block_test.c | 308 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
398 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
400 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
401 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
402 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
404 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
413 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_connect_test.c | 308 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
398 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
400 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
401 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
402 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
404 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
413 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_connect_v6_test.c | 366 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
458 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
460 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
461 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
462 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
464 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
473 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_receive_qos2_test.c | 233 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
281 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
283 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
284 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
285 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
287 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
296 … if(memcmp(packet_ptr -> nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_connect_will_message_test.c | 308 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
399 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
401 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xff; in ntest_1_entry()
402 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xff); in ntest_1_entry()
403 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
404 index = sizeof(fixed_header) + 2 + strlen(CLIENT_ID); in ntest_1_entry()
418 …content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID) + strlen(WILL_MESSAGE) + strlen(WILL… in ntest_1_entry()
|
| D | netx_mqtt_connect_will_topic_only_test.c | 313 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
404 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
406 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xff; in ntest_1_entry()
407 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xff); in ntest_1_entry()
408 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
409 index = sizeof(fixed_header) + 2 + strlen(CLIENT_ID); in ntest_1_entry()
420 … content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID) + strlen(WILL_TOPIC) + 2 + 2); in ntest_1_entry()
|
| D | netx_mqtt_receive_qos0_test.c | 344 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
435 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
437 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
438 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
439 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
441 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
450 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_receive_qos1_test.c | 341 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
432 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
434 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
435 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
436 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
438 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
447 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_receive_span_test.c | 352 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
443 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
445 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
446 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
447 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
449 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
458 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_multiple_receive_test.c | 371 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
462 memcpy(content, fixed_header, sizeof(fixed_header)); in ntest_1_entry()
464 content[sizeof(fixed_header)] = (strlen(CLIENT_ID) >> 8) & 0xf; in ntest_1_entry()
465 content[sizeof(fixed_header) + 1] = (strlen(CLIENT_ID) & 0xf); in ntest_1_entry()
466 memcpy(content + sizeof(fixed_header) + 2, CLIENT_ID, strlen(CLIENT_ID)); in ntest_1_entry()
468 content[1] = (UCHAR)(sizeof(fixed_header) + strlen(CLIENT_ID)); in ntest_1_entry()
477 … if (memcmp(packet_ptr->nx_packet_prepend_ptr, content, sizeof(fixed_header) + strlen(CLIENT_ID))) in ntest_1_entry()
|
| D | netx_mqtt_connect_packet_send_failure_test.c | 287 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
|
| D | netx_mqtt_websocket_block_test.c | 318 static UCHAR fixed_header[] = {0x10, 0x00, 0x00, 0x04, 'M', 'Q', 'T', 'T', 0x4, 0x0, 0x0, 0x0}; variable
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.c | 114 UCHAR fixed_header[5]; in _nxd_mqtt_client_set_fixed_header() local
115 UCHAR *byte = fixed_header; in _nxd_mqtt_client_set_fixed_header()
137 ret = nx_packet_data_append(packet_ptr, fixed_header, count + 1, in _nxd_mqtt_client_set_fixed_header()
1414 UCHAR fixed_header; in _nxd_mqtt_process_publish() local
1467 fixed_header = *(transmit_packet_ptr -> nx_packet_prepend_ptr); in _nxd_mqtt_process_publish()
1470 ((fixed_header & 0xF0) == (MQTT_CONTROL_PACKET_TYPE_PUBREC << 4))) in _nxd_mqtt_process_publish()
1669 UCHAR fixed_header; in _nxd_mqtt_process_publish_response() local
1691 fixed_header = *(transmit_packet_ptr -> nx_packet_prepend_ptr); in _nxd_mqtt_process_publish_response()
1702 … if ((fixed_header & 0xF6) == ((MQTT_CONTROL_PACKET_TYPE_PUBLISH << 4) | MQTT_PUBLISH_QOS_LEVEL_1)) in _nxd_mqtt_process_publish_response()
1726 if ((fixed_header & 0xF6) == (MQTT_CONTROL_PACKET_TYPE_PUBREC << 4)) in _nxd_mqtt_process_publish_response()
[all …]
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | direct_method_unit_test.c | 217 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
218 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
240 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
| D | nx_azure_iot_pnp_client_command_unit_test.c | 227 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
228 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
250 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
| D | nx_azure_iot_pnp_client_telemetry_unit_test.c | 277 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
278 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
300 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
| D | device_twin_unit_test.c | 240 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
241 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
263 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
| D | nx_azure_iot_adu_agent_unit_test.c | 516 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
517 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
539 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
| D | iot_provisioning_client_unit_test.c | 355 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
356 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
378 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
| D | nx_azure_iot_pnp_client_properties_unit_test.c | 282 UCHAR fixed_header[5]; in mqtt_client_set_fixed_header() local
283 UCHAR *byte = fixed_header; in mqtt_client_set_fixed_header()
305 ret = __real__nx_packet_data_append(packet_ptr, fixed_header, count + 1, in mqtt_client_set_fixed_header()
|
