| /arkcompiler/runtime_core/static_core/libpandabase/taskmanager/ |
| D | task_scheduler.cpp | 46 auto *worker = workers_[i].load(std::memory_order_relaxed); in StealTaskFromOtherWorker() local
71 bool TaskScheduler::FillWithTasks(WorkerThread *worker) in FillWithTasks()
112 bool TaskScheduler::WaitUntilNewTasks(WorkerThread *worker) in WaitUntilNewTasks()
127 size_t TaskScheduler::PutTasksInWorker(WorkerThread *worker, internal::SchedulableTaskQueueInterfac… in PutTasksInWorker()
158 auto *worker = workers_[i].load(std::memory_order_relaxed); in AreWorkersEmpty() local
212 auto *worker = workers_[i].load(std::memory_order_relaxed); in SetCountOfWorkers() local
218 for (auto *worker : workersToWait) { in SetCountOfWorkers() local
222 for (auto *worker : workersToWait) { in SetCountOfWorkers() local
236 for (auto *worker : workersToDelete_) { in ~TaskScheduler() local
|
| /arkcompiler/runtime_core/static_core/runtime/coroutines/ |
| D | stackful_coroutine_manager.cpp | 114 auto finWorkerIt = std::find_if(workers_.begin(), workers_.end(), [](auto &&worker) { in ChooseWorkerForFinalization()
147 …auto *worker = allocator->New<StackfulCoroutineWorker>(runtime, vm, this, wType, std::move(workerN… in CreateWorker() local
155 void StackfulCoroutineManager::OnWorkerShutdown(StackfulCoroutineWorker *worker) in OnWorkerShutdown()
175 void StackfulCoroutineManager::OnWorkerStartup(StackfulCoroutineWorker *worker) in OnWorkerStartup()
181 void StackfulCoroutineManager::OnWorkerStartupImpl(StackfulCoroutineWorker *worker) in OnWorkerStartupImpl()
774 for (auto *worker : workers_) { in MainCoroutineCompleted() local
835 auto *worker = co->GetContext<StackfulCoroutineContext>()->GetWorker(); in IsMainWorker() local
916 auto *worker = GetCurrentWorker(); in OnNativeCallExit() local
1132 auto *worker = GetCurrentWorker(); in TriggerMigration() local
|
| D | stackful_coroutine_worker.cpp | 281 void StackfulCoroutineWorker::ScheduleLoopProxy(void *worker) in ScheduleLoopProxy()
|
| D | threaded_coroutine_manager.cpp | 465 for (auto *worker : workers_) { in MainCoroutineCompleted() local
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| D | ets_coroutine.cpp | 248 auto *worker = GetWorker(); in GetExternalIfaceTable() local
259 auto *worker = GetWorker(); in OnHostWorkerChanged() local
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| D | thread_pool.h | 325 for (auto worker : workers_) { in WaitForWorkers() local
360 auto worker = allocator_->New<std::thread>(WorkerEntry, this, proc, i); in CreateNewThread() local
|
| /arkcompiler/runtime_core/static_core/plugins/ets/tests/native/exclusive_worker/ |
| D | exclusive_worker_tests.cpp | 53 std::thread worker([this, &event, routineName, routineSignature, in RunRoutineInExclusiveWorker() local
113 std::thread worker([this, &event, routineName, routineSignature, in UseAfterDetach() local
129 std::thread worker([this, &event, routineName, routineSignature, in AttachSameThread() local
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/g1/ |
| D | update_remset_worker.h | 222 …explicit SuspendUpdateRemsetWorkerScope(UpdateRemsetWorker<LanguageConfig> *worker) : worker_(work… in SuspendUpdateRemsetWorkerScope()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/intrinsics/ |
| D | std_core_ExclusiveLauncher.cpp | 119 auto *worker = coro->GetWorker(); in ExclusiveLaunch() local
|
| /arkcompiler/runtime_core/static_core/dprof/daemon/ |
| D | main.cpp | 253 Worker worker; in Main() local
|
| /arkcompiler/runtime_core/static_core/verification/verifier/ |
| D | verifier.cpp | 296 …auto *worker = runtime.GetInternalAllocator()->New<std::thread>(Worker, &queue, &lock, i, &result); in RunVerifier() local
|
| /arkcompiler/ets_frontend/ets2panda/driver/build_system/src/build/ |
| D | base_mode.ts | 889 const worker = cluster.fork(); constant
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/interop_js/ |
| D | interop_context.h | 522 static InteropCtx *Current(CoroutineWorker *worker) in Current()
|
| D | interop_context.cpp | 761 auto *worker = coro->GetWorker(); in Init() local
|
| /arkcompiler/runtime_core/static_core/runtime/tests/ |
| D | region_allocator_test.cpp | 687 std::thread worker([&allocateObjects, &vec1] { in TEST_F() local
|