Lines Matching refs:topic_info
191 iotx_mqtt_topic_info_pt topic_info = in iotx_cloud_conn_mqtt_event_handle() local
199 cm_warning("bypass %d bytes on [%.*s]", topic_info->payload_len, in iotx_cloud_conn_mqtt_event_handle()
200 topic_info->topic_len, topic_info->ptopic); in iotx_cloud_conn_mqtt_event_handle()
204 topic_handle_func(_mqtt_conncection->fd, topic_info->ptopic, in iotx_cloud_conn_mqtt_event_handle()
205 topic_info->topic_len, topic_info->payload, in iotx_cloud_conn_mqtt_event_handle()
206 topic_info->payload_len, NULL); in iotx_cloud_conn_mqtt_event_handle()
208 topic = cm_malloc(topic_info->topic_len + 1); in iotx_cloud_conn_mqtt_event_handle()
213 memset(topic, 0, topic_info->topic_len + 1); in iotx_cloud_conn_mqtt_event_handle()
214 memcpy(topic, topic_info->ptopic, topic_info->topic_len); in iotx_cloud_conn_mqtt_event_handle()
216 topic_handle_func(_mqtt_conncection->fd, topic, topic_info->payload, in iotx_cloud_conn_mqtt_event_handle()
217 topic_info->payload_len, NULL); in iotx_cloud_conn_mqtt_event_handle()