| /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 | 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 | 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_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;
|
| /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::__anon39cf34e60111::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/zstd/contrib/pzstd/utils/test/ |
| D | WorkQueueTest.cpp | 23 WorkQueue<int>* queue;
37 TEST(WorkQueue, SingleThreaded) { in TEST() argument
38 WorkQueue<int> queue; in TEST()
64 TEST(WorkQueue, SPSC) { in TEST() argument
65 WorkQueue<int> queue; in TEST()
92 TEST(WorkQueue, SPMC) { in TEST() argument
93 WorkQueue<int> queue; in TEST()
115 TEST(WorkQueue, MPMC) { in TEST() argument
116 WorkQueue<int> queue; in TEST()
150 TEST(WorkQueue, BoundedSizeWorks) { in TEST() argument
[all …]
|
| /external/rust/crates/grpcio/src/ |
| D | cq.rs | 143 pub struct WorkQueue { struct
148 unsafe impl Sync for WorkQueue {} argument
149 unsafe impl Send for WorkQueue {} implementation
153 impl WorkQueue { impl
154 pub fn new() -> WorkQueue { in new()
155 WorkQueue { in new()
190 pub(crate) worker: Arc<WorkQueue>,
194 pub fn new(handle: Arc<CompletionQueueHandle>, worker: Arc<WorkQueue>) -> CompletionQueue { in new()
|
| D | env.rs | 10 use crate::cq::{CompletionQueue, CompletionQueueHandle, EventType, WorkQueue};
16 let worker_info = Arc::new(WorkQueue::new()); in poll_queue()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | WorkQueueTest.kt | 28 val queue = WorkQueue() in <lambda>()
35 val queue = WorkQueue() in <lambda>()
48 val queue = WorkQueue() in <lambda>()
57 val victim = WorkQueue() in <lambda>()
63 val stealer = WorkQueue() in <lambda>()
74 internal fun WorkQueue.drain(): List<Long> { in drain()
|
| D | WorkQueueStressTest.kt | 21 private val producerQueue = WorkQueue()
55 val myQueue = WorkQueue() in testStealing()
91 val myQueue = WorkQueue() in testSingleProducerSingleStealer()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | WorkQueue.kt | 37 internal class WorkQueue { class
108 fun tryStealFrom(victim: WorkQueue): Long { in tryStealFrom()
119 fun tryStealBlockingFrom(victim: WorkQueue): Long { in tryStealBlockingFrom()
150 private fun tryStealLastScheduled(victim: WorkQueue, blockingOnly: Boolean): Long { in tryStealLastScheduled()
|
| /external/zstd/contrib/pzstd/ |
| D | Pzstd.h | 108 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks,
130 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames,
147 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs,
|
| D | Pzstd.cpp | 59 WorkQueue<std::shared_ptr<BufferWorkQueue>> outs{options.numThreads + 1}; in handleOneInput()
379 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks, in asyncCompressChunks()
494 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames, in asyncDecompressFrames()
571 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs, in writeFile()
|
| /external/zstd/contrib/pzstd/utils/ |
| D | WorkQueue.h | 26 class WorkQueue {
52 WorkQueue(std::size_t maxSize = 0) : done_(false), maxSize_(maxSize) {} in done_()
143 WorkQueue<Buffer> queue_;
|
| D | ThreadPool.h | 23 WorkQueue<std::function<void()>> tasks_;
|
| D | BUCK | 58 exported_headers=['WorkQueue.h'],
|
| /external/rust/crates/grpcio/src/task/ |
| D | executor.rs | 20 use crate::cq::{CompletionQueue, WorkQueue};
89 queue: Arc<WorkQueue>,
98 fn new(s: SpawnHandle, kicker: Kicker, queue: Arc<WorkQueue>) -> SpawnTask { in new()
|