| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue_sets_unittest.cc | 27 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) { in TearDown()
38 WorkQueue* NewTaskQueue(const char* queue_name) { in NewTaskQueue()
39 WorkQueue* queue = in NewTaskQueue()
40 new WorkQueue(nullptr, "test", WorkQueue::QueueType::kImmediate); in NewTaskQueue()
61 std::vector<std::unique_ptr<WorkQueue>> work_queues_;
66 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F()
74 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F()
78 WorkQueue* selected_work_queue; in TEST_F()
84 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F()
88 WorkQueue* selected_work_queue; in TEST_F()
[all …]
|
| D | work_queue.cc | 13 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() function in base::sequence_manager::internal::WorkQueue
18 void WorkQueue::AsValueInto(TimeTicks now, in AsValueInto()
25 WorkQueue::~WorkQueue() { in ~WorkQueue()
30 const TaskQueueImpl::Task* WorkQueue::GetFrontTask() const { in GetFrontTask()
36 const TaskQueueImpl::Task* WorkQueue::GetBackTask() const { in GetBackTask()
42 bool WorkQueue::BlockedByFence() const { in BlockedByFence()
52 bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const { in GetFrontTaskEnqueueOrder()
63 void WorkQueue::Push(TaskQueueImpl::Task task) { in Push()
83 void WorkQueue::PushNonNestableTaskToFront(TaskQueueImpl::Task task) { in PushNonNestableTaskToFront()
117 void WorkQueue::ReloadEmptyImmediateQueue() { in ReloadEmptyImmediateQueue()
[all …]
|
| D | work_queue_sets.h | 35 void AddQueue(WorkQueue* queue, size_t set_index);
38 void RemoveQueue(WorkQueue* work_queue);
41 void ChangeSetIndex(WorkQueue* queue, size_t set_index);
44 void OnFrontTaskChanged(WorkQueue* queue);
47 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
51 void OnPopQueue(WorkQueue* work_queue);
54 void OnQueueBlocked(WorkQueue* work_queue);
57 bool GetOldestQueueInSet(size_t set_index, WorkQueue** out_work_queue) const;
62 WorkQueue** out_work_queue,
71 bool ContainsWorkQueueForTest(const WorkQueue* queue) const;
[all …]
|
| D | work_queue_sets.cc | 18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue()
30 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue()
41 void WorkQueueSets::ChangeSetIndex(WorkQueue* work_queue, size_t set_index) { in ChangeSetIndex()
56 void WorkQueueSets::OnFrontTaskChanged(WorkQueue* work_queue) { in OnFrontTaskChanged()
65 void WorkQueueSets::OnTaskPushedToEmptyQueue(WorkQueue* work_queue) { in OnTaskPushedToEmptyQueue()
80 void WorkQueueSets::OnPopQueue(WorkQueue* work_queue) { in OnPopQueue()
101 void WorkQueueSets::OnQueueBlocked(WorkQueue* work_queue) { in OnQueueBlocked()
112 WorkQueue** out_work_queue) const { in GetOldestQueueInSet()
124 WorkQueue** out_work_queue, in GetOldestQueueAndEnqueueOrderInSet()
146 const WorkQueue* work_queue) const { in ContainsWorkQueueForTest()
|
| D | task_queue_selector.h | 52 bool SelectWorkQueueToService(WorkQueue** out_work_queue);
86 WorkQueue** out_work_queue,
105 WorkQueue** out_work_queue) const;
114 WorkQueue** out_work_queue) const;
117 WorkQueue** out_work_queue) const;
127 WorkQueue** out_work_queue) const;
199 bool SelectWorkQueueToServiceInternal(WorkQueue** out_work_queue);
|
| D | task_queue_selector_unittest.cc | 134 WorkQueue* chosen_work_queue; in PopTasks()
337 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
371 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
387 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
407 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
436 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
465 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
488 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
514 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
534 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
[all …]
|
| D | work_queue.h | 31 class BASE_EXPORT WorkQueue {
36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type);
37 ~WorkQueue();
106 bool ShouldRunBefore(const WorkQueue* other_queue) const;
145 DISALLOW_COPY_AND_ASSIGN(WorkQueue);
|
| D | work_queue_unittest.cc | 41 work_queue_.reset(new WorkQueue(task_queue_.get(), "test", in SetUp()
42 WorkQueue::QueueType::kImmediate)); in SetUp()
78 std::unique_ptr<WorkQueue> work_queue_;
137 WorkQueue* work_queue; in TEST_F()
147 WorkQueue* work_queue; in TEST_F()
155 WorkQueue* work_queue; in TEST_F()
172 WorkQueue* work_queue; in TEST_F()
182 WorkQueue* work_queue; in TEST_F()
195 WorkQueue* work_queue; in TEST_F()
216 WorkQueue* work_queue; in TEST_F()
[all …]
|
| D | task_queue_impl.h | 37 class WorkQueue; variable
232 WorkQueue* delayed_work_queue() { in delayed_work_queue()
236 const WorkQueue* delayed_work_queue() const { in delayed_work_queue()
240 WorkQueue* immediate_work_queue() { in immediate_work_queue()
244 const WorkQueue* immediate_work_queue() const { in immediate_work_queue()
319 friend class WorkQueue;
350 std::unique_ptr<WorkQueue> delayed_work_queue;
351 std::unique_ptr<WorkQueue> immediate_work_queue;
|
| D | task_queue_selector.cc | 157 WorkQueue** out_work_queue) const { in ChooseOldestImmediateTaskWithPriority()
164 WorkQueue** out_work_queue) const { in ChooseOldestDelayedTaskWithPriority()
172 WorkQueue** out_work_queue) const { in ChooseOldestImmediateOrDelayedTaskWithPriority()
173 WorkQueue* immediate_queue; in ChooseOldestImmediateOrDelayedTaskWithPriority()
178 WorkQueue* delayed_queue; in ChooseOldestImmediateOrDelayedTaskWithPriority()
199 WorkQueue** out_work_queue) const { in ChooseOldestWithPriority()
213 WorkQueue** out_work_queue, in SelectWorkQueueToService()
291 bool TaskQueueSelector::SelectWorkQueueToService(WorkQueue** out_work_queue) { in SelectWorkQueueToService()
|
| D | task_queue_impl.cc | 119 new WorkQueue(task_queue, "delayed", WorkQueue::QueueType::kDelayed)), in MainThreadOnly()
120 immediate_work_queue(new WorkQueue(task_queue, in MainThreadOnly()
122 WorkQueue::QueueType::kImmediate)), in MainThreadOnly()
172 std::unique_ptr<WorkQueue> immediate_work_queue = in UnregisterTaskQueue()
174 std::unique_ptr<WorkQueue> delayed_work_queue = in UnregisterTaskQueue()
|
| D | sequence_manager_impl.h | 259 internal::WorkQueue* selected_work_queue) const;
|
| D | sequence_manager_impl.cc | 322 internal::WorkQueue* work_queue = nullptr; in TakeTask()
577 internal::WorkQueue* selected_work_queue) const { in AsValueWithSelectorResult()
|
| /external/libchrome/base/synchronization/ |
| D | condition_variable_unittest.cc | 69 class WorkQueue : public PlatformThread::Delegate { class
71 explicit WorkQueue(int thread_count);
72 ~WorkQueue() override;
259 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
409 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
502 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anon16d4e8c80111::WorkQueue
529 WorkQueue::~WorkQueue() { in ~WorkQueue()
542 int WorkQueue::GetThreadId() { in GetThreadId()
548 bool WorkQueue::EveryIdWasAllocated() const { in EveryIdWasAllocated()
553 TimeDelta WorkQueue::GetAnAssignment(int thread_id) { in GetAnAssignment()
[all …]
|
| /external/syzkaller/syz-fuzzer/ |
| D | workqueue.go | 17 type WorkQueue struct { struct
64 func newWorkQueue(procs int, needCandidates chan struct{}) *WorkQueue {
65 return &WorkQueue{
71 func (wq *WorkQueue) enqueue(item interface{}) { argument
90 func (wq *WorkQueue) dequeue() (item interface{}) { argument
127 func (wq *WorkQueue) wantCandidates() bool { argument
|
| D | fuzzer.go | 36 workQueue *WorkQueue
|
| /external/swiftshader/third_party/llvm-7.0/llvm/lib/Transforms/Scalar/ |
| D | EarlyCSE.cpp | 614 SmallVector<MemoryAccess *, 8> WorkQueue; in removeMSSA() local
615 WorkQueue.push_back(MA); in removeMSSA()
619 for (unsigned I = 0; I < WorkQueue.size(); ++I) { in removeMSSA()
620 MemoryAccess *WI = WorkQueue[I]; in removeMSSA()
632 WorkQueue.push_back(MP); in removeMSSA()
|