| /external/libchrome/base/task/sequence_manager/ |
| D | task_queue.cc | 15 TaskQueue::TaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl, in TaskQueue() function in base::sequence_manager::TaskQueue
16 const TaskQueue::Spec& spec) in TaskQueue()
23 TaskQueue::~TaskQueue() { in ~TaskQueue()
33 TaskQueue::Task::Task(TaskQueue::PostedTask task, TimeTicks desired_run_time) in Task()
40 TaskQueue::TaskTiming::TaskTiming(bool has_wall_time, bool has_thread_time) in TaskTiming()
43 void TaskQueue::TaskTiming::RecordTaskStart(LazyNow* now) { in RecordTaskStart()
50 void TaskQueue::TaskTiming::RecordTaskEnd(LazyNow* now) { in RecordTaskEnd()
57 TaskQueue::PostedTask::PostedTask(OnceClosure callback, in PostedTask()
68 TaskQueue::PostedTask::PostedTask(PostedTask&& move_from) in PostedTask()
75 TaskQueue::PostedTask::~PostedTask() = default;
[all …]
|
| D | task_queue_selector.cc | 20 TaskQueue::QueuePriority priority) { in QueuePriorityToSelectorLogic()
22 case TaskQueue::kControlPriority: in QueuePriorityToSelectorLogic()
24 case TaskQueue::kHighestPriority: in QueuePriorityToSelectorLogic()
26 case TaskQueue::kHighPriority: in QueuePriorityToSelectorLogic()
28 case TaskQueue::kNormalPriority: in QueuePriorityToSelectorLogic()
30 case TaskQueue::kLowPriority: in QueuePriorityToSelectorLogic()
32 case TaskQueue::kBestEffortPriority: in QueuePriorityToSelectorLogic()
62 prioritizing_selector_.AddQueue(queue, TaskQueue::kNormalPriority); in AddQueue()
87 TaskQueue::QueuePriority priority) { in SetQueuePriority()
88 DCHECK_LT(priority, TaskQueue::kQueuePriorityCount); in SetQueuePriority()
[all …]
|
| D | task_queue_selector_unittest.cc | 112 TaskQueueImpl::Task(TaskQueue::PostedTask(test_closure_, FROM_HERE), in PushTasks()
126 TaskQueue::PostedTask(test_closure_, FROM_HERE), TimeTicks(), in PushTasksWithEnqueueOrder()
154 TaskQueue::Spec("test")); in SetUp()
159 EXPECT_EQ(TaskQueue::kNormalPriority, task_queues_[i]->GetQueuePriority()) in SetUp()
178 TaskQueue::Spec("test")); in NewTaskQueueWithBlockReporting()
204 TaskQueue::kHighestPriority); in TEST_F()
217 TaskQueue::kHighestPriority); in TEST_F()
218 selector_.SetQueuePriority(task_queues_[1].get(), TaskQueue::kHighPriority); in TEST_F()
219 selector_.SetQueuePriority(task_queues_[0].get(), TaskQueue::kLowPriority); in TEST_F()
230 selector_.SetQueuePriority(task_queues_[2].get(), TaskQueue::kLowPriority); in TEST_F()
[all …]
|
| D | task_queue_impl.h | 76 const TaskQueue::Spec& spec);
107 class BASE_EXPORT Task : public TaskQueue::Task {
109 Task(TaskQueue::PostedTask task,
113 Task(TaskQueue::PostedTask task,
151 PostTaskResult(bool success, TaskQueue::PostedTask task);
157 static PostTaskResult Fail(TaskQueue::PostedTask task);
160 TaskQueue::PostedTask task;
176 RepeatingCallback<void(const TaskQueue::Task&,
177 const TaskQueue::TaskTiming&)>;
179 RepeatingCallback<void(const TaskQueue::Task&,
[all …]
|
| D | task_queue_selector.h | 45 TaskQueue::QueuePriority priority);
80 TaskQueue::QueuePriority priority);
82 TaskQueue::QueuePriority priority);
85 bool SelectWorkQueueToService(TaskQueue::QueuePriority max_priority,
103 bool ChooseOldestWithPriority(TaskQueue::QueuePriority priority,
113 TaskQueue::QueuePriority priority,
116 bool ChooseOldestDelayedTaskWithPriority(TaskQueue::QueuePriority priority,
125 TaskQueue::QueuePriority priority,
196 static TaskQueue::QueuePriority NextPriority(
197 TaskQueue::QueuePriority priority);
[all …]
|
| D | task_queue_impl.cc | 21 const char* TaskQueue::PriorityToString(TaskQueue::QueuePriority priority) { in PriorityToString()
45 const TaskQueue::Spec& spec) in TaskQueueImpl()
71 TaskQueue::PostedTask task) in PostTaskResult()
80 return PostTaskResult(true, TaskQueue::PostedTask(OnceClosure(), Location())); in Success()
84 TaskQueue::PostedTask task) { in Fail()
88 TaskQueueImpl::Task::Task(TaskQueue::PostedTask task, in Task()
91 : TaskQueue::Task(std::move(task), desired_run_time) { in Task()
96 TaskQueueImpl::Task::Task(TaskQueue::PostedTask task, in Task()
100 : TaskQueue::Task(std::move(task), desired_run_time), in Task()
187 TaskQueue::PostedTask task) { in PostDelayedTask()
[all …]
|
| D | sequence_manager_impl_unittest.cc | 68 TaskQueue::Spec spec = TaskQueue::Spec("test")) { in CreateTaskQueue()
182 scoped_refptr<TaskQueue> default_task_queue = in SetUpWithMessagePump()
183 manager_->CreateTaskQueue<TestTaskQueue>(TaskQueue::Spec("default")); in SetUpWithMessagePump()
281 TaskQueue::QueueEnabledVoter* voter) { in DisableQueueTestTask()
373 task_queue->InsertFence(TaskQueue::InsertFencePosition::kNow); in InsertFenceAndPostTestTask()
421 std::unique_ptr<TaskQueue::QueueEnabledVoter> voter = in TEST_P()
594 runners_[0]->InsertFence(TaskQueue::InsertFencePosition::kNow); in TEST_P()
616 std::unique_ptr<TaskQueue::QueueEnabledVoter> voter = in TEST_P()
619 runners_[0]->InsertFence(TaskQueue::InsertFencePosition::kNow); in TEST_P()
630 std::unique_ptr<TaskQueue::QueueEnabledVoter> voter = in TEST_P()
[all …]
|
| D | task_queue.h | 35 class BASE_EXPORT TaskQueue : public SingleThreadTaskRunner {
50 virtual void OnQueueNextWakeUpChanged(TaskQueue* queue,
325 TaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl,
326 const TaskQueue::Spec& spec);
327 ~TaskQueue() override;
362 DISALLOW_COPY_AND_ASSIGN(TaskQueue);
|
| D | time_domain_unittest.cc | 27 const TaskQueue::Spec& spec) in TaskQueueImplForTest()
77 nullptr, time_domain_.get(), TaskQueue::Spec("test")); in SetUp()
142 TaskQueue::Spec("test")); in TEST_F()
146 TaskQueue::Spec("test")); in TEST_F()
150 TaskQueue::Spec("test")); in TEST_F()
191 TaskQueue::Spec("test")); in TEST_F()
254 TaskQueue::Spec("test")); in TEST_F()
289 TaskQueue::Spec("test")); in TEST_F()
|
| D | sequence_manager_impl.h | 50 class TaskQueue; variable
176 TaskQueue::TaskTiming task_timing) in ExecutingTask()
183 TaskQueue::TaskTiming task_timing;
280 const TaskQueue::Spec& spec) override;
291 TaskQueue::TaskTiming InitializeTaskTiming(
|
| D | work_queue_sets_unittest.cc | 42 work_queue_sets_->AddQueue(queue, TaskQueue::kControlPriority); in NewTaskQueue()
48 TaskQueue::PostedTask(BindOnce([] {}), FROM_HERE), TimeTicks(), in FakeTaskWithEnqueueOrder()
55 TaskQueue::PostedTask(BindOnce([] {}), FROM_HERE), TimeTicks(), in FakeNonNestableTaskWithEnqueueOrder()
67 size_t set = TaskQueue::kNormalPriority; in TEST_F()
75 size_t set = TaskQueue::kNormalPriority; in TEST_F()
85 size_t set = TaskQueue::kNormalPriority; in TEST_F()
292 size_t set = TaskQueue::kControlPriority; in TEST_F()
|
| /external/webrtc/rtc_base/ |
| D | task_queue.cc | 16 TaskQueue::TaskQueue( in TaskQueue() function in rtc::TaskQueue
20 TaskQueue::~TaskQueue() { in ~TaskQueue()
28 bool TaskQueue::IsCurrent() const { in IsCurrent()
32 void TaskQueue::PostTask(std::unique_ptr<webrtc::QueuedTask> task) { in PostTask()
36 void TaskQueue::PostDelayedTask(std::unique_ptr<webrtc::QueuedTask> task, in PostDelayedTask()
|
| D | task_queue.h | 76 class RTC_LOCKABLE RTC_EXPORT TaskQueue {
82 explicit TaskQueue(std::unique_ptr<webrtc::TaskQueueBase,
84 ~TaskQueue();
129 RTC_DISALLOW_COPY_AND_ASSIGN(TaskQueue);
|
| /external/webrtc/modules/audio_processing/aec_dump/ |
| D | aec_dump_factory.h | 22 class TaskQueue; variable
37 rtc::TaskQueue* worker_queue);
40 rtc::TaskQueue* worker_queue);
43 rtc::TaskQueue* worker_queue);
|
| D | null_aec_dump_factory.cc | 18 rtc::TaskQueue* worker_queue) { in Create()
24 rtc::TaskQueue* worker_queue) { in Create()
30 rtc::TaskQueue* worker_queue) { in Create()
|
| D | aec_dump_impl.h | 37 class TaskQueue; in RTC_POP_IGNORING_WUNDEF() local
49 rtc::TaskQueue* worker_queue);
83 rtc::TaskQueue* worker_queue_;
|
| /external/llvm-project/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 34 class TaskQueue {
42 explicit Task(Callable C, TaskQueue &Parent) in Task()
64 TaskQueue *Parent;
69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() function
72 ~TaskQueue() { in ~TaskQueue()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 34 class TaskQueue {
42 explicit Task(Callable C, TaskQueue &Parent) in Task()
64 TaskQueue *Parent;
69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() function
72 ~TaskQueue() { in ~TaskQueue()
|
| /external/webrtc/test/time_controller/ |
| D | external_time_controller_unittest.cc | 91 rtc::TaskQueue task_queue( in TEST()
117 rtc::TaskQueue task_queue( in TEST()
137 rtc::TaskQueue task_queue( in TEST()
150 rtc::TaskQueue task_queue( in TEST()
153 rtc::TaskQueue other_queue( in TEST()
170 rtc::TaskQueue task_queue( in TEST()
|
| D | simulated_time_controller_unittest.cc | 41 rtc::TaskQueue task_queue( in TEST()
66 rtc::TaskQueue task_queue( in TEST()
88 rtc::TaskQueue* task_queue) { in TEST()
96 rtc::TaskQueue task_queue( in TEST()
119 rtc::TaskQueue task_queue( in TEST()
|
| /external/libchrome/base/task/sequence_manager/test/ |
| D | test_task_queue.h | 14 class TestTaskQueue : public TaskQueue {
17 const TaskQueue::Spec& spec);
19 using TaskQueue::GetTaskQueueImpl;
|
| D | test_task_queue.cc | 13 const TaskQueue::Spec& spec) in TestTaskQueue()
14 : TaskQueue(std::move(impl), spec), weak_factory_(this) {} in TestTaskQueue()
|
| /external/webrtc/test/network/ |
| D | network_emulation.h | 41 rtc::TaskQueue* task_queue, in LinkEmulation()
59 rtc::TaskQueue* const task_queue_;
70 explicit NetworkRouterNode(rtc::TaskQueue* task_queue);
80 rtc::TaskQueue* const task_queue_;
102 rtc::TaskQueue* task_queue,
135 rtc::TaskQueue* task_queue,
180 rtc::TaskQueue* const task_queue_;
|
| /external/libchrome/base/message_loop/ |
| D | incoming_task_queue.h | 168 TaskQueue queue_;
215 TaskQueue queue_;
236 void ReloadWorkQueue(TaskQueue* work_queue);
258 TaskQueue incoming_queue_;
|
| /external/webrtc/video/adaptation/ |
| D | quality_scaler_resource_unittest.cc | 33 rtc::TaskQueue* encoder_queue) in FakeQualityScalerQpUsageHandlerCallback()
59 rtc::TaskQueue* const encoder_queue_;
112 rtc::TaskQueue resource_adaptation_queue_;
113 rtc::TaskQueue encoder_queue_;
|