| /arkcompiler/runtime_core/static_core/runtime/coroutines/ |
| H A D | coroutine_context.h | 36 virtual void AttachToCoroutine(Coroutine *co) in AttachToCoroutine() argument
63 static void UpdateId(os::thread::ThreadId id, Coroutine *co) in UpdateId() argument
|
| H A D | coroutine.cpp | 28 auto *co = allocator->New<Coroutine>(os::thread::GetCurrentThreadId(), allocator, vm, in Create() local
|
| H A D | stackful_coroutine.cpp | 32 void StackfulCoroutineContext::AttachToCoroutine(Coroutine *co) in AttachToCoroutine() argument
67 auto *co = GetCoroutine(); in Destroy() local
110 auto *co = GetCoroutine(); ThreadProcImpl() local
[all...] |
| H A D | coroutine_manager.cpp | 63 auto *co = coFactory_(runtime, vm, std::move(name), ctx, std::nullopt); in CreateEntrypointlessCoroutine() local
74 void CoroutineManager::DestroyEntrypointlessCoroutine(Coroutine *co) in DestroyEntrypointlessCoroutine() argument
104 DestroyEntrypointfulCoroutine(Coroutine *co) DestroyEntrypointfulCoroutine() argument
[all...] |
| H A D | threaded_coroutine.cpp | 48 void ThreadedCoroutineContext::AttachToCoroutine(Coroutine *co) in AttachToCoroutine() argument
66 auto *co = GetCoroutine(); in Destroy() local
96 auto *co = ctx->GetCoroutine(); ThreadProc() local
99 UpdateId(os::thread::GetCurrentThreadId(), co); ThreadProc() local
[all...] |
| H A D | threaded_coroutine_manager.cpp | 80 void ThreadedCoroutineManager::AddToRegistry(Coroutine *co) in AddToRegistry() argument
88 void ThreadedCoroutineManager::RemoveFromRegistry(Coroutine *co) in RemoveFromRegistry() argument
94 void ThreadedCoroutineManager::DeleteCoroutineInstance(Coroutine *co) in DeleteCoroutineInstance() argument
101 void ThreadedCoroutineManager::RegisterCoroutine(Coroutine *co) in RegisterCoroutine() argument
106 TerminateCoroutine(Coroutine *co) TerminateCoroutine() argument
297 PushToRunnableQueue(Coroutine *co) PushToRunnableQueue() argument
309 auto *co = runnablesQueue_.front(); PopFromRunnableQueue() local
347 Coroutine *co = CreateCoroutineInstance(completionEvent, entrypoint, std::move(arguments), std::move(coroName)); LaunchImpl() local
[all...] |
| H A D | stackful_coroutine_worker.cpp | 194 void StackfulCoroutineWorker::PushToRunnableQueue(Coroutine *co, bool pushFront) in PushToRunnableQueue() argument
213 auto *co = runnables_.front(); in PopFromRunnableQueue() local
332 auto *co = Coroutine::GetCurrent(); in GetCurrentContext() local
[all...] |
| H A D | stackful_coroutine_manager.cpp | 162 void StackfulCoroutineManager::AddToRegistry(Coroutine *co) in AddToRegistry() argument
170 void StackfulCoroutineManager::RemoveFromRegistry(Coroutine *co) in RemoveFromRegistry() argument
176 void StackfulCoroutineManager::RegisterCoroutine(Coroutine *co) in RegisterCoroutine() argument
181 TerminateCoroutine(Coroutine *co) TerminateCoroutine() argument
391 ReuseCoroutineInstance(Coroutine *co, CompletionEvent *completionEvent, Method *entrypoint, PandaVector<Value> &&arguments, PandaString name) ReuseCoroutineInstance() argument
406 Coroutine *co = coroutinePool_.back(); TryGetCoroutineFromPool() local
411 ChooseWorkerForCoroutine(Coroutine *co) ChooseWorkerForCoroutine() argument
491 Coroutine *co = nullptr; LaunchImpl() local
605 auto *co = Coroutine::GetCurrent(); GetCurrentContext() local
625 DestroyEntrypointfulCoroutine(Coroutine *co) DestroyEntrypointfulCoroutine() argument
663 auto *co = GetCoroutineFactory()(runtime, vm, std::move(name), ctx, Coroutine::NativeEntrypointInfo(entry, param)); CreateNativeCoroutine() local
672 DestroyNativeCoroutine(Coroutine *co) DestroyNativeCoroutine() argument
[all...] |
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| H A D | ets_coroutine.h | 44 auto co = allocator->New<EtsCoroutine>(os::thread::GetCurrentThreadId(), allocator, vm, std::move(name), in Create() local
59 Coroutine *co = Coroutine::GetCurrent(); in GetCurrent() local
|