| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue_unittest.cc | 51 int enqueue_order, in FakeCancelableTaskWithEnqueueOrder() argument
57 EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeCancelableTaskWithEnqueueOrder()
61 TaskQueueImpl::Task FakeTaskWithEnqueueOrder(int enqueue_order) { in FakeTaskWithEnqueueOrder() argument
64 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeTaskWithEnqueueOrder()
68 TaskQueueImpl::Task FakeNonNestableTaskWithEnqueueOrder(int enqueue_order) { in FakeNonNestableTaskWithEnqueueOrder() argument
71 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeNonNestableTaskWithEnqueueOrder()
96 EnqueueOrder enqueue_order; in TEST_F() local
97 EXPECT_FALSE(work_queue_->GetFrontTaskEnqueueOrder(&enqueue_order)); in TEST_F()
105 EnqueueOrder enqueue_order; in TEST_F() local
106 EXPECT_TRUE(work_queue_->GetFrontTaskEnqueueOrder(&enqueue_order)); in TEST_F()
[all …]
|
| D | work_queue_sets.cc | 21 EnqueueOrder enqueue_order; in AddQueue() local
22 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); in AddQueue()
27 work_queue_heaps_[set_index].insert({enqueue_order, work_queue}); in AddQueue()
44 EnqueueOrder enqueue_order; in ChangeSetIndex() local
45 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); in ChangeSetIndex()
53 work_queue_heaps_[set_index].insert({enqueue_order, work_queue}); in ChangeSetIndex()
57 EnqueueOrder enqueue_order; in OnFrontTaskChanged() local
58 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); in OnFrontTaskChanged()
62 {enqueue_order, work_queue}); in OnFrontTaskChanged()
69 EnqueueOrder enqueue_order; in OnTaskPushedToEmptyQueue() local
[all …]
|
| D | work_queue.cc | 49 return tasks_.empty() || tasks_.front().enqueue_order() >= fence_; in BlockedByFence()
52 bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const { in GetFrontTaskEnqueueOrder()
56 DCHECK_LE(tasks_.front().enqueue_order(), tasks_.back().enqueue_order()) in GetFrontTaskEnqueueOrder()
59 *enqueue_order = tasks_.front().enqueue_order(); in GetFrontTaskEnqueueOrder()
70 DCHECK(was_empty || tasks_.rbegin()->enqueue_order() < task.enqueue_order()); in Push()
94 DCHECK_LE(task.enqueue_order(), tasks_.front().enqueue_order()) in PushNonNestableTaskToFront()
218 EnqueueOrder enqueue_order; in ShouldRunBefore() local
220 bool have_task = GetFrontTaskEnqueueOrder(&enqueue_order); in ShouldRunBefore()
225 return enqueue_order < other_enqueue_order; in ShouldRunBefore()
|
| D | work_queue_sets_unittest.cc | 46 TaskQueueImpl::Task FakeTaskWithEnqueueOrder(int enqueue_order) { in FakeTaskWithEnqueueOrder() argument
49 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeTaskWithEnqueueOrder()
53 TaskQueueImpl::Task FakeNonNestableTaskWithEnqueueOrder(int enqueue_order) { in FakeNonNestableTaskWithEnqueueOrder() argument
56 EnqueueOrder(), EnqueueOrder::FromIntForTesting(enqueue_order)); in FakeNonNestableTaskWithEnqueueOrder()
117 EnqueueOrder enqueue_order; in TEST_F() local
119 set, &selected_work_queue, &enqueue_order)); in TEST_F()
121 EXPECT_EQ(10u, enqueue_order); in TEST_F()
|
| D | task_queue_impl.h | 116 EnqueueOrder enqueue_order);
126 EnqueueOrder enqueue_order() const { in enqueue_order() function
131 void set_enqueue_order(EnqueueOrder enqueue_order) { in set_enqueue_order() argument
133 enqueue_order_ = enqueue_order; in set_enqueue_order()
215 bool CouldTaskRun(EnqueueOrder enqueue_order) const;
|
| D | task_queue_impl.cc | 99 EnqueueOrder enqueue_order) in Task() argument
101 enqueue_order_(enqueue_order) { in Task()
304 EnqueueOrder sequence_number = task.enqueue_order(); in PushOntoImmediateIncomingQueueLocked()
352 main_thread_only().current_fence = task.enqueue_order(); in ReloadEmptyImmediateQueue()
648 immediate_incoming_queue().front().enqueue_order() > previous_fence && in InsertFence()
649 immediate_incoming_queue().front().enqueue_order() < current_fence) { in InsertFence()
679 immediate_incoming_queue().front().enqueue_order() > previous_fence) { in RemoveFence()
702 return immediate_incoming_queue().front().enqueue_order() > in BlockedByFence()
715 bool TaskQueueImpl::CouldTaskRun(EnqueueOrder enqueue_order) const { in CouldTaskRun()
722 return enqueue_order < main_thread_only().current_fence; in CouldTaskRun()
[all …]
|
| D | sequence_manager_impl.h | 265 internal::EnqueueOrder enqueue_order,
272 internal::EnqueueOrder enqueue_order);
|
| D | sequence_manager_impl.cc | 170 internal::EnqueueOrder enqueue_order) { in AddToIncomingImmediateWorkList() argument
178 task_queue->immediate_work_list_storage()->order = enqueue_order; in AddToIncomingImmediateWorkList()
279 internal::EnqueueOrder enqueue_order, in OnQueueHasIncomingImmediateWork() argument
281 if (AddToIncomingImmediateWorkList(queue, enqueue_order) && !queue_is_blocked) in OnQueueHasIncomingImmediateWork()
|
| D | work_queue.h | 54 bool GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const;
|
| D | sequence_manager_impl_unittest.cc | 2735 EnqueueOrder enqueue_order = manager_->GetNextSequenceNumber(); in TEST_P() local
2736 EXPECT_TRUE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2741 EXPECT_FALSE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2744 EXPECT_TRUE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2750 EnqueueOrder enqueue_order = manager_->GetNextSequenceNumber(); in TEST_P() local
2751 EXPECT_TRUE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2754 EXPECT_TRUE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2757 EXPECT_FALSE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2760 EXPECT_TRUE(runners_[0]->GetTaskQueueImpl()->CouldTaskRun(enqueue_order)); in TEST_P()
2768 EnqueueOrder enqueue_order = manager_->GetNextSequenceNumber(); in TEST_P() local
[all …]
|
| D | task_queue_selector_unittest.cc | 355 size_t enqueue_order[] = {10, 1, 2, 9, 4}; in TEST_F() local
357 PushTasksWithEnqueueOrder(queue_order, enqueue_order, 5); in TEST_F()
|
| /external/webrtc/webrtc/modules/pacing/ |
| D | paced_sender.cc | 48 uint64_t enqueue_order) in Packet()
56 enqueue_order(enqueue_order) {} in Packet()
65 uint64_t enqueue_order; member
84 return first->enqueue_order > second->enqueue_order; in operator ()()
|