| /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 | 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()
|
| 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 | sequence_manager.h | 111 scoped_refptr<TaskQueueType> CreateTaskQueue(const TaskQueue::Spec& spec, in CreateTaskQueue()
119 const TaskQueue::Spec& spec) = 0;
|
| /external/v8/src/libplatform/ |
| D | task-queue.cc | 15 TaskQueue::TaskQueue() : process_queue_semaphore_(0), terminated_(false) {} in TaskQueue() function in v8::platform::TaskQueue
18 TaskQueue::~TaskQueue() { in ~TaskQueue()
24 void TaskQueue::Append(std::unique_ptr<Task> task) { in Append()
31 std::unique_ptr<Task> TaskQueue::GetNext() { in GetNext()
50 void TaskQueue::Terminate() { in Terminate()
57 void TaskQueue::BlockUntilQueueEmptyForTesting() { in BlockUntilQueueEmptyForTesting()
|
| D | task-queue.h | 23 class V8_PLATFORM_EXPORT TaskQueue {
25 TaskQueue();
26 ~TaskQueue();
48 DISALLOW_COPY_AND_ASSIGN(TaskQueue);
|
| D | worker-thread.h | 19 class TaskQueue; variable
23 explicit WorkerThread(TaskQueue* queue); in NON_EXPORTED_BASE()
30 TaskQueue* queue_; in NON_EXPORTED_BASE()
|
| D | worker-thread.cc | 13 WorkerThread::WorkerThread(TaskQueue* queue) in WorkerThread()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 35 class TaskQueue {
43 explicit Task(Callable C, TaskQueue &Parent) in Task()
65 TaskQueue *Parent;
70 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() function
73 ~TaskQueue() { in ~TaskQueue()
|
| /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()
|
| D | fake_task.h | 13 class FakeTask : public TaskQueue::Task {
18 class FakeTaskTiming : public TaskQueue::TaskTiming {
|
| D | fake_task.cc | 11 : TaskQueue::Task(TaskQueue::PostedTask(OnceClosure(), FROM_HERE), in FakeTask()
|
| /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/swiftshader/third_party/llvm-7.0/llvm/unittests/Support/ |
| D | TaskQueueTest.cpp | 27 TaskQueue TQ(TP); in TEST_F()
71 TaskQueue TQ(TP); in TEST_F()
101 TaskQueue TQ(TP); in TEST_F()
|
| /external/swiftshader/third_party/marl/src/ |
| D | non_marl_bench.cpp | 124 using TaskQueue = std::vector<Task>; in MultiQueueTaskExecutor() typedef
131 std::vector<TaskQueue> taskQueues(numQueues); in MultiQueueTaskExecutor()
|
| /external/vogar/src/vogar/ |
| D | Run.java | 38 import vogar.tasks.TaskQueue;
103 public final TaskQueue taskQueue;
184 this.taskQueue = new TaskQueue(console, maxConcurrentActions); in Run()
|