Searched refs:mqtt_msg (Results 1 – 2 of 2) sorted by relevance
| /AliOS-Things-master/components/ota/ota_agent/transport/ |
| A D | ota_transport_mqtt.c | 227 aiot_mqtt_recv_t *mqtt_msg = (aiot_mqtt_recv_t *)msg; in ota_mqtt_sub_cb() local
232 if (mqtt_msg->type == AIOT_MQTTRECV_PUB) { in ota_mqtt_sub_cb()
233 payload = (char *)mqtt_msg->data.pub.payload; in ota_mqtt_sub_cb()
234 …OTA_LOG_I("pub, qos: %d, topic: %.*s\n", mqtt_msg->data.pub.qos, mqtt_msg->data.pub.topic_len, mqt… in ota_mqtt_sub_cb()
236 OTA_LOG_I("mqtt cb evt:%d %s", mqtt_msg->type, payload); in ota_mqtt_sub_cb()
240 OTA_LOG_I("mqtt type = %d", mqtt_msg->type); in ota_mqtt_sub_cb()
241 payload = (char *)mqtt_msg->data.pub.payload; in ota_mqtt_sub_cb()
|
| /AliOS-Things-master/components/linkkit/mqtt/ |
| A D | mqtt_api.c | 573 iotx_mqtt_topic_info_t mqtt_msg; in IOT_MQTT_Publish_Simple() local
582 memset(&mqtt_msg, 0x0, sizeof(iotx_mqtt_topic_info_t)); in IOT_MQTT_Publish_Simple()
584 mqtt_msg.qos = qos; in IOT_MQTT_Publish_Simple()
585 mqtt_msg.retain = 0; in IOT_MQTT_Publish_Simple()
586 mqtt_msg.dup = 0; in IOT_MQTT_Publish_Simple()
587 mqtt_msg.payload = (void *)data; in IOT_MQTT_Publish_Simple()
588 mqtt_msg.payload_len = len; in IOT_MQTT_Publish_Simple()
590 rc = wrapper_mqtt_publish(client, topic_name, &mqtt_msg); in IOT_MQTT_Publish_Simple()
|
Completed in 5 milliseconds