| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| D | test_worker.cpp | 87 Worker *worker = static_cast<Worker*>(req->data); in WorkerOnMessage() local
119 Worker *worker = static_cast<Worker*>(req->data); in HostOnMessage() local
140 auto worker = reinterpret_cast<Worker*>(data); in WorkerThreadFunction() local
156 static void UpdateMainThreadWorkerFlag(Worker *worker, bool isMainThreadWorker) in UpdateMainThreadWorkerFlag()
161 static void InitHostHandle(Worker *worker, uv_loop_t *loop) in InitHostHandle()
168 static void PostMessage(Worker *worker, void *message) in PostMessage()
173 static void UpdateWorkerState(Worker *worker, Worker::RunnerState state) in UpdateWorkerState()
182 static void SetCloseWorkerProp(Worker *worker, napi_env env) in SetCloseWorkerProp()
256 Worker* worker = nullptr; variable
278 Worker* worker = nullptr; variable
[all …]
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | worker.cpp | 34 Worker::PriorityScope::PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker) in PriorityScope()
64 Worker* worker = new Worker(env); in WorkerConstructor() local
71 auto worker = static_cast<Worker*>(req->data); in ReleaseWorkerHandles() local
137 Worker* worker = reinterpret_cast<Worker*>(req->data); in HandleDebuggerTask() local
209 auto worker = reinterpret_cast<Worker*>(const_cast<void*>(data)); in ExecuteInThread() local
338 auto worker = reinterpret_cast<Worker*>(req->data); in TriggerGCCheck() local
372 auto worker = static_cast<Worker*>(req->data); in PerformTask() local
472 Worker* worker = reinterpret_cast<Worker*>(task->worker_); in NotifyHandleTaskResult() local
508 auto worker = static_cast<Worker*>(task->worker_); in TaskResultCallback() local
|
| D | task_manager.cpp | 98 for (auto& worker : workers_) { in ~TaskManager() local
145 for (auto& worker : workers_) { in GetThreadInfos() local
246 auto worker = *iter; in CheckForBlockedWorkers() local
329 for (auto& worker : idleWorkers_) { in GetIdleWorkers() local
361 for (auto& worker : idleWorkers_) { in GetIdleWorkersList() local
409 auto worker = freeList_[i]; in TriggerShrink() local
437 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker *worker) { in TriggerShrink()
443 auto worker = *iter; in TriggerShrink() local
482 auto worker = *(idleWorkers_.begin()); in NotifyShrink() local
669 void TaskManager::NotifyWorkerIdle(Worker* worker) in NotifyWorkerIdle()
[all …]
|
| D | worker.h | 136 explicit RunningScope(Worker* worker) : worker_(worker) in RunningScope()
|
| D | task.h | 230 Worker* worker; member
|
| D | task.cpp | 1111 bool Task::UpdateTask(uint64_t startTime, void* worker) in UpdateTask()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker.cpp | 110 Worker* worker = nullptr; in InitPort() local
236 Worker* worker = nullptr; in Constructor() local
312 Worker* worker = static_cast<Worker*>(data); in WorkerDestructor() local
342 Worker* worker = static_cast<Worker*>(data); in HostEnvCleanCallback() local
440 Worker* worker = nullptr; in CommonPostMessage() local
477 Worker* worker = nullptr; in Terminate() local
530 Worker* worker = nullptr; in RegisterGlobalCallObject() local
554 Worker* worker = nullptr; in UnregisterGlobalCallObject() local
617 Worker* worker = nullptr; in AddListener() local
662 Worker* worker = nullptr; in RemoveListener() local
[all …]
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test.cpp | 197 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in CheckForBlockedWorkers() local
235 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TriggerShrink() local
311 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TryExpand() local
367 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyWorkerIdle() local
390 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in EnqueueTaskId() local
422 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in RestoreWorker() local
479 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyDependencyTaskInfo() local
741 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in ReleaseWorkerHandles() local
761 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in DebuggerOnPostTask() local
797 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in PerformTask() local
[all …]
|
| D | test_taskpool.cpp | 136 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
152 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
533 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
974 auto worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
1003 auto worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
2052 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
2080 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
2114 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
2158 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
3947 Worker* worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); variable
[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 | 98 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 | 1039 napi_async_work worker = nullptr; member
|