| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue_sets.cc | 18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue() argument
19 DCHECK(!work_queue->work_queue_sets()); in AddQueue()
22 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); in AddQueue()
23 work_queue->AssignToWorkQueueSets(this); in AddQueue()
24 work_queue->AssignSetIndex(set_index); in AddQueue()
27 work_queue_heaps_[set_index].insert({enqueue_order, work_queue}); in AddQueue()
30 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue() argument
31 DCHECK_EQ(this, work_queue->work_queue_sets()); in RemoveQueue()
32 work_queue->AssignToWorkQueueSets(nullptr); in RemoveQueue()
33 HeapHandle heap_handle = work_queue->heap_handle(); in RemoveQueue()
[all …]
|
| D | work_queue_sets_unittest.cc | 27 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) { in TearDown()
28 if (work_queue->work_queue_sets()) in TearDown()
29 work_queue_sets_->RemoveQueue(work_queue.get()); in TearDown()
66 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
68 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
70 EXPECT_EQ(set, work_queue->work_queue_set_index()); in TEST_F()
74 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
76 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
84 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
86 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
[all …]
|
| D | work_queue_unittest.cc | 137 WorkQueue* work_queue; in TEST_F() local
138 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
141 EXPECT_TRUE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
142 EXPECT_EQ(work_queue_.get(), work_queue); in TEST_F()
147 WorkQueue* work_queue; in TEST_F() local
148 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
151 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
155 WorkQueue* work_queue; in TEST_F() local
156 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
160 EXPECT_TRUE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
[all …]
|
| D | work_queue_sets.h | 38 void RemoveQueue(WorkQueue* work_queue);
47 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
51 void OnPopQueue(WorkQueue* work_queue);
54 void OnQueueBlocked(WorkQueue* work_queue);
|
| /external/cronet/stable/base/task/sequence_manager/ |
| D | work_queue_sets.cc | 30 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue() argument
31 DCHECK(!work_queue->work_queue_sets()); in AddQueue()
33 DCHECK(!work_queue->heap_handle().IsValid()); in AddQueue()
34 std::optional<TaskOrder> key = work_queue->GetFrontTaskOrder(); in AddQueue()
35 work_queue->AssignToWorkQueueSets(this); in AddQueue()
36 work_queue->AssignSetIndex(set_index); in AddQueue()
40 work_queue_heaps_[set_index].insert({*key, work_queue}); in AddQueue()
45 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue() argument
46 DCHECK_EQ(this, work_queue->work_queue_sets()); in RemoveQueue()
47 work_queue->AssignToWorkQueueSets(nullptr); in RemoveQueue()
[all …]
|
| D | work_queue_sets_unittest.cc | 59 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) { in TearDown()
60 if (work_queue->work_queue_sets()) in TearDown()
61 work_queue_sets_->RemoveQueue(work_queue.get()); in TearDown()
113 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
115 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
116 EXPECT_EQ(set, work_queue->work_queue_set_index()); in TEST_F()
120 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
122 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
127 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
129 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
[all …]
|
| D | work_queue_sets.h | 31 WorkQueueAndTaskOrder(WorkQueue& work_queue, const TaskOrder& task_order) in WorkQueueAndTaskOrder()
32 : queue(&work_queue), order(task_order) {} in WorkQueueAndTaskOrder()
63 void RemoveQueue(WorkQueue* work_queue);
72 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
77 void OnPopMinQueueInSet(WorkQueue* work_queue);
80 void OnQueueBlocked(WorkQueue* work_queue);
|
| /external/cronet/tot/base/task/sequence_manager/ |
| D | work_queue_sets.cc | 30 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue() argument
31 DCHECK(!work_queue->work_queue_sets()); in AddQueue()
33 DCHECK(!work_queue->heap_handle().IsValid()); in AddQueue()
34 std::optional<TaskOrder> key = work_queue->GetFrontTaskOrder(); in AddQueue()
35 work_queue->AssignToWorkQueueSets(this); in AddQueue()
36 work_queue->AssignSetIndex(set_index); in AddQueue()
40 work_queue_heaps_[set_index].insert({*key, work_queue}); in AddQueue()
45 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue() argument
46 DCHECK_EQ(this, work_queue->work_queue_sets()); in RemoveQueue()
47 work_queue->AssignToWorkQueueSets(nullptr); in RemoveQueue()
[all …]
|
| D | work_queue_sets_unittest.cc | 59 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) { in TearDown()
60 if (work_queue->work_queue_sets()) in TearDown()
61 work_queue_sets_->RemoveQueue(work_queue.get()); in TearDown()
113 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
115 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
116 EXPECT_EQ(set, work_queue->work_queue_set_index()); in TEST_F()
120 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
122 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
127 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
129 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
[all …]
|
| D | work_queue_sets.h | 31 WorkQueueAndTaskOrder(WorkQueue& work_queue, const TaskOrder& task_order) in WorkQueueAndTaskOrder()
32 : queue(&work_queue), order(task_order) {} in WorkQueueAndTaskOrder()
63 void RemoveQueue(WorkQueue* work_queue);
72 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
77 void OnPopMinQueueInSet(WorkQueue* work_queue);
80 void OnQueueBlocked(WorkQueue* work_queue);
|
| /external/pigweed/pw_work_queue/ |
| D | work_queue_test.cc | 24 namespace pw::work_queue { namespace
33 WorkQueueWithBuffer<10> work_queue; in TEST() local
36 Thread work_thread(test::WorkQueueThreadOptions(), work_queue); in TEST()
43 EXPECT_EQ(OkStatus(), work_queue.PushWork([&context] { in TEST()
50 EXPECT_EQ(OkStatus(), work_queue.PushWork([] { in TEST()
59 work_queue.RequestStop(); in TEST()
71 WorkQueueWithBuffer<10> work_queue; in TEST() local
74 Thread work_thread(test::WorkQueueThreadOptions(), work_queue); in TEST()
83 work_queue.PushWork([] { PW_LOG_INFO("Chopping onions"); })); in TEST()
86 EXPECT_EQ(OkStatus(), work_queue.PushWork([&context_a] { in TEST()
[all …]
|
| D | docs.rst | 19 #include "pw_work_queue/work_queue.h"
21 pw::work_queue::WorkQueueWithBuffer<10> work_queue;
28 // the work_queue executes it on the interrupt's behalf.
29 work_queue.CheckPushWork(SomeLongRunningProcessing);
33 // Start up the work_queue as a detached thread which runs forever.
34 pw::thread::DetachedThread(WorkQueueThreadOptions(), work_queue);
40 .. doxygennamespace:: pw::work_queue
|
| /external/tensorflow/tensorflow/core/tfrt/runtime/ |
| D | work_queue_interface.cc | 28 tfrt::ConcurrentWorkQueue* work_queue) in DefaultWorkQueueWrapperBase() argument
29 : id_(id), work_queue_(work_queue) {} in DefaultWorkQueueWrapperBase()
69 std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue) in DefaultWorkQueueWrapper() argument
70 : DefaultWorkQueueWrapperBase(/*id=*/0, work_queue.get()), in DefaultWorkQueueWrapper()
71 work_queue_(std::move(work_queue)) {} in DefaultWorkQueueWrapper()
75 DefaultWorkQueueWrapper(std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue, in DefaultWorkQueueWrapper() argument
77 : DefaultWorkQueueWrapperBase(/*id=*/0, work_queue.get()), in DefaultWorkQueueWrapper()
78 work_queue_(std::move(work_queue)), in DefaultWorkQueueWrapper()
103 std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue) { in WrapDefaultWorkQueue() argument
104 return std::make_unique<DefaultWorkQueueWrapper>(std::move(work_queue)); in WrapDefaultWorkQueue()
[all …]
|
| D | runtime.cc | 130 std::unique_ptr<WorkQueueInterface> work_queue) { in Create() argument
131 auto* work_queue_ptr = work_queue.get(); in Create()
134 tfrt::CreateMallocAllocator(), std::move(work_queue), in Create()
159 WorkQueueInterface* work_queue) in Runtime() argument
160 : core_runtime_(std::move(core_runtime)), work_queue_(work_queue) { in Runtime()
|
| /external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_ml2.cpp | 18 std::vector< std::function<void()> > work_queue; in main() local
24 work_queue.push_back( [=] in main()
33 work_queue.push_back(inner); in main()
43 while( !work_queue.empty() ) in main()
46 auto work = work_queue.back(); in main()
49 work = work_queue.back(); in main()
51 work_queue.pop_back(); in main()
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/ |
| D | user_scheduler.hpp | 31 sync_queue<work > work_queue; member in boost::user_scheduler
44 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
121 work_queue.close(); in close()
129 return work_queue.closed(); in closed()
149 work_queue.push(boost::move(w)); in submit()
156 work_queue.push(boost::move(w)); in submit()
164 work_queue.push(boost::move(w)); in submit()
189 sync_queue<work>::underlying_queue_type q = work_queue.underlying_queue(); in run_queued_closures()
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/executors/ |
| D | loop_executor.hpp | 38 concurrent::sync_queue<work > work_queue; member in boost::executors::loop_executor
66 work_queue.wait_pull(task) : in execute_one()
67 work_queue.try_pull(task); in execute_one()
126 work_queue.close(); in close()
134 return work_queue.closed(); in closed()
149 work_queue.push(boost::move(closure)); in submit()
195 sync_queue<work>::underlying_queue_type q = work_queue.underlying_queue(); in run_queued_closures()
|
| D | serial_executor.hpp | 44 concurrent::sync_queue<work > work_queue; member in boost::executors::serial_executor
80 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
154 work_queue.close(); in close()
162 return work_queue.closed(); in closed()
178 work_queue.push(boost::move(closure)); in submit()
|
| D | basic_thread_pool.hpp | 42 concurrent::sync_queue<work > work_queue; member in boost::executors::basic_thread_pool
55 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
93 queue_op_status st = work_queue.wait_pull(task); in worker_thread()
280 work_queue.close(); in close()
288 return work_queue.closed(); in closed()
303 work_queue.push(boost::move(closure)); in submit()
|
| /external/tensorflow/tensorflow/core/tfrt/graph_executor/ |
| D | graph_executor.cc | 84 tensorflow::tfrt_stub::WorkQueueInterface* work_queue, in SetUpRequestContext() argument
88 DCHECK(work_queue); in SetUpRequestContext()
92 int64_t request_id = work_queue->id(); in SetUpRequestContext()
104 work_queue->InitializeRequest(&request_context_builder, in SetUpRequestContext()
111 auto* inter_op_queue = request_queue ? request_queue.get() : work_queue; in SetUpRequestContext()
155 run_options.work_queue ? run_options.work_queue in GraphExecutionRunOnFunction()
156 : runtime.work_queue(), in GraphExecutionRunOnFunction()
185 if (run_options.work_queue) { in GraphExecutionRunOnFunction()
188 exec_ctx.set_work_queue(run_options.work_queue); in GraphExecutionRunOnFunction()
192 exec_ctx.set_work_queue(runtime.work_queue()); in GraphExecutionRunOnFunction()
[all …]
|
| /external/pigweed/pw_system/ |
| D | work_queue.cc | 24 work_queue::WorkQueue& GetWorkQueue() { in GetWorkQueue()
27 static pw::work_queue::WorkQueueWithBuffer<kMaxWorkQueueEntries> work_queue; in GetWorkQueue() local
28 return work_queue; in GetWorkQueue()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | convert_mover.cc | 151 std::deque<HloInstruction*> work_queue; in MoveConvertPrecisionOps() local
153 work_queue.insert(work_queue.end(), instrs.rbegin(), instrs.rend()); in MoveConvertPrecisionOps()
154 while (!work_queue.empty()) { in MoveConvertPrecisionOps()
155 HloInstruction* instr = work_queue.front(); in MoveConvertPrecisionOps()
156 work_queue.pop_front(); in MoveConvertPrecisionOps()
176 work_queue.push_front(MakeConvertToHlo(operand, dst_ty)); in MoveConvertPrecisionOps()
177 new_operands.push_back(work_queue.front()); in MoveConvertPrecisionOps()
|
| /external/pigweed/pw_software_update/public/pw_software_update/ |
| D | bundled_update_service.h | 37 work_queue::WorkQueue& work_queue) in BundledUpdateService() argument
44 work_queue_(work_queue),
101 work_queue::WorkQueue& work_queue_ PW_GUARDED_BY(mutex_);
|
| D | bundled_update_service_pwpb.h | 38 work_queue::WorkQueue& work_queue) in BundledUpdateService() argument
44 work_queue_(work_queue),
99 work_queue::WorkQueue& work_queue_ PW_GUARDED_BY(mutex_);
|
| /external/pigweed/pw_uart/ |
| D | blocking_adapter_test.cc | 250 work_queue::WorkQueueWithBuffer<2> work_queue; member in pw::uart::__anon30c296480111::BlockingAdapterTest
270 work_queue); in StartWorkQueueThread()
276 work_queue.RequestStop(); in StopWorkQueueThread()
322 work_queue.CheckPushWork([this]() { in TEST_F()
343 work_queue.CheckPushWork([this]() { in TEST_F()
364 work_queue.CheckPushWork([this]() { in TEST_F()
385 work_queue.CheckPushWork([this]() { in TEST_F()
403 work_queue.CheckPushWork([this]() { in TEST_F()
|