| /AliOS-Things-master/components/uagent/src/ |
| A D | uagent_comm_mqtt.c | 20 static void *mqtt_client = NULL; variable
60 if (mqtt_client != NULL) { in uagent_ext_comm_init()
71 rc = aiot_mqtt_sub(mqtt_client, mqtt_topic_dn , uagent_handler, CORE_MQTT_QOS0, NULL); in uagent_ext_comm_init()
80 …rc = aiot_mqtt_sub(mqtt_client, mqtt_topic_up_reply, uagent_up_reply_handler, CORE_MQTT_QOS0 , NUL… in uagent_ext_comm_init()
90 … rc = aiot_mqtt_sub(mqtt_client, broadcast_topic_dn, uagent_handler, CORE_MQTT_QOS1 , NULL); in uagent_ext_comm_init()
113 if (mqtt_client != NULL) { in uagent_ext_comm_publish()
114 …rc = aiot_mqtt_pub(mqtt_client, mqtt_topic_up, data, len, conn_orient ? CORE_MQTT_QOS1 : CORE_MQTT… in uagent_ext_comm_publish()
125 if (NULL != mqtt_client) { in check_connect()
126 core_mqtt_handle_t *mqtt_handle = mqtt_client; in check_connect()
140 mqtt_client = mqtt_client_handle; in uagent_mqtt_client_set()
|
| /AliOS-Things-master/components/ota/hal/ |
| A D | ota_hal_trans.c | 10 int ota_hal_mqtt_publish(void *mqtt_client, char *topic, int qos, void *data, int len) in ota_hal_mqtt_publish() argument
12 return aiot_mqtt_pub(mqtt_client, topic, data, len, qos); in ota_hal_mqtt_publish()
15 int ota_hal_mqtt_subscribe(void *mqtt_client, char *topic, void* cb, void *ctx) in ota_hal_mqtt_subscribe() argument
17 return aiot_mqtt_sub(mqtt_client, topic, cb, 0, ctx); in ota_hal_mqtt_subscribe()
|
| A D | ota_hal_trans.h | 38 int ota_hal_mqtt_subscribe(void *mqtt_client, char *topic, void* cb, void *ctx);
39 int ota_hal_mqtt_publish(void *mqtt_client, char *topic, int qos, void *data, int len);
|
| /AliOS-Things-master/components/ota/ota_agent/transport/ |
| A D | ota_transport_mqtt.c | 195 static int ota_mqtt_publish(void *mqtt_client, const char *name, char *msg, char *pk, char *dn) in ota_mqtt_publish() argument
207 ret = ota_hal_mqtt_publish(mqtt_client, topic, 1, (void *)msg, strlen(msg) + 1); in ota_mqtt_publish()
223 static void ota_mqtt_sub_cb(void *mqtt_client, void *msg, void *pctx) in ota_mqtt_sub_cb() argument
312 ret = ota_hal_mqtt_publish(ctx->mqtt_client, topic, 1, (void *)msg, strlen(msg) + 1); in ota_transport_inform_otaver()
340 ret = ota_hal_mqtt_subscribe(ctx->mqtt_client, topic, ota_mqtt_sub_cb, ctx); in ota_transport_upgrade()
477 ret = ota_mqtt_publish(ctx->mqtt_client, "progress", msg, ctx->pk, ctx->dn); in ota_transport_status()
|
| /AliOS-Things-master/components/amp_adapter/platform/aos/haas700/ |
| A D | ota_agent.h | 228 …void *mqtt_client; /* mqtt client */ /* OTA … member
|
| /AliOS-Things-master/components/ota/include/ |
| A D | ota_agent.h | 228 …void *mqtt_client; /* mqtt client */ /* OTA … member
|
| /AliOS-Things-master/components/ota/ota_agent/ |
| A D | ota_service.c | 75 ret = ota_transport_inform(ctx->mqtt_client, ctx->pk, ctx->dn, module_name, version); in ota_report_module_version()
408 ctx->mqtt_client = NULL; in ota_service_param_reset()
|
| /AliOS-Things-master/components/py_engine/external/app_mgr/ |
| A D | app_upgrade.c | 161 internal_ctx.mqtt_client = (void *)mqtt_handle; in py_app_upgrade_service()
|
| /AliOS-Things-master/solutions/ota_demo/ |
| A D | otaappdemo.c | 159 ctx.mqtt_client = handle; in mqtt_connected_cb()
|
| /AliOS-Things-master/components/amp/services/app_mgr/ |
| A D | app_upgrade.c | 361 internal_ctx.mqtt_client = (void *)mqtt_handle; in amp_app_upgrade_service()
|
| /AliOS-Things-master/components/amp/engine/duktape_engine/addons/advanced/ota/ |
| A D | module_appota.c | 447 customer_ota_ctx.mqtt_client = (void *)iot_device_handle->mqtt_handle; in native_ota_init()
|
| /AliOS-Things-master/components/py_engine/modules/ota/ |
| A D | modappota.c | 512 customer_ota_ctx.mqtt_client = (void *)iot_device_handle->mqtt_handle; in ota_init()
|
| /AliOS-Things-master/components/amp/engine/quickjs_engine/addons/advanced/ota/ |
| A D | module_appota.c | 506 customer_ota_ctx.mqtt_client = (void *)iot_device_handle->mqtt_handle; in native_ota_init()
|
| /AliOS-Things-master/components/amp/engine/duktape_engine/addons/advanced/aiot/ |
| A D | module_aiot_gateway.c | 427 ota_svc->mqtt_client = iot_gateway_handle->mqtt_handle; in aiot_gateway_connect()
|