Lines Matching refs:mqtt_handle
19 static int32_t _ota_subscribe(void *mqtt_handle, void *ota_handle);
42 ota_handle->mqtt_handle = NULL; in _ota_core_mqtt_process_handler()
62 return core_mqtt_setopt(ota_handle->mqtt_handle, option, &process_data); in _ota_core_mqtt_operate_process_handler()
102 …res = aiot_mqtt_setopt(ota_handle->mqtt_handle, AIOT_MQTTOPT_REMOVE_TOPIC_MAP, (void *)&topic_map); in aiot_ota_deinit()
141 ota_handle->mqtt_handle = data; in aiot_ota_setopt()
345 core_mqtt_handle_t *mqtt_handle = ota_handle->mqtt_handle; in aiot_ota_report_version() local
346 if (NULL == mqtt_handle) { in aiot_ota_report_version()
349 product_key = mqtt_handle->product_key; in aiot_ota_report_version()
350 device_name = mqtt_handle->device_name; in aiot_ota_report_version()
362 …res = _ota_publish_base(mqtt_handle, OTA_VERSION_TOPIC_PREFIX, product_key, device_name, NULL, pay… in aiot_ota_report_version()
390 core_mqtt_handle_t *mqtt_handle = ota_handle->mqtt_handle; in aiot_ota_report_version_ext() local
391 if (NULL == mqtt_handle) { in aiot_ota_report_version_ext()
401 …res = _ota_publish_base(mqtt_handle, OTA_VERSION_TOPIC_PREFIX, product_key, device_name, NULL, pay… in aiot_ota_report_version_ext()
429 res = _ota_publish_base(ota_handle->mqtt_handle, OTA_GET_TOPIC_PREFIX, in aiot_ota_query_firmware()
430 ((core_mqtt_handle_t *)(ota_handle->mqtt_handle))->product_key, in aiot_ota_query_firmware()
431 …((core_mqtt_handle_t *)(ota_handle->mqtt_handle))->device_name, OTA_GET_TOPIC_SUFFIX, payload_stri… in aiot_ota_query_firmware()
468 res = _ota_publish_base(download_handle->task_desc->mqtt_handle, OTA_PROGRESS_TOPIC_PREFIX, in aiot_download_report_progress()
679 task_desc.mqtt_handle = ota_handle->mqtt_handle; in _ota_mqtt_process()
1055 dst_task_desc->mqtt_handle = src_task_desc->mqtt_handle; in _download_deep_copy_task_desc()
1081 core_mqtt_handle_t *mqtt_handle = (core_mqtt_handle_t *)handle; in _ota_publish_base() local
1086 if (NULL == product_key || NULL == device_name || NULL == mqtt_handle) { in _ota_publish_base()
1090 sysdep = mqtt_handle->sysdep; in _ota_publish_base()
1132 …res = aiot_mqtt_pub(mqtt_handle, topic_string, (uint8_t *)payload_string, strlen(payload_string), … in _ota_publish_base()
1149 static int32_t _ota_subscribe(void *mqtt_handle, void *ota_handle) in _ota_subscribe() argument
1160 res = aiot_mqtt_setopt(mqtt_handle, AIOT_MQTTOPT_APPEND_TOPIC_MAP, (void *)&topic_map); in _ota_subscribe()