Lines Matching refs:adapter
90 iotx_alcs_adapter_t *adapter, CoAPMessage *message, in _iotx_alcs_send_list_search_and_remove() argument
96 list_for_each_entry_safe(node, next, &adapter->alcs_send_list, linked_list, in _iotx_alcs_send_list_search_and_remove()
116 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)userdata; in iotx_alcs_coap_adapter_send_msg_handle() local
130 HAL_MutexLock(adapter->mutex); in iotx_alcs_coap_adapter_send_msg_handle()
131 res = _iotx_alcs_send_list_search_and_remove(adapter, message, in iotx_alcs_coap_adapter_send_msg_handle()
133 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_coap_adapter_send_msg_handle()
148 adapter->alcs_event_handle->h_fp( in iotx_alcs_coap_adapter_send_msg_handle()
149 adapter->alcs_event_handle->pcontext, (void *)adapter, &event); in iotx_alcs_coap_adapter_send_msg_handle()
165 HAL_MutexLock(adapter->mutex); in iotx_alcs_coap_adapter_send_msg_handle()
166 res = _iotx_alcs_send_list_search_and_remove(adapter, message, in iotx_alcs_coap_adapter_send_msg_handle()
168 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_coap_adapter_send_msg_handle()
183 adapter->alcs_event_handle->h_fp( in iotx_alcs_coap_adapter_send_msg_handle()
184 adapter->alcs_event_handle->pcontext, (void *)adapter, &event); in iotx_alcs_coap_adapter_send_msg_handle()
206 int iotx_alcs_adapter_list_init(iotx_alcs_adapter_t *adapter) in iotx_alcs_adapter_list_init() argument
209 INIT_LIST_HEAD(&adapter->alcs_send_list); in iotx_alcs_adapter_list_init()
210 INIT_LIST_HEAD(&adapter->alcs_subdev_list); in iotx_alcs_adapter_list_init()
215 static void _iotx_alcs_adapter_send_list_destroy(iotx_alcs_adapter_t *adapter) in _iotx_alcs_adapter_send_list_destroy() argument
220 list_for_each_entry_safe(node, next, &adapter->alcs_send_list, linked_list, in _iotx_alcs_adapter_send_list_destroy()
230 static void _iotx_alcs_adapter_subdev_list_destroy(iotx_alcs_adapter_t *adapter) in _iotx_alcs_adapter_subdev_list_destroy() argument
235 list_for_each_entry_safe(node, next, &adapter->alcs_subdev_list, in _iotx_alcs_adapter_subdev_list_destroy()
247 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in iotx_alcs_adapter_deinit() local
252 HAL_MutexLock(adapter->mutex); in iotx_alcs_adapter_deinit()
253 _iotx_alcs_adapter_send_list_destroy(adapter); in iotx_alcs_adapter_deinit()
254 _iotx_alcs_adapter_subdev_list_destroy(adapter); in iotx_alcs_adapter_deinit()
255 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_adapter_deinit()
257 if (adapter->alcs_event_handle) { in iotx_alcs_adapter_deinit()
258 ALCS_free(adapter->alcs_event_handle); in iotx_alcs_adapter_deinit()
261 HAL_MutexDestroy(adapter->mutex); in iotx_alcs_adapter_deinit()
263 alcs_mqtt_deinit(adapter->coap_ctx, product_key, device_name); in iotx_alcs_adapter_deinit()
274 int iotx_alcs_adapter_init(iotx_alcs_adapter_t *adapter, in iotx_alcs_adapter_init() argument
286 adapter->mutex = HAL_MutexCreate(); in iotx_alcs_adapter_init()
287 if (adapter->mutex == NULL) { in iotx_alcs_adapter_init()
304 HAL_MutexDestroy(adapter->mutex); in iotx_alcs_adapter_init()
307 adapter->coap_ctx = coap_ctx; in iotx_alcs_adapter_init()
331 adapter->role = param->role; in iotx_alcs_adapter_init()
335 if (adapter->role & IOTX_ALCS_ROLE_SERVER) { in iotx_alcs_adapter_init()
336 adapter->alcs_server_auth_timer_func = on_svr_auth_timer; in iotx_alcs_adapter_init()
344 if (adapter->role & IOTX_ALCS_ROLE_CLIENT) { in iotx_alcs_adapter_init()
345 adapter->alcs_client_auth_timer_func = on_client_auth_timer; in iotx_alcs_adapter_init()
350 adapter->alcs_event_handle = in iotx_alcs_adapter_init()
353 if (adapter->alcs_event_handle == NULL) { in iotx_alcs_adapter_init()
358 memcpy(adapter->alcs_event_handle, param->handle_event, in iotx_alcs_adapter_init()
361 if (iotx_alcs_adapter_list_init(adapter) != SUCCESS_RETURN) { in iotx_alcs_adapter_init()
367 alcs_localsetup_init(adapter, coap_ctx, product_key, device_name); in iotx_alcs_adapter_init()
375 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in _iotx_alcs_subdev_list_search() local
383 list_for_each_entry(node, &adapter->alcs_subdev_list, linked_list, in _iotx_alcs_subdev_list_search()
401 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in iotx_alcs_subdev_remove() local
409 HAL_MutexLock(adapter->mutex); in iotx_alcs_subdev_remove()
413 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_subdev_remove()
418 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_subdev_remove()
428 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in iotx_alcs_subdev_update_stage() local
436 HAL_MutexLock(adapter->mutex); in iotx_alcs_subdev_update_stage()
442 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_subdev_update_stage()
448 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_subdev_update_stage()
454 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in iotx_alcs_subdev_stage_check() local
458 HAL_MutexLock(adapter->mutex); in iotx_alcs_subdev_stage_check()
459 list_for_each_entry(node, &adapter->alcs_subdev_list, linked_list, in iotx_alcs_subdev_stage_check()
476 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_subdev_stage_check()
482 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in iotx_alcs_construct() local
490 memset(adapter, 0, sizeof(iotx_alcs_adapter_t)); in iotx_alcs_construct()
492 res = iotx_alcs_adapter_init(adapter, params); in iotx_alcs_construct()
498 return (void *)adapter; in iotx_alcs_construct()
504 iotx_alcs_adapter_t *adapter = __iotx_alcs_get_ctx(); in iotx_alcs_cloud_init() local
510 if (adapter->local_cloud_inited == 1) { in iotx_alcs_cloud_init()
532 if (alcs_mqtt_init(adapter->coap_ctx, product_key, device_name) != in iotx_alcs_cloud_init()
539 adapter->local_cloud_inited = 1; in iotx_alcs_cloud_init()
557 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in alcs_heartbeat() local
559 if (adapter->role & IOTX_ALCS_ROLE_SERVER && in alcs_heartbeat()
560 adapter->alcs_server_auth_timer_func != NULL) { in alcs_heartbeat()
561 adapter->alcs_server_auth_timer_func(adapter->coap_ctx); in alcs_heartbeat()
564 if (adapter->role & IOTX_ALCS_ROLE_CLIENT && in alcs_heartbeat()
565 adapter->alcs_client_auth_timer_func != NULL) { in alcs_heartbeat()
566 adapter->alcs_client_auth_timer_func(adapter->coap_ctx); in alcs_heartbeat()
572 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in iotx_alcs_yield() local
574 if (adapter == NULL || adapter->coap_ctx == NULL) { in iotx_alcs_yield()
588 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in iotx_alcs_send() local
602 if (adapter == NULL || adapter->coap_ctx || msg == NULL || in iotx_alcs_send()
619 alcs_msg_init(adapter->coap_ctx, &coap_msg, msg->msg_code, msg->msg_type, 0, in iotx_alcs_send()
620 &coap_payload, (void *)adapter); in iotx_alcs_send()
649 res = alcs_sendmsg_secure(adapter->coap_ctx, &devKey, &coap_msg, 2, in iotx_alcs_send()
689 HAL_MutexLock(adapter->mutex); in iotx_alcs_send()
690 list_add_tail(&alcs_send_msg->linked_list, &adapter->alcs_send_list); in iotx_alcs_send()
691 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_send()
700 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in iotx_alcs_send_Response() local
714 if (adapter == NULL || adapter->coap_ctx == NULL || msg == NULL || in iotx_alcs_send_Response()
736 alcs_msg_init(adapter->coap_ctx, &coap_msg, msg->msg_code, msg->msg_type, 0, in iotx_alcs_send_Response()
737 &coap_payload, (void *)adapter); in iotx_alcs_send_Response()
769 if (alcs_resource_need_auth(adapter->coap_ctx, msg->uri)) { in iotx_alcs_send_Response()
770 res = alcs_sendrsp_secure(adapter->coap_ctx, &devKey, &coap_msg, 0, 0, in iotx_alcs_send_Response()
773 res = alcs_sendrsp(adapter->coap_ctx, &network_addr, &coap_msg, 0, 0, in iotx_alcs_send_Response()
790 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in iotx_alcs_register_resource() local
799 if (adapter == NULL || adapter->coap_ctx == NULL || resource->uri == NULL || in iotx_alcs_register_resource()
821 adapter->coap_ctx, productKey, deviceName, resource->uri, in iotx_alcs_register_resource()
838 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in iotx_alcs_observe_notify() local
844 res = alcs_observe_notify(adapter->coap_ctx, uri, &coap_payload); in iotx_alcs_observe_notify()
861 iotx_alcs_adapter_t *adapter = (iotx_alcs_adapter_t *)handle; in iotx_alcs_add_sub_device() local
873 if (adapter->coap_ctx != NULL) { in iotx_alcs_add_sub_device()
874 alcs_auth_subdev_init(adapter->coap_ctx, pk, dn); in iotx_alcs_add_sub_device()
878 HAL_MutexLock(adapter->mutex); in iotx_alcs_add_sub_device()
882 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_add_sub_device()
885 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_add_sub_device()
903 HAL_MutexLock(adapter->mutex); in iotx_alcs_add_sub_device()
904 list_add_tail(&subdev_item->linked_list, &adapter->alcs_subdev_list); in iotx_alcs_add_sub_device()
905 HAL_MutexUnlock(adapter->mutex); in iotx_alcs_add_sub_device()
907 alcs_localsetup_add_sub_device(adapter, subdev_item->product_key, in iotx_alcs_add_sub_device()