Lines Matching refs:sysdep
23 static int32_t _ota_parse_json(aiot_sysdep_portfile_t *sysdep, void *in, uint32_t in_len, char *key…
29 static void *_download_deep_copy_base(aiot_sysdep_portfile_t *sysdep, char *in);
30 static void *_download_deep_copy_task_desc(aiot_sysdep_portfile_t *sysdep, void *data);
31 static int32_t _download_deep_free_task_desc(aiot_sysdep_portfile_t *sysdep, void *data);
68 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_ota_init() local
70 sysdep = aiot_sysdep_get_portfile(); in aiot_ota_init()
71 if (sysdep == NULL) { in aiot_ota_init()
75 ota_handle = sysdep->core_sysdep_malloc(sizeof(ota_handle_t), OTA_MODULE_NAME); in aiot_ota_init()
80 ota_handle->data_mutex = sysdep->core_sysdep_mutex_init(); in aiot_ota_init()
81 ota_handle->sysdep = sysdep; in aiot_ota_init()
82 core_global_init(sysdep); in aiot_ota_init()
89 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_ota_deinit() local
108 sysdep = ota_handle->sysdep; in aiot_ota_deinit()
109 core_global_deinit(sysdep); in aiot_ota_deinit()
110 sysdep->core_sysdep_mutex_deinit(&(ota_handle->data_mutex)); in aiot_ota_deinit()
111 sysdep->core_sysdep_free(ota_handle); in aiot_ota_deinit()
120 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_ota_setopt() local
129 sysdep = ota_handle->sysdep; in aiot_ota_setopt()
130 sysdep->core_sysdep_mutex_lock(ota_handle->data_mutex); in aiot_ota_setopt()
157 sysdep->core_sysdep_mutex_unlock(ota_handle->data_mutex); in aiot_ota_setopt()
165 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_download_init() local
170 sysdep = aiot_sysdep_get_portfile(); in aiot_download_init()
171 if (NULL == sysdep) { in aiot_download_init()
175 download_handle = sysdep->core_sysdep_malloc(sizeof(download_handle_t), DOWNLOAD_MODULE_NAME); in aiot_download_init()
180 download_handle->sysdep = sysdep; in aiot_download_init()
181 download_handle->data_mutex = sysdep->core_sysdep_mutex_init(); in aiot_download_init()
182 download_handle->recv_mutex = sysdep->core_sysdep_mutex_init(); in aiot_download_init()
186 sysdep->core_sysdep_free(download_handle); in aiot_download_init()
193 sysdep->core_sysdep_free(download_handle); in aiot_download_init()
194 sysdep->core_sysdep_free(http_handle); in aiot_download_init()
210 aiot_sysdep_portfile_t *sysdep = download_handle->sysdep; in aiot_download_deinit() local
217 sysdep->core_sysdep_free(download_handle->digest_ctx); in aiot_download_deinit()
222 sysdep->core_sysdep_free(download_handle->digest_ctx); in aiot_download_deinit()
225 _download_deep_free_task_desc(sysdep, download_handle->task_desc); in aiot_download_deinit()
226 sysdep->core_sysdep_free(download_handle->task_desc); in aiot_download_deinit()
229 sysdep->core_sysdep_mutex_deinit(&(download_handle->data_mutex)); in aiot_download_deinit()
230 sysdep->core_sysdep_mutex_deinit(&(download_handle->recv_mutex)); in aiot_download_deinit()
231 sysdep->core_sysdep_free(download_handle); in aiot_download_deinit()
248 aiot_sysdep_portfile_t *sysdep = download_handle->sysdep; in aiot_download_setopt() local
250 sysdep->core_sysdep_mutex_lock(download_handle->data_mutex); in aiot_download_setopt()
271 void *new_task_desc = _download_deep_copy_task_desc(sysdep, data); in aiot_download_setopt()
279 …core_sha256_context_t *ctx = sysdep->core_sysdep_malloc(sizeof(core_sha256_context_t), OTA_MODULE_… in aiot_download_setopt()
288 …utils_md5_context_t *ctx = sysdep->core_sysdep_malloc(sizeof(utils_md5_context_t), OTA_MODULE_NAME… in aiot_download_setopt()
323 sysdep->core_sysdep_mutex_unlock(download_handle->data_mutex); in aiot_download_setopt()
331 aiot_sysdep_portfile_t *sysdep; in aiot_ota_report_version() local
352 sysdep = ota_handle->sysdep; in aiot_ota_report_version()
356 core_sprintf(sysdep, &payload_string, "%s%s%s%s%s", src, topic_len, OTA_MODULE_NAME); in aiot_ota_report_version()
360 core_sprintf(sysdep, &payload_string, "%s%s%s", src, topic_len, OTA_MODULE_NAME); in aiot_ota_report_version()
363 sysdep->core_sysdep_free(payload_string); in aiot_ota_report_version()
371 aiot_sysdep_portfile_t *sysdep; in aiot_ota_report_version_ext() local
395 sysdep = ota_handle->sysdep; in aiot_ota_report_version_ext()
399 core_sprintf(sysdep, &payload_string, "%s%s%s", src, topic_len, OTA_MODULE_NAME); in aiot_ota_report_version_ext()
402 sysdep->core_sysdep_free(payload_string); in aiot_ota_report_version_ext()
410 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_ota_query_firmware() local
418 sysdep = ota_handle->sysdep; in aiot_ota_query_firmware()
423 core_sprintf(sysdep, &payload_string, "%s%s%s", src, topic_len, OTA_MODULE_NAME); in aiot_ota_query_firmware()
427 core_sprintf(sysdep, &payload_string, "%s", src, topic_len, OTA_MODULE_NAME); in aiot_ota_query_firmware()
432 sysdep->core_sysdep_free(payload_string); in aiot_ota_query_firmware()
440 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_download_report_progress() local
450 sysdep = download_handle->sysdep; in aiot_download_report_progress()
461 core_sprintf(sysdep, &payload_string, "%s%s%s%s%s", src, topic_len, OTA_MODULE_NAME); in aiot_download_report_progress()
465 core_sprintf(sysdep, &payload_string, "%s%s%s", src, topic_len, OTA_MODULE_NAME); in aiot_download_report_progress()
471 sysdep->core_sysdep_free(payload_string); in aiot_download_report_progress()
479 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_download_recv() local
486 sysdep = download_handle->sysdep; in aiot_download_recv()
488 sysdep->core_sysdep_mutex_lock(download_handle->recv_mutex); in aiot_download_recv()
525 … core_log1(download_handle->sysdep, STATE_DOWNLOAD_RECV_ERROR, "recv got %s, renewal\r\n", in aiot_download_recv()
545 sysdep->core_sysdep_mutex_unlock(download_handle->recv_mutex); in aiot_download_recv()
551 int32_t _download_deep_free_task_desc(aiot_sysdep_portfile_t *sysdep, void *data) in _download_deep_free_task_desc() argument
561 sysdep->core_sysdep_free(task_desc->product_key); in _download_deep_free_task_desc()
564 sysdep->core_sysdep_free(task_desc->device_name); in _download_deep_free_task_desc()
567 sysdep->core_sysdep_free(task_desc->url); in _download_deep_free_task_desc()
570 sysdep->core_sysdep_free(task_desc->expect_digest); in _download_deep_free_task_desc()
573 sysdep->core_sysdep_free(task_desc->version); in _download_deep_free_task_desc()
576 sysdep->core_sysdep_free(task_desc->module); in _download_deep_free_task_desc()
579 sysdep->core_sysdep_free(task_desc->extra_data); in _download_deep_free_task_desc()
586 int32_t _ota_prase_topic(aiot_sysdep_portfile_t *sysdep, char *topic, uint8_t topic_len, in _ota_prase_topic() argument
631 …if ((NULL == (_product_key_local = sysdep->core_sysdep_malloc(_product_key_len + 1, OTA_MODULE_NAM… in _ota_prase_topic()
632 …|| (NULL == (_device_name_local = sysdep->core_sysdep_malloc(_device_name_len + 1, OTA_MODULE_NAME… in _ota_prase_topic()
634 sysdep->core_sysdep_free(_product_key_local); in _ota_prase_topic()
654 aiot_sysdep_portfile_t *sysdep = NULL; in _ota_mqtt_process() local
670 sysdep = ota_handle->sysdep; in _ota_mqtt_process()
671 res = _ota_prase_topic(sysdep, packet->data.pub.topic, packet->data.pub.topic_len, in _ota_mqtt_process()
696 if ((STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "size", &size_string)) in _ota_mqtt_process()
697 … || (STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "version", &(task_desc.version)))) { in _ota_mqtt_process()
702 if ((STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "configSize", &size_string)) in _ota_mqtt_process()
703 … || (STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "configId", &(task_desc.version)))) { in _ota_mqtt_process()
711 if ((STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "url", &(task_desc.url))) in _ota_mqtt_process()
712 … || (STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "sign", &(task_desc.expect_digest))) in _ota_mqtt_process()
713 …|| (STATE_SUCCESS != _ota_parse_json(sysdep, data, data_len, "signMethod", &(digest_method_string)… in _ota_mqtt_process()
732 _ota_parse_json(sysdep, data, data_len, "module", &(task_desc.module)); in _ota_mqtt_process()
733 _ota_parse_json(sysdep, data, data_len, "extData", &(task_desc.extra_data)); in _ota_mqtt_process()
747 sysdep->core_sysdep_free(size_string); in _ota_mqtt_process()
750 sysdep->core_sysdep_free(digest_method_string); in _ota_mqtt_process()
752 _download_deep_free_task_desc(sysdep, (void *)(&task_desc)); in _ota_mqtt_process()
808 aiot_sysdep_portfile_t *sysdep = NULL; in aiot_download_send_request() local
819 sysdep = download_handle->sysdep; in aiot_download_send_request()
842 res = core_sprintf(sysdep, &header_string, "%s%s%s%s\r\n", src, len, OTA_MODULE_NAME); in aiot_download_send_request()
845 sysdep->core_sysdep_free(header_string); in aiot_download_send_request()
856 sysdep->core_sysdep_free(header_string); in aiot_download_send_request()
864 sysdep->core_sysdep_free(header_string); in aiot_download_send_request()
871 sysdep->core_sysdep_free(header_string); in aiot_download_send_request()
884 sysdep->core_sysdep_free(header_string); in aiot_download_send_request()
964 …core_log(download_handle->sysdep, STATE_DOWNLOAD_HTTPRSP_CODE_ERROR, "wrong http respond code\r\n"… in _http_recv_handler()
968 …core_log(download_handle->sysdep, STATE_DOWNLOAD_HTTPRSP_HEADER_ERROR, "wrong http respond header\… in _http_recv_handler()
973 …core_log(download_handle->sysdep, STATE_DOWNLOAD_FETCH_TOO_MANY, "downloaded exceeds expected\r\n"… in _http_recv_handler()
993 core_log(download_handle->sysdep, ret, "digest mismatch\r\n"); in _http_recv_handler()
996 … core_log(download_handle->sysdep, STATE_OTA_DIGEST_MATCH, "digest matched\r\n"); in _http_recv_handler()
1022 static void *_download_deep_copy_base(aiot_sysdep_portfile_t *sysdep, char *in) in _download_deep_copy_base() argument
1030 tmp = (aiot_download_task_desc_t *)sysdep->core_sysdep_malloc(len, in _download_deep_copy_base()
1041 static void *_download_deep_copy_task_desc(aiot_sysdep_portfile_t *sysdep, void *data) in _download_deep_copy_task_desc() argument
1046 …dst_task_desc = (aiot_download_task_desc_t *)sysdep->core_sysdep_malloc(sizeof(aiot_download_task_… in _download_deep_copy_task_desc()
1059 … if (NULL == (dst_task_desc->module = _download_deep_copy_base(sysdep, src_task_desc->module))) { in _download_deep_copy_task_desc()
1063 …if ((NULL == (dst_task_desc->product_key = _download_deep_copy_base(sysdep, src_task_desc->product… in _download_deep_copy_task_desc()
1064 …|| (NULL == (dst_task_desc->device_name = _download_deep_copy_base(sysdep, src_task_desc->device_n… in _download_deep_copy_task_desc()
1065 || (NULL == (dst_task_desc->url = _download_deep_copy_base(sysdep, src_task_desc->url))) in _download_deep_copy_task_desc()
1066 … || (NULL == (dst_task_desc->version = _download_deep_copy_base(sysdep, src_task_desc->version))) in _download_deep_copy_task_desc()
1067 …|| (NULL == (dst_task_desc->expect_digest = _download_deep_copy_base(sysdep, src_task_desc->expect… in _download_deep_copy_task_desc()
1068 _download_deep_free_task_desc(sysdep, dst_task_desc); in _download_deep_copy_task_desc()
1069 sysdep->core_sysdep_free(dst_task_desc); in _download_deep_copy_task_desc()
1084 aiot_sysdep_portfile_t *sysdep = NULL; in _ota_publish_base() local
1090 sysdep = mqtt_handle->sysdep; in _ota_publish_base()
1095 res = core_sprintf(sysdep, &topic_string, "%s/%s/%s", src, topic_len, OTA_MODULE_NAME); in _ota_publish_base()
1102 res = core_sprintf(sysdep, &topic_string, "%s/%s/%s/%s", src, topic_len, OTA_MODULE_NAME); in _ota_publish_base()
1113 res = core_global_alink_id_next(sysdep, &alink_id); in _ota_publish_base()
1125 … res = core_sprintf(sysdep, &payload_string, "%s%s%s%s%s", src, topic_len, OTA_MODULE_NAME); in _ota_publish_base()
1136 sysdep->core_sysdep_free(topic_string); in _ota_publish_base()
1139 sysdep->core_sysdep_free(payload_string); in _ota_publish_base()
1143 core_log(sysdep, STATE_OTA_REPORT_FAILED, topic_prefix); in _ota_publish_base()
1169 static int32_t _ota_parse_json(aiot_sysdep_portfile_t *sysdep, void *input, uint32_t input_len, cha… in _ota_parse_json() argument
1181 buffer = sysdep->core_sysdep_malloc(buffer_len, OTA_MODULE_NAME); in _ota_parse_json()