| /ohos5.0/base/startup/init/services/loopevent/task/ |
| H A D | le_asynctask.c | 24 static void DoAsyncEvent_(const LoopHandle loopHandle, AsyncEventTask *asyncTask) in DoAsyncEvent_() argument
26 LE_CHECK(loopHandle != NULL && asyncTask != NULL, return, "Invalid parameters"); in DoAsyncEvent_()
33 StreamTask *task = &asyncTask->stream; in DoAsyncEvent_()
38 if (asyncTask->processAsyncEvent) { in DoAsyncEvent_()
39 asyncTask->processAsyncEvent((TaskHandle)asyncTask, eventId, in DoAsyncEvent_()
60 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in LE_DoAsyncEvent() local
61 while (!IsBufferEmpty(&asyncTask->stream)) { in LE_DoAsyncEvent()
72 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in HandleAsyncEvent_() local
77 DoAsyncEvent_(loopHandle, asyncTask); in HandleAsyncEvent_()
78 if (!IsBufferEmpty(&asyncTask->stream)) { in HandleAsyncEvent_()
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/js/napi/app/js_app_manager/ |
| H A D | js_app_state_observer.cpp | 41 auto asyncTask = [jsObserver, appStateData, env = env_]() { in OnForegroundApplicationChanged() local
50 napi_status ret = napi_send_event(env_, asyncTask, napi_eprio_immediate); in OnForegroundApplicationChanged()
76 auto asyncTask = [jsObserver, abilityStateData, env = env_]() { in OnAbilityStateChanged() local
85 napi_status ret = napi_send_event(env_, asyncTask, napi_eprio_immediate); in OnAbilityStateChanged()
110 auto asyncTask = [jsObserver, abilityStateData, env = env_]() { in OnExtensionStateChanged() local
119 napi_status ret = napi_send_event(env_, asyncTask, napi_eprio_immediate); in OnExtensionStateChanged()
144 auto asyncTask = [jsObserver, processData, env = env_]() { in OnProcessCreated() local
178 auto asyncTask = [jsObserver, processData, env = env_]() { in OnProcessStateChanged() local
212 auto asyncTask = [jsObserver, processData, env = env_]() { in OnProcessDied() local
247 auto asyncTask = [jsObserver, appStateData, env = env_]() { in OnAppStarted() local
[all …]
|
| H A D | js_app_manager.cpp | 553 auto asyncTask = [appManager = appManager_, observer = observer_, observerId, in OnOffOld() local
558 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnOffOld()
662 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnGetForegroundApplications()
694 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnGetRunningProcessInformation()
789 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnGetRunningProcessInformationByBundleType()
816 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnIsRunningInStabilityTest()
873 auto asyncTask = [bundleName, clearPageStack, abilityManager = abilityManager_, in OnkillProcessesByBundleName() local
921 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnClearUpApplicationData()
969 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnClearUpAppData()
996 auto asyncTask = [missionId, env, task = napiAsyncTask.get()]() { in OnTerminateMission() local
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/js/napi/insight_intent/insight_intent_driver/ |
| H A D | js_insight_intent_driver.cpp | 62 std::unique_ptr<NapiAsyncTask> asyncTask = nullptr; in ProcessInsightIntentExecute() local
64 asyncTask = std::make_unique<NapiAsyncTask>(nativeDeferred_, nullptr, in ProcessInsightIntentExecute()
67 asyncTask = std::make_unique<NapiAsyncTask>(callbackRef_, nullptr, in ProcessInsightIntentExecute()
70 NapiAsyncTask::Schedule("JsInsightIntentDriver::OnExecute", env_, std::move(asyncTask)); in ProcessInsightIntentExecute()
118 std::unique_ptr<NapiAsyncTask> asyncTask = nullptr; in OnExecute() local
121 asyncTask = std::make_unique<NapiAsyncTask>(nativeDeferred, nullptr, nullptr); in OnExecute()
125 asyncTask = std::make_unique<NapiAsyncTask>(callbackRef, nullptr, nullptr); in OnExecute()
128 if (asyncTask == nullptr) { in OnExecute()
137 asyncTask->Reject(env, CreateJsError(env, GetJsErrorCodeByNativeError(err))); in OnExecute()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/src/dfx/ |
| H A D | multistages_capture_dfx_first_visit.cpp | 103 …shared_ptr<MediaLibraryAsyncTask> asyncTask = make_shared<MediaLibraryAsyncTask>(ReportInternal, t… in Report() local
104 if (asyncTask == nullptr) { in Report()
109 asyncWorker->AddTask(asyncTask, true); in Report()
|
| /ohos5.0/foundation/window/window_manager/interfaces/kits/napi/extension_window/ |
| H A D | js_extension_window.cpp | 340 auto asyncTask = [env, task = napiAsyncTask]() { in OnSetWindowKeepScreenOn() local
344 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnSetWindowKeepScreenOn()
360 auto asyncTask = [env, task = napiAsyncTask]() { in OnSetWindowBrightness() local
364 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnSetWindowBrightness()
385 auto asyncTask = [env, task = napiAsyncTask]() { in OnSetPreferredOrientation() local
389 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnSetPreferredOrientation()
405 auto asyncTask = [env, task = napiAsyncTask]() { in OnSetSpecificSystemBarEnabled() local
425 auto asyncTask = [env, task = napiAsyncTask]() { in OnResizeWindow() local
445 auto asyncTask = [env, task = napiAsyncTask]() { in OnMoveWindowTo() local
487 auto asyncTask = [extWindow = extensionWindow_, env, task = napiAsyncTask]() { in OnDestroyWindow() local
[all …]
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/src/ |
| H A D | multistages_video_capture_manager.cpp | 181 shared_ptr<MediaLibraryAsyncTask> asyncTask = in SyncWithDeferredVideoProcSession() local
183 if (asyncTask == nullptr) { in SyncWithDeferredVideoProcSession()
188 asyncWorker->AddTask(asyncTask, false); in SyncWithDeferredVideoProcSession()
|
| H A D | multistages_photo_capture_manager.cpp | 430 shared_ptr<MediaLibraryAsyncTask> asyncTask = in SyncWithDeferredProcSession() local
432 if (asyncTask == nullptr) { in SyncWithDeferredProcSession()
437 asyncWorker->AddTask(asyncTask, false); in SyncWithDeferredProcSession()
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/native/ability/native/ui_extension_ability/ |
| H A D | js_ui_extension_context.cpp | 251 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in CreateOpenLinkTask() local
258 asyncTask->Reject(env, CreateJsError(env, AbilityErrorCode::ERROR_CODE_INNER)); in CreateOpenLinkTask()
262 asyncTask->Reject(env, CreateJsErrorByNativeErr(env, resultCode)); in CreateOpenLinkTask()
265 asyncTask->ResolveWithNoError(env, abilityResult); in CreateOpenLinkTask()
430 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnStartAbilityForResult() local
436 asyncTask->Reject(env, CreateJsError(env, AbilityErrorCode::ERROR_CODE_INNER)); in OnStartAbilityForResult()
440 asyncTask->Reject(env, CreateJsErrorByNativeErr(env, resultCode)); in OnStartAbilityForResult()
443 asyncTask->Resolve(env, abilityResult); in OnStartAbilityForResult()
505 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnStartAbilityForResultAsCaller() local
515 asyncTask->Reject(env, CreateJsErrorByNativeErr(env, resultCode)); in OnStartAbilityForResultAsCaller()
[all …]
|
| H A D | js_ui_extension_content_session.cpp | 460 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnStartAbilityForResult() local
461 if (asyncTask == nullptr) { in OnStartAbilityForResult()
469 StartAbilityForResultRuntimeTask(env, want, asyncTask, unwrapArgc, startOptions); in OnStartAbilityForResult()
474 AAFwk::Want &want, std::shared_ptr<NapiAsyncTask> asyncTask, size_t& unwrapArgc, in StartAbilityForResultRuntimeTask() argument
477 if (asyncTask == nullptr) { in StartAbilityForResultRuntimeTask()
482 …RuntimeTask task = [env, asyncTask, element = want.GetElement(), flags = want.GetFlags(), startTim… in StartAbilityForResultRuntimeTask()
498 isInner ? asyncTask->Reject(env, CreateJsErrorByNativeErr(env, resultCode)) : in StartAbilityForResultRuntimeTask()
499 asyncTask->ResolveWithNoError(env, abilityResult); in StartAbilityForResultRuntimeTask()
505 asyncTask->Reject(env, CreateJsError(env, AbilityErrorCode::ERROR_CODE_INVALID_CONTEXT)); in StartAbilityForResultRuntimeTask()
|
| /ohos5.0/foundation/ability/form_fwk/frameworks/js/napi/form_host/ |
| H A D | js_form_host.cpp | 992 const std::shared_ptr<NapiAsyncTask> &asyncTask, in InnerAcquireFormState() argument
1029 std::shared_ptr<AbilityRuntime::NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnAcquireFormState() local
1037 asyncTask->ResolveWithNoError(env, objValue); in OnAcquireFormState()
1040 InnerAcquireFormState(env, asyncTask, std::move(task), want); in OnAcquireFormState()
1526 std::shared_ptr<AbilityRuntime::NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnShareForm() local
1528 ShareFormCallBackClient::ShareFormTask task = [env, asyncTask](int32_t code) { in OnShareForm()
1531 asyncTask->ResolveWithNoError(env, CreateJsUndefined(env)); in OnShareForm()
1537 InnerShareForm(env, asyncTask, std::move(task), formId, devicedId); in OnShareForm()
1565 std::shared_ptr<AbilityRuntime::NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnAcquireFormData() local
1572 asyncTask->ResolveWithNoError(env, objValue); in OnAcquireFormData()
[all …]
|
| /ohos5.0/foundation/multimedia/player_framework/frameworks/js/avplayer/ |
| H A D | avplayer_napi.h | 352 if (asyncTask != nullptr) {
353 …auto result = isTimeLimited ? asyncTask->GetResultWithTimeLimit(milliseconds) : asyncTask->GetResu…
359 std::shared_ptr<TaskHandler<TaskRet>> asyncTask = nullptr; member
|
| H A D | avplayer_napi.cpp | 285 promiseCtx->asyncTask = jsPlayer->PrepareTask(); in JsPrepare()
363 promiseCtx->asyncTask = jsPlayer->PlayTask(); in JsPlay()
436 promiseCtx->asyncTask = jsPlayer->PauseTask(); in JsPause()
508 promiseCtx->asyncTask = jsPlayer->StopTask(); in JsStop()
581 promiseCtx->asyncTask = jsPlayer->ResetTask(); in JsReset()
596 if (promiseCtx->asyncTask != nullptr) { in JsReset()
679 promiseCtx->asyncTask = jsPlayer->ReleaseTask(); in JsRelease()
692 if (promiseCtx->asyncTask != nullptr) { in JsRelease()
2412 if (promiseCtx->asyncTask) { in JsGetTrackDescription()
2625 auto result = promiseCtx->asyncTask->GetResult(); in JsGetCurrentTrack()
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/js/napi/ability_manager/ |
| H A D | js_ability_manager.cpp | 476 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnAcquireShareData() local
478 …AAFwk::ShareRuntimeTask task = [env, asyncTask](int32_t resultCode, const AAFwk::WantParams &wantP… in OnAcquireShareData()
480 asyncTask->Reject(env, CreateJsError(env, GetJsErrorCodeByNativeError(resultCode))); in OnAcquireShareData()
485 asyncTask->Reject(env, CreateJsError(env, AbilityErrorCode::ERROR_CODE_INNER)); in OnAcquireShareData()
487 asyncTask->ResolveWithNoError(env, abilityResult); in OnAcquireShareData()
496 asyncTask->Reject(env, CreateJsError(env, GetJsErrorCodeByNativeError(err))); in OnAcquireShareData()
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/js/napi/feature_ability/ |
| H A D | js_feature_ability.cpp | 147 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnStartAbilityForResult() local
148 FeatureAbilityTask task = [env, asyncTask](int resultCode, const AAFwk::Want& want) { in OnStartAbilityForResult()
154 asyncTask->Reject(env, CreateJsError(env, 1, "failed to get result data!")); in OnStartAbilityForResult()
156 asyncTask->Resolve(env, abilityResult); in OnStartAbilityForResult()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | background_cloud_file_processor.cpp | 216 auto asyncTask = std::make_shared<MediaLibraryAsyncTask>(DownloadCloudFilesExecutor, taskData); in AddDownloadTask() local
217 asyncWorker->AddTask(asyncTask, false); in AddDownloadTask()
390 auto asyncTask = std::make_shared<MediaLibraryAsyncTask>(UpdateCloudDataExecutor, taskData); in AddUpdateDataTask() local
391 asyncWorker->AddTask(asyncTask, false); in AddUpdateDataTask()
|
| H A D | picture_data_operations.cpp | 318 auto asyncTask = std::make_shared<MediaLibraryAsyncTask>(SavePictureExecutor, taskData); in AddSavePictureTask() local
319 asyncWorker->AddTask(asyncTask, true); in AddSavePictureTask()
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/native/ability/native/ability_runtime/ |
| H A D | js_ability_context.cpp | 724 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in CreateOpenLinkTask() local
734 isInner ? asyncTask->Reject(env, CreateJsErrorByNativeErr(env, resultCode)) : in CreateOpenLinkTask()
735 asyncTask->ResolveWithNoError(env, abilityResult); in CreateOpenLinkTask()
1109 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnStartAbilityForResult() local
1129 isInner ? asyncTask->Reject(env, CreateJsErrorByNativeErr(env, resultCode)) : in OnStartAbilityForResult()
1130 asyncTask->Resolve(env, abilityResult); in OnStartAbilityForResult()
1194 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnStartAbilityForResultWithAccount() local
1215 asyncTask->Resolve(env, abilityResult); in OnStartAbilityForResultWithAccount()
1723 std::shared_ptr<NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnRequestDialogService() local
1725 [env, asyncTask](int32_t resultCode, const AAFwk::Want &resultWant) { in OnRequestDialogService()
[all …]
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/jsview/ |
| H A D | js_nav_path_stack.cpp | 208 auto asyncTask = [asyncContext, weakStack = WeakClaim(this)]() { in OnPushDestination() local
219 … context->PostAsyncEvent(asyncTask, "ArkUINavigationPushDestination", TaskExecutor::TaskType::JS); in OnPushDestination()
|
| /ohos5.0/foundation/window/window_manager/window_scene/interfaces/kits/napi/screen_session_manager/ |
| H A D | js_screen_session.cpp | 563 …auto asyncTask = [jsCallbackRef, callbackType, screenSessionWeak, event, eventStatus, reason, env … in OnPowerStatusChange() local
587 napi_status ret = napi_send_event(env_, asyncTask, napi_eprio_vip); in OnPowerStatusChange()
677 auto asyncTask = [jsCallbackRef, callbackType, mainScreenId, uid, clientName, env = env_]() { in OnScreenCaptureNotify() local
695 napi_status ret = napi_send_event(env_, asyncTask, napi_eprio_immediate); in OnScreenCaptureNotify()
|
| /ohos5.0/foundation/window/window_manager/interfaces/kits/napi/window_runtime/window_stage_napi/ |
| H A D | js_window_stage.cpp | 587 auto asyncTask = [where, weakWindow = wptr(window), isModal, env, task = napiAsyncTask] { in OnSetWindowModal() local
605 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnSetWindowModal()
847 auto asyncTask = [weakWindow = wptr(window), where, env, task = napiAsyncTask, enabled] { in OnSetWindowRectAutoSave() local
864 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnSetWindowRectAutoSave()
884 auto asyncTask = [weakWindow = wptr(window), where, env, task = napiAsyncTask] { in OnIsWindowRectAutoSave() local
903 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnIsWindowRectAutoSave()
|
| /ohos5.0/foundation/window/window_manager/interfaces/kits/napi/picture_in_picture_napi/ |
| H A D | js_pip_window_manager.cpp | 228 auto asyncTask = [this, env, task = napiAsyncTask, pipOption]() { in NapiSendTask() local
251 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_immediate)) { in NapiSendTask()
|
| /ohos5.0/foundation/ability/form_fwk/frameworks/js/napi/formHost/ |
| H A D | napi_form_host.cpp | 1069 std::shared_ptr<AbilityRuntime::NapiAsyncTask> asyncTask = std::move(uasyncTask); in OnShareForm() local
1071 ShareFormTask task = [env, asyncTask](int32_t code) { in OnShareForm()
1074 asyncTask->Resolve(env, CreateJsUndefined(env)); in OnShareForm()
1078 asyncTask->Reject(env, AbilityRuntime::CreateJsError(env, retCode, retMsg)); in OnShareForm()
1083 asyncTask->Reject(env, AbilityRuntime::CreateJsError(env, errCode, "Invalidate params.")); in OnShareForm()
1085 InnerShareForm(env, asyncTask, std::move(task), formId, remoteDeviceId); in OnShareForm()
1545 const std::shared_ptr<AbilityRuntime::NapiAsyncTask> &asyncTask, in InnerShareForm() argument
1560 asyncTask->Reject(env, AbilityRuntime::CreateJsError(env, retCode, retMsg)); in InnerShareForm()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/ |
| H A D | enhancement_manager.cpp | 163 …shared_ptr<MediaLibraryAsyncTask> asyncTask = make_shared<MediaLibraryAsyncTask>(InitCloudEnhancem… in InitAsync() local
165 if (asyncTask == nullptr) { in InitAsync()
170 asyncWorker->AddTask(asyncTask, false); in InitAsync()
|
| /ohos5.0/foundation/window/window_manager/interfaces/kits/napi/window_runtime/window_napi/ |
| H A D | js_window.cpp | 1454 auto asyncTask = [windowToken = wptr<Window>(windowToken_), errCode, x, y, in OnMoveTo() local
1476 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnMoveTo()
1512 auto asyncTask = [windowToken = wptr<Window>(windowToken_), x, y, in OnMoveWindowTo() local
1529 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnMoveWindowTo()
1756 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnResize()
1796 auto asyncTask = [windowToken = wptr<Window>(windowToken_), width, height, in OnResizeWindow() local
1814 if (napi_status::napi_ok != napi_send_event(env, asyncTask, napi_eprio_high)) { in OnResizeWindow()
1997 auto asyncTask = [windowToken = wptr<Window>(windowToken_), winMode, in OnSetWindowMode() local
2641 auto asyncTask = [weakToken = wptr<Window>(windowToken_), isTitleHoverShown, in OnSetTitleAndDockHoverShown() local
2716 auto asyncTask = CreateAsyncTask(env, lastParam, nullptr, in OnSetWindowLayoutFullScreen() local
[all …]
|