Searched refs:workerEnv_ (Results 1 - 8 of 8) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.cpp | 55 napi_close_handle_scope(worker_->workerEnv_, scope_);
in ~RunningScope()
107 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_);
in CheckFreeConditions()
113 } else if (Timer::HasTimer(workerEnv_)) {
in CheckFreeConditions()
223 napi_create_runtime(worker->hostEnv_, &worker->workerEnv_);
in ExecuteInThread()
224 if (worker->workerEnv_ == nullptr) {
in ExecuteInThread()
228 auto workerEngine = reinterpret_cast<NativeEngine*>(worker->workerEnv_);
in ExecuteInThread()
231 workerEngine->InitTaskPoolThread(worker->workerEnv_, Worker::TaskResultCallback);
in ExecuteInThread()
272 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_);
in PrepareForWorkerInstance()
283 Timer::RegisterTime(workerEnv_);
in PrepareForWorkerInstance()
286 if (NapiHelper::IsExceptionPending(workerEnv_)) {
in PrepareForWorkerInstance()
[all...] |
| H A D | taskpool.h | 78 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_;
member in Commonlibrary::Concurrent::TaskPoolModule::CallbackScope
|
| H A D | worker.h | 120 if (workerEnv_ != nullptr) {
in GetWorkerLoop()
121 return NapiHelper::GetLibUV(workerEnv_);
in GetWorkerLoop()
143 napi_open_handle_scope(worker_->workerEnv_, &scope_);
in RunningScope()
199 napi_env workerEnv_ {nullptr};
|
| H A D | task_manager.cpp | 146 if (worker->workerEnv_ == nullptr) { in GetThreadInfos()
258 auto workerEngine = reinterpret_cast<NativeEngine*>(worker->workerEnv_); in CheckForBlockedWorkers()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | worker.h | 416 if (workerEnv_ != nullptr) { in GetWorkerLoop()
417 return NapiHelper::GetLibUV(workerEnv_); in GetWorkerLoop()
424 workerEnv_ = workerEnv; in SetWorkerEnv()
426 workerEnvCallback_(workerEnv_); in SetWorkerEnv()
456 return workerEnv_ == env; in IsSameWorkerEnv()
472 if (workerEnv_ != nullptr) { in RegisterCallbackForWorkerEnv()
473 workerEnvCallback_(workerEnv_); in RegisterCallbackForWorkerEnv()
479 return workerEnv_; in GetWorkerEnv()
583 napi_env workerEnv_ {nullptr};
|
| H A D | worker.cpp | 1351 auto workerEngine = reinterpret_cast<NativeEngine*>(workerEnv_); in PrepareForWorkerInstance()
1373 Timer::RegisterTime(workerEnv_); in PrepareForWorkerInstance()
1376 napi_status status = napi_run_actor(workerEnv_, scriptContent, scriptContentSize, in PrepareForWorkerInstance()
1388 napi_create_string_utf8(workerEnv_, name_.c_str(), name_.length(), &nameValue); in PrepareForWorkerInstance()
1389 NapiHelper::SetNamePropertyInGlobal(workerEnv_, "name", nameValue); in PrepareForWorkerInstance()
1833 Timer::ClearEnvironmentTimer(workerEnv_); in TerminateWorker()
1940 status = napi_open_handle_scope(workerEnv_, &scope); in WorkerOnMessageInner()
1950 napi_close_handle_scope(workerEnv_, scope); in WorkerOnMessageInner()
1955 status = napi_deserialize(workerEnv_, data, &result); in WorkerOnMessageInner()
1956 napi_delete_serialization_data(workerEnv_, dat in WorkerOnMessageInner()
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 198 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()
743 worker->workerEnv_ in ReleaseWorkerHandles()
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| H A D | test_worker.cpp | 256 worker->workerEnv_ = workerEnv; in RemoveGlobalCallObject()
652 worker->workerEnv_ = nullptr; in TestWorkerOnMessageInner()
656 worker->workerEnv_ = workerEnv; in TestWorkerOnMessageInner()
710 worker->workerEnv_ = workerEnv; in HandleHostException()
785 worker->workerEnv_ = workerEnv; in RemoveListenerInner()
|
Completed in 18 milliseconds