| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| D | test_worker.cpp | 90 Worker* worker = nullptr; variable
112 Worker* worker = nullptr; variable
163 Worker* worker = nullptr; variable
193 Worker* worker = nullptr; variable
270 Worker* worker = nullptr; variable
295 Worker* worker = nullptr; variable
345 Worker* worker = nullptr; variable
379 Worker* worker = nullptr; variable
425 Worker* worker = nullptr; variable
468 Worker* worker = nullptr; variable
[all …]
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker_new.cpp | 63 NewWorker* worker = nullptr; in InitWorker() local
120 NewWorker* worker = nullptr; in WorkerConstructor() local
196 NewWorker* worker = reinterpret_cast<NewWorker*>(data); in WorkerConstructor() local
245 NewWorker* worker = nullptr; in PostMessage() local
279 NewWorker* worker = nullptr; in Terminate() local
340 NewWorker* worker = nullptr; in AddListener() local
382 NewWorker* worker = nullptr; in RemoveListener() local
440 NewWorker* worker = nullptr; in DispatchEvent() local
478 NewWorker* worker = nullptr; in RemoveAllListener() local
493 NewWorker* worker = nullptr; in CancelTask() local
[all …]
|
| D | worker.cpp | 83 Worker* worker = nullptr; in CloseWorker() local
190 auto worker = reinterpret_cast<Worker*>(const_cast<void*>(data)); in ExecuteInThread() local
248 Worker* worker = static_cast<Worker*>(req->data); in HostOnMessage() local
294 Worker* worker = static_cast<Worker*>(req->data); in HostOnError() local
306 Worker* worker = DereferenceHelp::DereferenceOf(&Worker::debuggerOnPostTaskSignal_, req); in HandleDebuggerTask() local
331 Worker* worker = static_cast<Worker*>(req->data); in WorkerOnMessage() local
597 Worker* worker = nullptr; in PostMessage() local
639 Worker* worker = nullptr; in PostMessageToHost() local
701 Worker* worker = nullptr; in Terminate() local
739 Worker* worker = nullptr; in CancelTask() local
[all …]
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | worker.cpp | 47 Worker* worker = new Worker(env); in WorkerConstructor() local
55 auto worker = static_cast<Worker*>(req->data); in ReleaseWorkerHandles() local
101 Worker* worker = reinterpret_cast<Worker*>(req->data); in HandleDebuggerTask() local
121 auto worker = reinterpret_cast<Worker*>(const_cast<void*>(data)); in ExecuteInThread() local
249 auto worker = static_cast<Worker*>(req->data); in PerformTask() local
368 Worker* worker = reinterpret_cast<Worker*>(taskInfo->worker); in NotifyTaskResult() local
|
| D | worker.h | 97 RunningScope(Worker* worker, napi_status& status) : worker_(worker) in RunningScope()
114 PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker) in PriorityScope()
|
| D | task_manager.cpp | 85 for (auto& worker : workers_) { in ~TaskManager() local
107 for (auto& worker : workers_) { in GetThreadInfos() local
159 Worker* worker = reinterpret_cast<Worker*>(taskInfo->worker); in GetTaskInfos() local
209 auto worker = *iter; in CheckForBlockedWorkers() local
255 … auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [this](Worker *worker) { in CreateOrDeleteWorkers()
269 auto worker = *iter; in CreateOrDeleteWorkers() local
594 void TaskManager::NotifyWorkerIdle(Worker* worker) in NotifyWorkerIdle()
605 void TaskManager::NotifyWorkerCreated(Worker* worker) in NotifyWorkerCreated()
611 void TaskManager::NotifyWorkerAdded(Worker* worker) in NotifyWorkerAdded()
634 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) { in GetRunningWorkers()
[all …]
|
| D | task.h | 57 void* worker = nullptr; member
|
| /commonlibrary/ets_utils/js_sys_module/process/ |
| D | js_childprocess.h | 26 napi_async_work worker = nullptr; member
32 napi_async_work worker = nullptr; member
43 napi_async_work worker = nullptr; member
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | timer_test.rs | 80 let worker = manager.map.get(&i).unwrap(); in simulate() localVariable
84 let worker = worker.clone(); in simulate() localVariable
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| D | js_base64.h | 33 napi_async_work worker = nullptr; member
44 napi_async_work worker = nullptr; member
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| D | multi_thread_builder.rs | 93 let worker = match num { in max_worker_num_by_qos() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test_taskpool.cpp | 42 Worker* worker = Worker::WorkerConstructor(env); variable
73 Worker* worker = Worker::WorkerConstructor(env); variable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | worker.rs | 33 pub(crate) worker: Arc<Worker>, field
|
| D | async_pool.rs | 533 let worker = vec.get(i).expect("worker index out of range"); in get_worker() localVariable
|
| /commonlibrary/ets_utils/js_api_module/buffer/ |
| D | native_module_buffer.cpp | 946 napi_async_work worker = nullptr; member
|