Searched refs:EnqueueOrder (Results 1 – 17 of 17) sorted by relevance
21 class EnqueueOrder {23 EnqueueOrder() : value_(kNone) {} in EnqueueOrder() function24 ~EnqueueOrder() = default;26 static EnqueueOrder none() { return EnqueueOrder(kNone); } in none()27 static EnqueueOrder blocking_fence() { return EnqueueOrder(kBlockingFence); } in blocking_fence()33 static EnqueueOrder FromIntForTesting(uint64_t value) { in FromIntForTesting()34 return EnqueueOrder(value); in FromIntForTesting()45 EnqueueOrder GenerateNext() { in GenerateNext()46 return EnqueueOrder(std::atomic_fetch_add_explicit( in GenerateNext()56 explicit EnqueueOrder(uint64_t value) : value_(value) {} in EnqueueOrder() function
56 TimeTicks(), EnqueueOrder(), in FakeCancelableTaskWithEnqueueOrder()57 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeCancelableTaskWithEnqueueOrder()64 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeTaskWithEnqueueOrder()71 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeNonNestableTaskWithEnqueueOrder()91 work_queue_->InsertFence(EnqueueOrder::blocking_fence()); in TEST_F()96 EnqueueOrder enqueue_order; in TEST_F()105 EnqueueOrder enqueue_order; in TEST_F()146 work_queue_->InsertFence(EnqueueOrder::blocking_fence()); in TEST_F()171 work_queue_->InsertFence(EnqueueOrder::blocking_fence()); in TEST_F()181 work_queue_->InsertFence(EnqueueOrder::FromIntForTesting(3)); in TEST_F()[all …]
52 bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const { in GetFrontTaskEnqueueOrder()176 bool WorkQueue::InsertFenceImpl(EnqueueOrder fence) { in InsertFenceImpl()178 DCHECK(fence >= fence_ || fence == EnqueueOrder::blocking_fence()); in InsertFenceImpl()184 void WorkQueue::InsertFenceSilently(EnqueueOrder fence) { in InsertFenceSilently()186 DCHECK(!fence_ || fence_ == EnqueueOrder::blocking_fence()); in InsertFenceSilently()190 bool WorkQueue::InsertFence(EnqueueOrder fence) { in InsertFence()207 fence_ = EnqueueOrder::none(); in RemoveFence()218 EnqueueOrder enqueue_order; in ShouldRunBefore()219 EnqueueOrder other_enqueue_order; in ShouldRunBefore()
54 bool GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const;113 bool InsertFence(EnqueueOrder fence);118 void InsertFenceSilently(EnqueueOrder fence);134 bool InsertFenceImpl(EnqueueOrder fence);142 EnqueueOrder fence_;
21 EnqueueOrder enqueue_order; in AddQueue()44 EnqueueOrder enqueue_order; in ChangeSetIndex()57 EnqueueOrder enqueue_order; in OnFrontTaskChanged()69 EnqueueOrder enqueue_order; in OnTaskPushedToEmptyQueue()89 EnqueueOrder enqueue_order; in OnPopQueue()125 EnqueueOrder* out_enqueue_order) const { in GetOldestQueueAndEnqueueOrderInSet()132 EnqueueOrder enqueue_order; in GetOldestQueueAndEnqueueOrderInSet()147 EnqueueOrder enqueue_order; in ContainsWorkQueueForTest()
43 internal::EnqueueOrder order;111 EnqueueOrder sequence_number);115 EnqueueOrder sequence_number,116 EnqueueOrder enqueue_order);126 EnqueueOrder enqueue_order() const { in enqueue_order()131 void set_enqueue_order(EnqueueOrder enqueue_order) { in set_enqueue_order()144 EnqueueOrder enqueue_order_;215 bool CouldTaskRun(EnqueueOrder enqueue_order) const;359 EnqueueOrder current_fence;
45 using base::sequence_manager::internal::EnqueueOrder;275 void TestTask(uint64_t value, std::vector<EnqueueOrder>* out_result) { in TestTask()276 out_result->push_back(EnqueueOrder::FromIntForTesting(value)); in TestTask()280 std::vector<EnqueueOrder>* out_result, in DisableQueueTestTask()282 out_result->push_back(EnqueueOrder::FromIntForTesting(value)); in DisableQueueTestTask()289 std::vector<EnqueueOrder> run_order; in TEST_P()301 std::vector<EnqueueOrder> run_order; in TEST_P()316 std::vector<EnqueueOrder> run_order; in TEST_P()328 std::vector<EnqueueOrder> run_order; in TEST_P()344 std::vector<EnqueueOrder> run_order; in TEST_P()[all …]
108 EnqueueOrder::Generator enqueue_order_generator; in PushTasks()113 TimeTicks(), EnqueueOrder(), in PushTasks()127 EnqueueOrder(), in PushTasksWithEnqueueOrder()128 EnqueueOrder::FromIntForTesting(enqueue_orders[i]))); in PushTasksWithEnqueueOrder()735 EnqueueOrder(), EnqueueOrder::FromIntForTesting(2))); in TEST_F()749 EnqueueOrder(), EnqueueOrder::FromIntForTesting(2))); in TEST_F()774 TimeTicks(), EnqueueOrder(), in TEST_F()775 EnqueueOrder::FromIntForTesting(2)); in TEST_F()805 TimeTicks(), EnqueueOrder::FromIntForTesting(2), in TEST_F()806 EnqueueOrder::FromIntForTesting(2)); in TEST_F()[all …]
11 EnqueueOrder::Generator::Generator() : counter_(kFirst) {} in Generator()13 EnqueueOrder::Generator::~Generator() = default;
90 EnqueueOrder sequence_number) in Task()98 EnqueueOrder sequence_number, in Task()99 EnqueueOrder enqueue_order) in Task()203 EnqueueOrder sequence_number = in PostImmediateTaskImpl()223 EnqueueOrder sequence_number = in PostDelayedTaskImpl()240 EnqueueOrder sequence_number = in PostDelayedTaskImpl()266 EnqueueOrder thread_hop_task_sequence_number = in PushOntoDelayedIncomingQueueLocked()304 EnqueueOrder sequence_number = task.enqueue_order(); in PushOntoImmediateIncomingQueueLocked()631 EnqueueOrder previous_fence = main_thread_only().current_fence; in InsertFence()632 EnqueueOrder current_fence = in InsertFence()[all …]
49 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeTaskWithEnqueueOrder()56 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeNonNestableTaskWithEnqueueOrder()117 EnqueueOrder enqueue_order; in TEST_F()298 queue1->InsertFence(EnqueueOrder::blocking_fence()); in TEST_F()
63 EnqueueOrder* out_enqueue_order) const;78 EnqueueOrder key;
255 internal::EnqueueOrder GetNextSequenceNumber();265 internal::EnqueueOrder enqueue_order,272 internal::EnqueueOrder enqueue_order);297 internal::EnqueueOrder::Generator enqueue_order_generator_;
175 EnqueueOrder immediate_enqueue_order; in ChooseOldestImmediateOrDelayedTaskWithPriority()179 EnqueueOrder delayed_enqueue_order; in ChooseOldestImmediateOrDelayedTaskWithPriority()
170 internal::EnqueueOrder enqueue_order) { in AddToIncomingImmediateWorkList()279 internal::EnqueueOrder enqueue_order, in OnQueueHasIncomingImmediateWork()570 internal::EnqueueOrder SequenceManagerImpl::GetNextSequenceNumber() { in GetNextSequenceNumber()
80 uint64_t EnqueueOrder() const;
73 uint64_t RoundRobinPacketQueue::QueuedPacket::EnqueueOrder() const { in EnqueueOrder() function in webrtc::RoundRobinPacketQueue::QueuedPacket