| /arkcompiler/runtime_core/static_core/runtime/coroutines/ |
| D | coroutine_context.h | 36 virtual void AttachToCoroutine(Coroutine *co) in AttachToCoroutine()
63 static void UpdateId(os::thread::ThreadId id, Coroutine *co) in UpdateId()
|
| D | stackful_coroutine_manager.cpp | 96 …auto *co = CreateNativeCoroutine(runtime, vm, coroEntryPoint, &entrypointParam, "[finalize coro] ", in FinalizeWorkers() local
272 for (auto *co : coroutinePool_) { in Finalize() local
279 void StackfulCoroutineManager::AddToRegistry(Coroutine *co) in AddToRegistry()
289 void StackfulCoroutineManager::RemoveFromRegistry(Coroutine *co) in RemoveFromRegistry()
298 void StackfulCoroutineManager::RegisterCoroutine(Coroutine *co) in RegisterCoroutine()
323 bool StackfulCoroutineManager::TerminateCoroutine(Coroutine *co) in TerminateCoroutine()
546 void StackfulCoroutineManager::ReuseCoroutineInstance(Coroutine *co, EntrypointInfo &&epInfo, Panda… in ReuseCoroutineInstance()
559 Coroutine *co = coroutinePool_.back(); in TryGetCoroutineFromPool() local
564 StackfulCoroutineWorker *StackfulCoroutineManager::ChooseWorkerForCoroutine(Coroutine *co) in ChooseWorkerForCoroutine()
614 Coroutine *co = nullptr; in GetCoroutineInstanceForLaunch() local
[all …]
|
| D | threaded_coroutine_manager.cpp | 89 void ThreadedCoroutineManager::AddToRegistry(Coroutine *co) in AddToRegistry()
96 void ThreadedCoroutineManager::RemoveFromRegistry(Coroutine *co) in RemoveFromRegistry()
102 void ThreadedCoroutineManager::DeleteCoroutineInstance(Coroutine *co) in DeleteCoroutineInstance()
109 void ThreadedCoroutineManager::RegisterCoroutine(Coroutine *co) in RegisterCoroutine()
132 bool ThreadedCoroutineManager::TerminateCoroutine(Coroutine *co) in TerminateCoroutine()
348 …runnablesQueue_.IterateOverCoroutines([](Coroutine *co) { LOG(DEBUG, COROUTINES) << co->GetName() … in PrintRunnableQueue()
353 void ThreadedCoroutineManager::PushToRunnableQueue(Coroutine *co, CoroutinePriority priority) in PushToRunnableQueue()
395 CoroutineWorker *ThreadedCoroutineManager::ChooseWorkerForCoroutine([[maybe_unused]] Coroutine *co) in ChooseWorkerForCoroutine()
411 …Coroutine *co = CreateCoroutineInstance(std::move(epInfo), std::move(coroName), Coroutine::Type::M… in LaunchImpl() local
|
| D | stackful_coroutine.cpp | 56 void StackfulCoroutineContext::AttachToCoroutine(Coroutine *co) in AttachToCoroutine()
99 auto *co = GetCoroutine(); in Destroy() local
136 auto *co = GetCoroutine(); in ThreadProcImpl() local
|
| D | coroutine_manager.h | 255 virtual void OnCoroBecameActive([[maybe_unused]] Coroutine *co) {}; in OnCoroBecameActive()
260 virtual void OnCoroBecameNonActive([[maybe_unused]] Coroutine *co) {}; in OnCoroBecameNonActive()
262 virtual void OnNativeCallEnter([[maybe_unused]] Coroutine *co) {}; in OnNativeCallEnter()
264 virtual void OnNativeCallExit([[maybe_unused]] Coroutine *co) {}; in OnNativeCallExit()
|
| D | threaded_coroutine.cpp | 48 void ThreadedCoroutineContext::AttachToCoroutine(Coroutine *co) in AttachToCoroutine()
66 auto *co = GetCoroutine(); in Destroy() local
96 auto *co = ctx->GetCoroutine(); in ThreadProc() local
|
| D | coroutine_manager.cpp | 66 auto *co = coFactory_(runtime, vm, std::move(name), ctx, std::nullopt, type, priority); in CreateEntrypointlessCoroutine() local
78 void CoroutineManager::DestroyEntrypointlessCoroutine(Coroutine *co) in DestroyEntrypointlessCoroutine()
108 void CoroutineManager::DestroyEntrypointfulCoroutine(Coroutine *co) in DestroyEntrypointfulCoroutine()
|
| D | coroutine_worker.cpp | 22 void CoroutineWorker::OnCoroBecameActive(Coroutine *co) in OnCoroBecameActive()
|
| D | stackful_coroutine_worker.cpp | 228 …runnables_.IterateOverCoroutines([](Coroutine *co) { LOG(DEBUG, COROUTINES) << co->GetName() << " … in PrintRunnables()
286 void StackfulCoroutineWorker::PushToRunnableQueue(Coroutine *co, CoroutinePriority priority) in PushToRunnableQueue()
436 auto *co = Coroutine::GetCurrent(); in GetCurrentContext() local
|
| D | coroutine.cpp | 34 auto *co = allocator->New<Coroutine>(os::thread::GetCurrentThreadId(), allocator, vm, in Create() local
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| D | ets_object_state_info.cpp | 57 auto *co = EtsCoroutine::GetCurrent(); in TryAddNewInfo() local
89 auto *co = EtsCoroutine::GetCurrent(); in TryReadEtsHash() local
110 auto *co = EtsCoroutine::GetCurrent(); in TryReadInteropIndex() local
132 auto *co = EtsCoroutine::GetCurrent(); in TryDropInteropIndex() local
153 auto *co = EtsCoroutine::GetCurrent(); in TryResetInteropIndex() local
171 auto *co = EtsCoroutine::GetCurrent(); in TryCheckIfInteropIndexIsValid() local
|
| D | ets_coroutine.h | 51 …auto co = allocator->New<EtsCoroutine>(os::thread::GetCurrentThreadId(), allocator, vm, std::move(… variable
72 Coroutine *co = Coroutine::GetCurrent(); in GetCurrent() local
|
| /arkcompiler/ets_frontend/es2panda/test/compiler/js/ |
| D | cocos_worker_test.js | 19955 class co { class
|
| /arkcompiler/ets_frontend/legacy_bin/api8/src/ |
| D | index.js | 2 …peof e?function(e,t){if("string"==typeof t&&""!==t||(t="utf8"),!Buffer.isEncoding(t))throw new Typ… function
|