| /NetX-Duo-v6.2.1/samples/ |
| D | demo_mqtt_client.c | 74 static UCHAR topic_buffer[NXD_MQTT_MAX_TOPIC_NAME_LENGTH]; variable
163 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in thread_mqtt_entry()
167 topic_buffer[topic_length] = 0; in thread_mqtt_entry()
169 printf("topic = %s, message = %s\n", topic_buffer, message_buffer); in thread_mqtt_entry()
|
| /NetX-Duo-v6.2.1/test/regression/interoperability_test/mqtt_test/ |
| D | netx_mqtt_double_subscribers_test.c | 150 static UCHAR topic_buffer[NXD_MQTT_MAX_TOPIC_NAME_LENGTH]; variable
270 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
287 …status = nxd_mqtt_client_message_get(&mqtt_client_0, topic_buffer, sizeof(topic_buffer), &topic_le… in client_thread_entry()
|
| D | netx_mqtt_subscriber_empty_message_test.c | 129 static UCHAR topic_buffer[NXD_MQTT_MAX_TOPIC_NAME_LENGTH]; variable
167 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
|
| D | netx_mqtt_subscriber_test.c | 129 static UCHAR topic_buffer[NXD_MQTT_MAX_TOPIC_NAME_LENGTH]; variable
167 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_twice_test.c | 145 static UCHAR topic_buffer[NXD_MQTT_MAX_TOPIC_NAME_LENGTH]; variable
246 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
|
| D | netx_mqtt_tls_subscriber_test.c | 145 static UCHAR topic_buffer[NXD_MQTT_MAX_TOPIC_NAME_LENGTH]; variable
234 …status = nxd_mqtt_client_message_get(&mqtt_client, topic_buffer, sizeof(topic_buffer), &topic_leng… in client_thread_entry()
|
| /NetX-Duo-v6.2.1/test/regression/azure_iot/ |
| D | nx_azure_iot_adu_agent_unit_test.c | 613 static UCHAR topic_buffer[100]; variable
621 …topic_size = snprintf(topic_buffer, sizeof(topic_buffer), reported_property_success_topic, reporte… in generate_test_property_send_response()
622 construct_command_message(iothub_client_ptr, topic_buffer, in generate_test_property_send_response()
640 …topic_size = snprintf(topic_buffer, sizeof(topic_buffer), reported_property_success_topic, reporte… in generate_test_property_new_update_send()
663 …topic_size = snprintf(topic_buffer, sizeof(topic_buffer), reported_property_success_topic, reporte… in generate_test_property_cancel_update_send()
|
| /NetX-Duo-v6.2.1/addons/mqtt/ |
| D | nxd_mqtt_client.h | 471 UINT nxd_mqtt_client_message_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *topic_buffer, UINT topic_buffe…
495 UINT _nxd_mqtt_client_message_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *topic_buffer, UINT topic_buff…
530 UINT _nxde_mqtt_client_message_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *topic_buffer, UINT topic_buf…
|
| D | nxd_mqtt_client.c | 5425 UINT _nxd_mqtt_client_message_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *topic_buffer, UINT topic_buff… in _nxd_mqtt_client_message_get() argument
5464 nx_packet_data_extract_offset(packet_ptr, topic_offset, topic_buffer, in _nxd_mqtt_client_message_get()
6095 UINT _nxde_mqtt_client_message_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *topic_buffer, UINT topic_buf… in _nxde_mqtt_client_message_get() argument
6108 if ((message_buffer == NX_NULL) || (topic_buffer == NX_NULL)) in _nxde_mqtt_client_message_get()
6114 …return(_nxd_mqtt_client_message_get(client_ptr, topic_buffer, topic_buffer_size, actual_topic_leng… in _nxde_mqtt_client_message_get()
|
