| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| D | test_worker.cpp | 190 Worker *worker = static_cast<Worker*>(req->data); in WorkerOnMessage() local
222 Worker *worker = static_cast<Worker*>(req->data); in HostOnMessage() local
243 auto worker = reinterpret_cast<Worker*>(data); in WorkerThreadFunction() local
259 static void UpdateMainThreadWorkerFlag(Worker *worker, bool isMainThreadWorker) in UpdateMainThreadWorkerFlag()
264 static void InitHostHandle(Worker *worker, uv_loop_t *loop) in InitHostHandle()
271 static void PostMessage(Worker *worker, void *message) in PostMessage()
276 static void UpdateWorkerState(Worker *worker, Worker::RunnerState state) in UpdateWorkerState()
285 static void SetCloseWorkerProp(Worker *worker, napi_env env) in SetCloseWorkerProp()
300 static void SetWorkerRef(Worker *worker, napi_env env) in SetWorkerRef()
314 static void SetWorkerHostEnv(Worker *worker, napi_env env, bool setNull) in SetWorkerHostEnv()
[all …]
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_manager.cpp | 109 for (auto& worker : workers_) { in ~TaskManager() local
162 for (auto& worker : workers_) { in GetThreadInfos() local
278 auto worker = *iter; in CheckForBlockedWorkers() local
361 for (auto& worker : idleWorkers_) { in GetIdleWorkers() local
393 for (auto& worker : idleWorkers_) { in GetIdleWorkersList() local
439 auto worker = freeList_[i]; in TriggerShrink() local
467 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker* worker) { in TriggerShrink()
473 auto worker = *iter; in TriggerShrink() local
499 auto worker = *iter; in NotifyShrink() local
515 auto worker = *(idleWorkers_.begin()); in NotifyShrink() local
[all …]
|
| D | worker.cpp | 37 Worker::PriorityScope::PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker) in PriorityScope()
67 Worker* worker = new Worker(env); in WorkerConstructor() local
85 auto worker = static_cast<Worker*>(req->data); in ReleaseWorkerHandles() local
147 Worker* worker = reinterpret_cast<Worker*>(req->data); in HandleDebuggerTask() local
219 auto worker = reinterpret_cast<Worker*>(const_cast<void*>(data)); in ExecuteInThread() local
386 auto worker = reinterpret_cast<Worker*>(req->data); in TriggerGCCheck() local
418 auto worker = static_cast<Worker*>(req->data); in PerformTask() local
528 Worker* worker = reinterpret_cast<Worker*>(task->GetWorker()); in NotifyHandleTaskResult() local
566 auto worker = static_cast<Worker*>(task->worker_); in TaskResultCallback() local
|
| D | worker.h | 136 explicit RunningScope(Worker* worker) : worker_(worker) in RunningScope()
|
| D | task.cpp | 1147 bool Task::UpdateTask(uint64_t startTime, void* worker) in UpdateTask()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test.cpp | 200 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in CheckForBlockedWorkers() local
238 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TriggerShrink() local
314 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TryExpand() local
366 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyWorkerIdle() local
388 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in EnqueueTaskId() local
419 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in RestoreWorker() local
476 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyDependencyTaskInfo() local
736 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in ReleaseWorkerHandles() local
756 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in DebuggerOnPostTask() local
792 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in PerformTask() local
[all …]
|
| D | test_taskpool.cpp | 146 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
162 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
419 auto worker = static_cast<Worker*>(WorkerConstructor(env)); variable
434 auto worker = static_cast<Worker*>(WorkerConstructor(env)); variable
543 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
977 auto worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
991 auto worker = Worker::WorkerConstructor(env); variable
1010 auto worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
2059 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
2093 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
[all …]
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker.cpp | 154 Worker* worker = nullptr; in InitPort() local
279 Worker* worker = nullptr; in Constructor() local
371 Worker* worker = static_cast<Worker*>(data); in WorkerDestructor() local
405 Worker* worker = static_cast<Worker*>(data); in WorkerHostEnvCleanCallback() local
431 void Worker::HostEnvCleanCallbackInner(Worker* worker) in HostEnvCleanCallbackInner()
582 Worker* worker = nullptr; in CommonPostMessage() local
626 Worker* worker = nullptr; in Terminate() local
677 Worker* worker = nullptr; in RegisterGlobalCallObject() local
700 Worker* worker = nullptr; in UnregisterGlobalCallObject() local
760 Worker* worker = nullptr; in AddListener() local
[all …]
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| D | js_base64.h | 43 napi_async_work worker = nullptr; member
55 napi_async_work worker = nullptr; member
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| D | multi_thread_builder.rs | 94 let worker = match num { in max_worker_num_by_qos() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | worker.rs | 32 pub(crate) worker: Arc<Worker>, field
|
| /commonlibrary/ets_utils/js_api_module/buffer/ |
| D | native_module_buffer.cpp | 1048 napi_async_work worker = nullptr; member
|