Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 26) sorted by relevance

12

/ark/js_runtime/ecmascript/
Dtagged_queue.h33 static TaggedQueue *Push(const JSThread *thread, const JSHandle<TaggedQueue> &queue, in Push() argument
36 uint32_t capacity = queue->GetCapacity().GetArrayLength(); in Push()
48 uint32_t start = queue->GetStart().GetArrayLength(); in Push()
49 uint32_t end = queue->GetEnd().GetArrayLength(); in Push()
50 uint32_t size = queue->Size(); in Push()
55 return *queue; in Push()
64 newQueue->Set(thread, newEnd, queue->Get(i)); in Push()
74 queue->Set(thread, end, value.GetTaggedValue()); in Push()
75 queue->SetEnd(thread, JSTaggedValue((end + 1) % capacity)); in Push()
76 return *queue; in Push()
[all …]
Dtagged_queue-inl.h26 …auto queue = TaggedQueue::Cast(*thread->GetEcmaVM()->GetFactory()->NewTaggedArray(length, initVal)… in Create() local
27 queue->SetStart(thread, JSTaggedValue(0)); // equal to 0 when add 1. in Create()
28 queue->SetEnd(thread, JSTaggedValue(0)); in Create()
29 queue->SetCapacity(thread, JSTaggedValue(capacity)); in Create()
30 return queue; in Create()
Decma_vm.cpp731 void EcmaVM::SetMicroJobQueue(job::MicroJobQueue *queue) in SetMicroJobQueue() argument
733 ASSERT(queue != nullptr); in SetMicroJobQueue()
734 microJobQueue_ = JSTaggedValue(queue); in SetMicroJobQueue()
Decma_vm.h465 void SetMicroJobQueue(job::MicroJobQueue *queue);
Dobject_factory.cpp1836 auto queue = JSHandle<TaggedQueue>::Cast(NewTaggedArray(queueLength, JSTaggedValue::Hole())); in NewTaggedQueue() local
1837 queue->SetStart(thread_, JSTaggedValue(0)); // equal to 0 when add 1. in NewTaggedQueue()
1838 queue->SetEnd(thread_, JSTaggedValue(0)); in NewTaggedQueue()
1839 queue->SetCapacity(thread_, JSTaggedValue(length)); in NewTaggedQueue()
1841 return queue; in NewTaggedQueue()
/ark/js_runtime/ecmascript/tests/
Djs_tagged_queue_test.cpp58 JSHandle<TaggedQueue> queue = thread->GetEcmaVM()->GetFactory()->NewTaggedQueue(0); in HWTEST_F_L0() local
59 EXPECT_TRUE(*queue != nullptr); in HWTEST_F_L0()
60 EXPECT_TRUE(queue->Empty()); in HWTEST_F_L0()
61 EXPECT_TRUE(queue->Size() == 0); in HWTEST_F_L0()
62 EXPECT_TRUE(queue->Front() == JSTaggedValue::Hole()); in HWTEST_F_L0()
63 EXPECT_TRUE(queue->Back() == JSTaggedValue::Hole()); in HWTEST_F_L0()
68 JSHandle<TaggedQueue> queue = thread->GetEcmaVM()->GetFactory()->NewTaggedQueue(0); in HWTEST_F_L0() local
69 EXPECT_TRUE(queue->Empty()); in HWTEST_F_L0()
72 … TaggedQueue::Push(thread, queue, JSHandle<JSTaggedValue>(thread, JSTaggedValue(0)))); in HWTEST_F_L0()
/ark/js_runtime/ecmascript/snapshot/mem/
Dsnapshot_serialize.h35 void Serialize(TaggedObject *objectHeader, CQueue<TaggedObject *> *queue,
54 CQueue<TaggedObject *> *queue,
57 CQueue<TaggedObject *> *queue,
60 CQueue<TaggedObject *> *queue,
63 CQueue<TaggedObject *> *queue,
65 …DynArraySerialize(TaggedObject *objectHeader, uintptr_t snapshotObj, CQueue<TaggedObject *> *queue,
68 …nProgramSerialize(TaggedObject *objectHeader, uintptr_t snapshotObj, CQueue<TaggedObject *> *queue,
81 CQueue<TaggedObject *> *queue,
83 uint64_t HandleTaggedField(JSTaggedType *tagged, CQueue<TaggedObject *> *queue,
Dslot_bit.cpp30 …t SerializeHelper::AddObjectHeaderToData(TaggedObject *objectHeader, CQueue<TaggedObject *> *queue, in AddObjectHeaderToData() argument
33 queue->emplace(objectHeader); in AddObjectHeaderToData()
40 …Helper::AddTaggedObjectRangeToData(ObjectSlot start, ObjectSlot end, CQueue<TaggedObject *> *queue, in AddTaggedObjectRangeToData() argument
51 slotBit = AddObjectHeaderToData(object.GetTaggedObject(), queue, data, index); in AddTaggedObjectRangeToData()
Dsnapshot_serialize.cpp665 void SnapShotSerialize::Serialize(TaggedObject *objectHeader, CQueue<TaggedObject *> *queue, in Serialize() argument
689 SlotBit headSlot = HandleObjectHeader(objectHeader, objectType, objectSize, queue, data); in Serialize()
697 DynClassSerialize(objectHeader, snapshotObj, objectSize, queue, data); in Serialize()
704 DynArraySerialize(objectHeader, snapshotObj, queue, data); in Serialize()
710 DynProgramSerialize(objectHeader, snapshotObj, queue, data); in Serialize()
722 JSFunctionBaseSerialize(objectHeader, snapshotObj, objectSize, queue, data); in Serialize()
725 JSProxySerialize(objectHeader, snapshotObj, objectSize, queue, data); in Serialize()
728 JSObjectSerialize(objectHeader, snapshotObj, objectSize, queue, data); in Serialize()
866 CQueue<TaggedObject *> *queue, in HandleObjectHeader() argument
874 slot = SerializeHelper::AddObjectHeaderToData(hclassClass, queue, data); in HandleObjectHeader()
[all …]
Dslot_bit.h127 static SlotBit AddObjectHeaderToData(TaggedObject *objectHeader, CQueue<TaggedObject *> *queue,
129 …ic void AddTaggedObjectRangeToData(ObjectSlot start, ObjectSlot end, CQueue<TaggedObject *> *queue,
/ark/runtime_core/tests/cts-generator/
Dtest-runner.rb206 queue = Queue.new
207 files.each { |x| queue.push x}
211 def create_executor_threads(queue, id, reporter_factory) argument
214 while file = queue.pop(true)
235 create_executor_threads queue, id, reporter_factory
274 while file = queue.pop(true)
/ark/runtime_core/runtime/tests/
Dmock_queue_thread_pool.cpp187 auto queue = allocator->New<MockQueue>(allocator); in TestThreadPool() local
190 allocator, queue, controller, initial_number_of_threads, "Test thread"); in TestThreadPool()
216 allocator->Delete(queue); in TestThreadPool()
291 auto queue = allocator->New<MockQueue>(allocator, QUEUE_SIZE); in TestThreadPoolWithControllers() local
294 allocator, queue, controller, number_of_threads_initial, "Test thread"); in TestThreadPoolWithControllers()
327 allocator->Delete(queue); in TestThreadPoolWithControllers()
/ark/js_runtime/ecmascript/mem/
Dstw_young_gc_for_testing.cpp99 ProcessQueue *queue = workList_->GetWeakReferenceQueue(i); in SweepPhases() local
101 auto obj = queue->PopBack(); in SweepPhases()
Dfull_gc.cpp89 ProcessQueue *queue = workList_->GetWeakReferenceQueue(i); in SweepPhases() local
92 auto obj = queue->PopBack(); in SweepPhases()
Dc_containers.h54 using CQueue = std::queue<T, Container>;
Dparallel_evacuation.cpp235 ProcessQueue *queue = heap_->GetWorkList()->GetWeakReferenceQueue(i); in UpdateRecordWeakReference() local
238 auto obj = queue->PopBack(); in UpdateRecordWeakReference()
/ark/js_runtime/ecmascript/platform/
Dtask_queue.h42 std::queue<std::unique_ptr<Task>> tasks_;
/ark/js_runtime/ecmascript/tooling/
Dprotocol_handler.h61 std::queue<std::string> requestQueue_;
Dprotocol_handler.cpp56 std::queue<std::string> dispatchingQueue; in ProcessCommand()
/ark/runtime_core/runtime/mem/
Dregion_allocator-inl.h217 PandaPriorityQueue<std::pair<uint32_t, Region *>> queue; in GetTopGarbageRegions() local
220 queue.push(std::pair<uint32_t, Region *>(garbage_bytes, region)); in GetTopGarbageRegions()
224 auto *region = queue.top().second; in GetTopGarbageRegions()
226 queue.pop(); in GetTopGarbageRegions()
/ark/runtime_core/runtime/
Dthread_pool.h49 …explicit ThreadPool(mem::InternalAllocatorPtr allocator, TaskQueueInterface<Task> *queue, ProcArg …
52 queue_(queue), in allocator_()
/ark/runtime_core/runtime/include/mem/
Dpanda_containers.h53 using PandaQueue = std::queue<T, PandaContainer>;
56 using PandaQueueTL = std::queue<T, PandaContainer>;
/ark/runtime_core/docs/diagrams/
Dgc-mark.puactivity27 :Put the object into the corresponding queue;
/ark/runtime_core/libpandabase/utils/
Darena_containers.h43 using ArenaQueue = std::queue<T, ArenaContainer>;
/ark/runtime_core/dprof/daemon/
Dmain.cpp160 std::queue<os::unix::UniqueFd> queue_;

12