8c24d921b0
sample: examples\aliyun_iotkit_csdk_mqtt project: board\TencentOS_tiny_EVB_MX_Plus\KEIL\aliyun_iotkit_csdk_mqtt
236 lines
6.9 KiB
C
236 lines
6.9 KiB
C
/*
|
|
* Copyright (C) 2015-2018 Alibaba Group Holding Limited
|
|
*/
|
|
#include "iotx_dm_internal.h"
|
|
|
|
#if defined(OTA_ENABLED) && !defined(BUILD_AOS)
|
|
|
|
#ifdef INFRA_MEM_STATS
|
|
#include "infra_mem_stats.h"
|
|
#define DM_COTA_MALLOC(size) LITE_malloc(size, MEM_MAGIC, "dm.cota")
|
|
#define DM_COTA_FREE(ptr) LITE_free(ptr)
|
|
#else
|
|
#define DM_COTA_MALLOC(size) HAL_Malloc(size)
|
|
#define DM_COTA_FREE(ptr) {HAL_Free((void *)ptr);ptr = NULL;}
|
|
#endif
|
|
|
|
static dm_cota_ctx_t g_dm_cota_ctx;
|
|
|
|
static dm_cota_ctx_t *_dm_cota_get_ctx(void)
|
|
{
|
|
return &g_dm_cota_ctx;
|
|
}
|
|
|
|
int dm_cota_init(void)
|
|
{
|
|
dm_cota_ctx_t *ctx = _dm_cota_get_ctx();
|
|
|
|
memset(ctx, 0, sizeof(dm_cota_ctx_t));
|
|
|
|
return SUCCESS_RETURN;
|
|
}
|
|
|
|
int dm_cota_deinit(void)
|
|
{
|
|
dm_cota_ctx_t *ctx = _dm_cota_get_ctx();
|
|
|
|
memset(ctx, 0, sizeof(dm_cota_ctx_t));
|
|
|
|
return SUCCESS_RETURN;
|
|
}
|
|
|
|
static int _dm_cota_send_new_config_to_user(void *ota_handle)
|
|
{
|
|
int res = 0, message_len = 0;
|
|
char *message = NULL;
|
|
uint32_t config_size = 0;
|
|
char *config_id = NULL, *sign = NULL, *sign_method = NULL, *url = NULL, *get_type = NULL;
|
|
const char *cota_new_config_fmt =
|
|
"{\"configId\":\"%s\",\"configSize\":%d,\"getType\":\"%s\",\"sign\":\"%s\",\"signMethod\":\"%s\",\"url\":\"%s\"}";
|
|
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_COTA_CONFIG_ID, (void *)&config_id, 1);
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_COTA_CONFIG_SIZE, &config_size, 4);
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_COTA_SIGN, (void *)&sign, 1);
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_COTA_SIGN_METHOD, (void *)&sign_method, 1);
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_COTA_URL, (void *)&url, 1);
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_COTA_GETTYPE, (void *)&get_type, 1);
|
|
|
|
if (config_id == NULL || sign == NULL || sign_method == NULL || url == NULL || get_type == NULL) {
|
|
res = FAIL_RETURN;
|
|
goto ERROR;
|
|
}
|
|
|
|
message_len = strlen(cota_new_config_fmt) + strlen(config_id) + DM_UTILS_UINT32_STRLEN + strlen(get_type) +
|
|
strlen(sign) + strlen(sign_method) + strlen(url) + 1;
|
|
|
|
message = DM_malloc(message_len);
|
|
if (message == NULL) {
|
|
res = DM_MEMORY_NOT_ENOUGH;
|
|
goto ERROR;
|
|
}
|
|
memset(message, 0, message_len);
|
|
HAL_Snprintf(message, message_len, cota_new_config_fmt, config_id, config_size, get_type, sign, sign_method, url);
|
|
|
|
dm_log_info("Send To User: %s", message);
|
|
|
|
res = _dm_msg_send_to_user(IOTX_DM_EVENT_COTA_NEW_CONFIG, message);
|
|
if (res != SUCCESS_RETURN) {
|
|
if (message) {
|
|
DM_free(message);
|
|
}
|
|
res = FAIL_RETURN;
|
|
goto ERROR;
|
|
}
|
|
|
|
res = SUCCESS_RETURN;
|
|
ERROR:
|
|
if (config_id) {
|
|
DM_COTA_FREE(config_id);
|
|
}
|
|
if (sign) {
|
|
DM_COTA_FREE(sign);
|
|
}
|
|
if (sign_method) {
|
|
DM_COTA_FREE(sign_method);
|
|
}
|
|
if (url) {
|
|
DM_COTA_FREE(url);
|
|
}
|
|
if (get_type) {
|
|
DM_COTA_FREE(get_type);
|
|
}
|
|
|
|
return res;
|
|
}
|
|
|
|
int dm_cota_perform_sync(_OU_ char *output, _IN_ int output_len)
|
|
{
|
|
int res = 0, file_download = 0;
|
|
uint32_t file_size = 0, file_downloaded = 0;
|
|
uint64_t percent_pre = 0, percent_now = 0;
|
|
unsigned long long report_pre = 0, report_now = 0;
|
|
dm_cota_ctx_t *ctx = _dm_cota_get_ctx();
|
|
void *ota_handle = NULL;
|
|
uint32_t ota_type = IOT_OTAT_NONE;
|
|
|
|
if (output == NULL || output_len <= 0) {
|
|
return DM_INVALID_PARAMETER;
|
|
}
|
|
|
|
/* Get Ota Handle */
|
|
res = dm_ota_get_ota_handle(&ota_handle);
|
|
if (res != SUCCESS_RETURN) {
|
|
return FAIL_RETURN;
|
|
}
|
|
|
|
if (ota_handle == NULL) {
|
|
return FAIL_RETURN;
|
|
}
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_OTA_TYPE, &ota_type, 4);
|
|
|
|
if (ota_type != IOT_OTAT_COTA) {
|
|
return FAIL_RETURN;
|
|
}
|
|
|
|
/* reset the size_fetched in ota_handle to be 0 */
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_RESET_FETCHED_SIZE, ota_handle, 4);
|
|
/* Prepare Write Data To Storage */
|
|
HAL_Firmware_Persistence_Start();
|
|
|
|
while (1) {
|
|
file_download = IOT_OTA_FetchYield(ota_handle, output, output_len, 1);
|
|
if (file_download < 0) {
|
|
IOT_OTA_ReportProgress(ota_handle, IOT_OTAP_FETCH_FAILED, NULL);
|
|
HAL_Firmware_Persistence_Stop();
|
|
ctx->is_report_new_config = 0;
|
|
return FAIL_RETURN;
|
|
}
|
|
|
|
/* Write Config File Into Stroage */
|
|
HAL_Firmware_Persistence_Write(output, file_download);
|
|
|
|
/* Get OTA information */
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_FETCHED_SIZE, &file_downloaded, 4);
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_FILE_SIZE, &file_size, 4);
|
|
|
|
/* Calculate Download Percent And Update Report Timestamp*/
|
|
percent_now = (file_downloaded * 100) / file_size;
|
|
report_now = HAL_UptimeMs();
|
|
|
|
/* Report Download Process To Cloud */
|
|
if (report_now < report_pre) {
|
|
report_pre = report_now;
|
|
}
|
|
if ((((percent_now - percent_pre) > 5) &&
|
|
((report_now - report_pre) > 50)) || (percent_now >= IOT_OTAP_FETCH_PERCENTAGE_MAX)) {
|
|
IOT_OTA_ReportProgress(ota_handle, percent_now, NULL);
|
|
percent_pre = percent_now;
|
|
report_pre = report_now;
|
|
}
|
|
|
|
/* Check If OTA Finished */
|
|
if (IOT_OTA_IsFetchFinish(ota_handle)) {
|
|
uint32_t file_isvalid = 0;
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_CHECK_CONFIG, &file_isvalid, 4);
|
|
if (file_isvalid == 0) {
|
|
HAL_Firmware_Persistence_Stop();
|
|
ctx->is_report_new_config = 0;
|
|
return FAIL_RETURN;
|
|
} else {
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
HAL_Firmware_Persistence_Stop();
|
|
ctx->is_report_new_config = 0;
|
|
|
|
return SUCCESS_RETURN;
|
|
}
|
|
|
|
int dm_cota_get_config(const char *config_scope, const char *get_type, const char *attribute_keys)
|
|
{
|
|
int res = 0;
|
|
void *ota_handle = NULL;
|
|
|
|
/* Get Ota Handle */
|
|
res = dm_ota_get_ota_handle(&ota_handle);
|
|
if (res != SUCCESS_RETURN) {
|
|
return FAIL_RETURN;
|
|
}
|
|
|
|
return iotx_ota_get_config(ota_handle, config_scope, get_type, attribute_keys);
|
|
}
|
|
|
|
int dm_cota_status_check(void)
|
|
{
|
|
int res = 0;
|
|
dm_cota_ctx_t *ctx = _dm_cota_get_ctx();
|
|
void *ota_handle = NULL;
|
|
|
|
/* Get Ota Handle */
|
|
res = dm_ota_get_ota_handle(&ota_handle);
|
|
if (res != SUCCESS_RETURN) {
|
|
return FAIL_RETURN;
|
|
}
|
|
|
|
if (IOT_OTA_IsFetching(ota_handle)) {
|
|
uint32_t ota_type = IOT_OTAT_NONE;
|
|
|
|
IOT_OTA_Ioctl(ota_handle, IOT_OTAG_OTA_TYPE, &ota_type, 4);
|
|
|
|
if (ota_type == IOT_OTAT_COTA) {
|
|
/* Send New Config Information To User */
|
|
if (ctx->is_report_new_config == 0) {
|
|
dm_log_debug("Cota Status Check");
|
|
res = _dm_cota_send_new_config_to_user(ota_handle);
|
|
if (res == SUCCESS_RETURN) {
|
|
ctx->is_report_new_config = 1;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return SUCCESS_RETURN;
|
|
}
|
|
#endif |