Home
last modified time | relevance | path

Searched refs:EnqueueOrder (Results 1 – 25 of 38) sorted by relevance

12

/external/cronet/base/task/sequence_manager/
Denqueue_order.h21 class EnqueueOrder {
23 EnqueueOrder() : value_(kNone) {} in EnqueueOrder() function
24 ~EnqueueOrder() = default;
26 static EnqueueOrder none() { return EnqueueOrder(kNone); } in none()
27 static EnqueueOrder blocking_fence() { return EnqueueOrder(kBlockingFence); } in blocking_fence()
30 static EnqueueOrder max() { in max()
31 return EnqueueOrder(std::numeric_limits<uint64_t>::max()); in max()
38 static EnqueueOrder FromIntForTesting(uint64_t value) { in FromIntForTesting()
39 return EnqueueOrder(value); in FromIntForTesting()
47 explicit EnqueueOrder(uint64_t value) : value_(value) {} in EnqueueOrder() function
Dtask_queue_selector_unittest.cc90 Task(PostedTask(nullptr, test_closure_, FROM_HERE), EnqueueOrder(), in PushTasks()
100 Task(PostedTask(nullptr, test_closure_, FROM_HERE), EnqueueOrder(), in PushTasksWithEnqueueOrder()
101 EnqueueOrder::FromIntForTesting(enqueue_orders[i]))); in PushTasksWithEnqueueOrder()
107 Task(PostedTask(nullptr, test_closure_, FROM_HERE), EnqueueOrder(), in PushTask()
108 EnqueueOrder::FromIntForTesting(enqueue_order))); in PushTask()
381 Task(PostedTask(nullptr, test_closure_, FROM_HERE), EnqueueOrder(), in TEST_F()
382 EnqueueOrder::FromIntForTesting(2))); in TEST_F()
393 Task(PostedTask(nullptr, test_closure_, FROM_HERE), EnqueueOrder(), in TEST_F()
394 EnqueueOrder::FromIntForTesting(2))); in TEST_F()
406 Task(PostedTask(nullptr, test_closure_, FROM_HERE), EnqueueOrder(), in TEST_F()
[all …]
Dtask_order.h55 EnqueueOrder enqueue_order() const { return enqueue_order_; } in enqueue_order()
62 static TaskOrder CreateForTesting(EnqueueOrder enqueue_order,
65 static TaskOrder CreateForTesting(EnqueueOrder enqueue_order);
75 TaskOrder(EnqueueOrder enqueue_order,
83 EnqueueOrder enqueue_order_;
Dfence.cc19 DCHECK_NE(task_order_.enqueue_order(), EnqueueOrder::none()); in Fence()
22 Fence::Fence(EnqueueOrder enqueue_order, in Fence()
35 return CreateWithEnqueueOrder(EnqueueOrder::blocking_fence()); in BlockingFence()
39 Fence Fence::CreateWithEnqueueOrder(EnqueueOrder enqueue_order) { in CreateWithEnqueueOrder()
Dtasks.h104 EnqueueOrder sequence_order,
105 EnqueueOrder enqueue_order = EnqueueOrder(),
115 EnqueueOrder enqueue_order() const { in enqueue_order()
120 void set_enqueue_order(EnqueueOrder enqueue_order) { in set_enqueue_order()
166 EnqueueOrder enqueue_order_;
Dwork_queue_sets_unittest.cc72 EnqueueOrder(), in FakeTaskWithEnqueueOrder()
73 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeTaskWithEnqueueOrder()
79 EnqueueOrder(), in FakeNonNestableTaskWithEnqueueOrder()
80 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeNonNestableTaskWithEnqueueOrder()
89 EnqueueOrder::FromIntForTesting(task_order.sequence_num()), in FakeTaskWithTaskOrder()
168 EXPECT_EQ(EnqueueOrder::FromIntForTesting(4), in TEST_F()
410 const EnqueueOrder kEnqueueOrder = EnqueueOrder::FromIntForTesting(5); in TEST_F()
443 const EnqueueOrder kEnqueueOrder = EnqueueOrder::FromIntForTesting(5); in TEST_F()
481 TaskOrder::CreateForTesting(EnqueueOrder::FromIntForTesting(10), in TEST_F()
485 TaskOrder::CreateForTesting(EnqueueOrder::FromIntForTesting(11), in TEST_F()
[all …]
Dfence.h45 return task_order_.enqueue_order() == EnqueueOrder::blocking_fence(); in IsBlockingFence()
51 Fence(EnqueueOrder enqueue_order,
57 static Fence CreateWithEnqueueOrder(EnqueueOrder enqueue_order);
Dwork_queue_unittest.cc75 EnqueueOrder(), in FakeCancelableTaskWithEnqueueOrder()
76 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeCancelableTaskWithEnqueueOrder()
82 EnqueueOrder(), in FakeTaskWithEnqueueOrder()
83 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeTaskWithEnqueueOrder()
89 EnqueueOrder(), in FakeNonNestableTaskWithEnqueueOrder()
90 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeNonNestableTaskWithEnqueueOrder()
99 EnqueueOrder::FromIntForTesting(task_order.sequence_num()), in FakeTaskWithTaskOrder()
106 EnqueueOrder::FromIntForTesting(enqueue_order))); in CreateFenceWithEnqueueOrder()
580 TaskOrder::CreateForTesting(EnqueueOrder::FromIntForTesting(4), in TEST_F()
590 const EnqueueOrder kEnqueueOrder = EnqueueOrder::FromIntForTesting(5); in TEST_F()
[all …]
Dtask_order.cc38 TaskOrder TaskOrder::CreateForTesting(EnqueueOrder enqueue_order, in CreateForTesting()
45 TaskOrder TaskOrder::CreateForTesting(EnqueueOrder enqueue_order) { in CreateForTesting()
49 TaskOrder::TaskOrder(EnqueueOrder enqueue_order, in TaskOrder()
Denqueue_order_generator.h29 EnqueueOrder GenerateNext() { in GenerateNext()
30 return EnqueueOrder(std::atomic_fetch_add_explicit( in GenerateNext()
Dtask_queue_impl.h158 bool CouldTaskRun(EnqueueOrder enqueue_order) const;
163 bool WasBlockedOrLowPriority(EnqueueOrder enqueue_order) const;
222 EnqueueOrder enqueue_order);
224 void OnWakeUp(LazyNow* lazy_now, EnqueueOrder enqueue_order);
447 EnqueueOrder enqueue_order_at_which_we_became_unblocked;
466 EnqueueOrder
Dsequence_manager_impl_unittest.cc67 using base::sequence_manager::EnqueueOrder;
645 void TestTask(uint64_t value, std::vector<EnqueueOrder>* out_result) { in TestTask()
646 out_result->push_back(EnqueueOrder::FromIntForTesting(value)); in TestTask()
650 std::vector<EnqueueOrder>* out_result, in DisableQueueTestTask()
652 out_result->push_back(EnqueueOrder::FromIntForTesting(value)); in DisableQueueTestTask()
659 std::vector<EnqueueOrder> run_order; in TEST_P()
671 std::vector<EnqueueOrder> run_order; in TEST_P()
692 std::vector<EnqueueOrder> run_order; in TEST_P()
703 std::vector<EnqueueOrder> run_order; in TEST_P()
721 std::vector<EnqueueOrder> run_order; in TEST_P()
[all …]
/external/libchrome/base/task/sequence_manager/
Denqueue_order.h21 class EnqueueOrder {
23 EnqueueOrder() : value_(kNone) {} in EnqueueOrder() function
24 ~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
Dwork_queue_unittest.cc56 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 …]
Dwork_queue.cc52 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()
Dwork_queue_sets.cc21 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()
Dwork_queue.h54 bool GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const;
113 bool InsertFence(EnqueueOrder fence);
118 void InsertFenceSilently(EnqueueOrder fence);
134 bool InsertFenceImpl(EnqueueOrder fence);
142 EnqueueOrder fence_;
Dtask_queue_impl.h43 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;
Dsequence_manager_impl_unittest.cc45 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 …]
Dtask_queue_selector_unittest.cc108 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 …]
Denqueue_order.cc11 EnqueueOrder::Generator::Generator() : counter_(kFirst) {} in Generator()
13 EnqueueOrder::Generator::~Generator() = default;
Dtask_queue_impl.cc90 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 …]
Dwork_queue_sets_unittest.cc49 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()
Dsequence_manager_impl.h255 internal::EnqueueOrder GetNextSequenceNumber();
265 internal::EnqueueOrder enqueue_order,
272 internal::EnqueueOrder enqueue_order);
297 internal::EnqueueOrder::Generator enqueue_order_generator_;
/external/cronet/base/task/sequence_manager/test/
Dfake_task.cc19 EnqueueOrder(), in FakeTask()
20 EnqueueOrder(), in FakeTask()

12