Searched refs:jobQueue (Results 1 - 6 of 6) sorted by relevance
| /arkcompiler/ets_runtime/ecmascript/jobs/ |
| H A D | micro_job_queue.cpp | 25 uint32_t MicroJobQueue::GetPromiseQueueSize(JSThread *thread, JSHandle<MicroJobQueue> jobQueue) in GetPromiseQueueSize() argument
28 JSHandle<TaggedQueue> promiseQueue(thread, jobQueue->GetPromiseJobQueue()); in GetPromiseQueueSize()
32 void MicroJobQueue::EnqueueJob(JSThread *thread, JSHandle<MicroJobQueue> jobQueue, QueueType queueType, in EnqueueJob() argument
47 JSHandle<TaggedQueue> promiseQueue(thread, jobQueue->GetPromiseJobQueue()); in EnqueueJob()
49 jobQueue->SetPromiseJobQueue(thread, JSTaggedValue(newPromiseQueue)); in EnqueueJob()
52 JSHandle<TaggedQueue> scriptQueue(thread, jobQueue->GetScriptJobQueue()); in EnqueueJob()
54 jobQueue->SetScriptJobQueue(thread, JSTaggedValue(newScriptQueue)); in EnqueueJob()
58 void MicroJobQueue::ExecutePendingJob(JSThread *thread, JSHandle<MicroJobQueue> jobQueue) in ExecutePendingJob() argument
61 JSMutableHandle<TaggedQueue> promiseQueue(thread, jobQueue->GetPromiseJobQueue()); in ExecutePendingJob()
75 jobQueue in ExecutePendingJob()
[all...] |
| H A D | micro_job_queue.h | 35 static uint32_t GetPromiseQueueSize(JSThread *thread, JSHandle<MicroJobQueue> jobQueue);
36 static void EnqueueJob(JSThread *thread, JSHandle<MicroJobQueue> jobQueue, QueueType queueType,
38 static void ExecutePendingJob(JSThread *thread, JSHandle<MicroJobQueue> jobQueue);
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/types/ |
| H A D | ets_promise.cpp | 73 auto *jobQueue = coro->GetPandaVM()->GetJobQueue(); in LaunchCallback() local
74 if (launchMode == CoroutineLaunchMode::MAIN_WORKER && jobQueue != nullptr) { in LaunchCallback()
75 jobQueue->Post(callback); in LaunchCallback()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/intrinsics/ |
| H A D | std_core_Promise.cpp | 151 auto *jobQueue = currentCoro->GetPandaVM()->GetJobQueue(); in EtsPromiseCreateLink() local
152 if (jobQueue != nullptr) { in EtsPromiseCreateLink()
153 jobQueue->CreateLink(source, target->AsObject()); in EtsPromiseCreateLink()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| H A D | ets_vm.h | 285 void InitJobQueue(JobQueue *jobQueue) in InitJobQueue() argument
288 jobQueue_.reset(jobQueue); in InitJobQueue()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/interop_js/ |
| H A D | interop_context.cpp | 129 auto *jobQueue = Runtime::GetCurrent()->GetInternalAllocator()->New<JsJobQueue>(); in InteropCtx() local
130 vm->InitJobQueue(jobQueue); in InteropCtx()
|
Completed in 3 milliseconds