Home
last modified time | relevance | path

Searched refs:workerEnv_ (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dworker.cpp55 napi_close_handle_scope(worker_->workerEnv_, scope_); in ~RunningScope()
98 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in CheckFreeConditions()
102 } else if (Timer::HasTimer(workerEnv_)) { in CheckFreeConditions()
211 napi_create_runtime(worker->hostEnv_, &worker->workerEnv_); in ExecuteInThread()
212 if (worker->workerEnv_ == nullptr) { in ExecuteInThread()
260 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in PrepareForWorkerInstance()
271 Timer::RegisterTime(workerEnv_); in PrepareForWorkerInstance()
274 if (NapiHelper::IsExceptionPending(workerEnv_)) { in PrepareForWorkerInstance()
300 Timer::ClearEnvironmentTimer(workerEnv_); in ReleaseWorkerThreadContent()
306 workerEnv_ = nullptr; in ReleaseWorkerThreadContent()
[all …]
H A Dtaskpool.h78 workerEnv_(workerEnv), taskId_(taskId) in CallbackScope()
85 if (workerEnv_ != nullptr) { in ~CallbackScope()
86 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in ~CallbackScope()
96 napi_env workerEnv_; variable
H A Dworker.h115 if (workerEnv_ != nullptr) { in GetWorkerLoop()
116 return NapiHelper::GetLibUV(workerEnv_); in GetWorkerLoop()
138 napi_open_handle_scope(worker_->workerEnv_, &scope_); in RunningScope()
192 napi_env workerEnv_ {nullptr};
H A Dtask_manager.cpp146 if (worker->workerEnv_ == nullptr) { in GetThreadInfos()
258 auto workerEngine = reinterpret_cast<NativeEngine*>(worker->workerEnv_); in CheckForBlockedWorkers()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.h428 if (workerEnv_ != nullptr) { in GetWorkerLoop()
429 return NapiHelper::GetLibUV(workerEnv_); in GetWorkerLoop()
436 workerEnv_ = workerEnv; in SetWorkerEnv()
438 workerEnvCallback_(workerEnv_); in SetWorkerEnv()
468 return workerEnv_ == env; in IsSameWorkerEnv()
484 if (workerEnv_ != nullptr) { in RegisterCallbackForWorkerEnv()
485 workerEnvCallback_(workerEnv_); in RegisterCallbackForWorkerEnv()
491 return workerEnv_; in GetWorkerEnv()
597 napi_env workerEnv_ {nullptr};
H A Dworker.cpp1399 Timer::RegisterTime(workerEnv_); in PrepareForWorkerInstance()
1866 Timer::ClearEnvironmentTimer(workerEnv_); in TerminateWorker()
2010 napi_create_object(workerEnv_, &event); in WorkerOnMessageInner()
2018 napi_close_handle_scope(workerEnv_, scope); in WorkerOnMessageInner()
2060 if (!NapiHelper::IsExceptionPending(workerEnv_)) { in HandleException()
2065 HandleScope scope(workerEnv_, status); in HandleException()
2066 NAPI_CALL_RETURN_VOID(workerEnv_, status); in HandleException()
2235 if (workerEnv_ == nullptr) { in CallWorkerFunction()
2296 workerMessageQueue_.Clear(workerEnv_); in ReleaseWorkerThreadContent()
2297 workerGlobalCallQueue_.Clear(workerEnv_); in ReleaseWorkerThreadContent()
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp198 worker->workerEnv_ = nullptr; in CheckForBlockedWorkers()
204 worker->workerEnv_ = env; in CheckForBlockedWorkers()
236 worker->workerEnv_ = env; in TriggerShrink()
273 worker1->workerEnv_ = env; in NotifyShrink()
274 worker2->workerEnv_ = env; in NotifyShrink()
312 worker->workerEnv_ = env; in TryExpand()
368 worker->workerEnv_ = env; in NotifyWorkerIdle()
431 worker->workerEnv_ = env; in RestoreWorker()
480 worker->workerEnv_ = env; in NotifyDependencyTaskInfo()
744 worker->workerEnv_ = workerEnv; in ReleaseWorkerHandles()
[all …]