Home
last modified time | relevance | path

Searched refs:workerEngine (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dworker.cpp100 if (workerEngine->HasListeningCounter()) { in CheckFreeConditions()
106 } else if (workerEngine->HasSubEnv()) { in CheckFreeConditions()
110 } else if (workerEngine->IsProfiling()) { in CheckFreeConditions()
218 workerEngine->MarkTaskPoolThread(); in ExecuteInThread()
266 if (!workerEngine->CallInitWorkerFunc(workerEngine)) { in PrepareForWorkerInstance()
285 if (workerEngine == nullptr) { in ReleaseWorkerThreadContent()
302 if (!workerEngine->CallOffWorkerFunc(workerEngine)) { in ReleaseWorkerThreadContent()
305 delete workerEngine; in ReleaseWorkerThreadContent()
329 workerEngine->NotifyTaskBegin(); in NotifyTaskBegin()
340 workerEngine->NotifyTaskFinished(); in TriggerGCCheck()
[all …]
H A Dtaskpool.h86 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in ~CallbackScope() local
87 workerEngine->DecreaseListeningCounter(); in ~CallbackScope()
H A Dtask_manager.cpp258 auto workerEngine = reinterpret_cast<NativeEngine*>(worker->workerEnv_); in CheckForBlockedWorkers() local
259 if (worker->idleState_ && !workerEngine->IsExecutingPendingJob()) { in CheckForBlockedWorkers()
260 if (!workerEngine->HasWaitingRequest()) { in CheckForBlockedWorkers()
1000 auto workerEngine = reinterpret_cast<NativeEngine*>(env); in NotifyCallbackExecute() local
1001 workerEngine->IncreaseListeningCounter(); in NotifyCallbackExecute()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp1236 NativeEngine* workerEngine = reinterpret_cast<NativeEngine*>(workerEnv); variable
1237 workerEngine->MarkRestrictedWorkerThread();
1282 NativeEngine* workerEngine = reinterpret_cast<NativeEngine*>(workerEnv); variable
1283 workerEngine->MarkTaskPoolThread();
1328 NativeEngine* workerEngine = reinterpret_cast<NativeEngine*>(workerEnv); variable
1329 workerEngine->MarkWorkerThread();
1375 NativeEngine* workerEngine = reinterpret_cast<NativeEngine*>(workerEnv); variable
1376 workerEngine->MarkRestrictedWorkerThread();
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.cpp1377 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in PrepareForWorkerInstance() local
1381 workerEngine->SetDebuggerPostTaskFunc([this](std::function<void()>&& task) { in PrepareForWorkerInstance()
1385 if (!hostEngine->CallInitWorkerFunc(workerEngine)) { in PrepareForWorkerInstance()
2279 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in ReleaseWorkerThreadContent() local
2280 if (hostEngine != nullptr && workerEngine != nullptr) { in ReleaseWorkerThreadContent()
2281 if (!hostEngine->DeleteWorker(workerEngine)) { in ReleaseWorkerThreadContent()
/ohos5.0/foundation/arkui/napi/native_engine/impl/ark/
H A Dark_native_engine.h249 bool DeleteWorker(NativeEngine* workerEngine) override;
H A Dark_native_engine.cpp2029 bool ArkNativeEngine::DeleteWorker(NativeEngine* workerEngine) in DeleteWorker() argument
2031 if (workerEngine != nullptr) { in DeleteWorker()
2033 …const panda::ecmascript::EcmaVM* workerVM = reinterpret_cast<ArkNativeEngine*>(workerEngine)->GetE… in DeleteWorker()
/ohos5.0/foundation/arkui/napi/native_engine/
H A Dnative_engine.h202 virtual bool DeleteWorker(NativeEngine* workerEngine) = 0;
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp745 NativeEngine* workerEngine = reinterpret_cast<NativeEngine*>(workerEnv); in ReleaseWorkerHandles() local