| /external/cronet/base/task/sequence_manager/ |
| D | work_queue_sets.cc | 29 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue()
44 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue()
57 void WorkQueueSets::ChangeSetIndex(WorkQueue* work_queue, size_t set_index) { in ChangeSetIndex()
77 void WorkQueueSets::OnQueuesFrontTaskChanged(WorkQueue* work_queue) { in OnQueuesFrontTaskChanged()
96 void WorkQueueSets::OnTaskPushedToEmptyQueue(WorkQueue* work_queue) { in OnTaskPushedToEmptyQueue()
113 void WorkQueueSets::OnPopMinQueueInSet(WorkQueue* work_queue) { in OnPopMinQueueInSet()
137 void WorkQueueSets::OnQueueBlocked(WorkQueue* work_queue) { in OnQueueBlocked()
|
| D | work_queue_sets_unittest.cc | 108 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
115 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
122 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
133 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
141 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
322 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
331 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
|
| D | work_queue.cc | 94 WorkQueue::TaskPusher::TaskPusher(WorkQueue* work_queue) in TaskPusher()
|
| /external/libchrome/base/task/sequence_manager/ |
| 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()
|
| D | work_queue_unittest.cc | 137 WorkQueue* work_queue; in TEST_F() local
147 WorkQueue* work_queue; in TEST_F() local
155 WorkQueue* work_queue; in TEST_F() local
172 WorkQueue* work_queue; in TEST_F() local
182 WorkQueue* work_queue; in TEST_F() local
195 WorkQueue* work_queue; in TEST_F() local
216 WorkQueue* work_queue; in TEST_F() local
236 WorkQueue* work_queue; in TEST_F() local
254 WorkQueue* work_queue; in TEST_F() local
346 WorkQueue* work_queue; in TEST_F() local
|
| D | work_queue_sets_unittest.cc | 66 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
74 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
84 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
100 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
111 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
264 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
273 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
|
| /external/tensorflow/tensorflow/core/tfrt/runtime/ |
| D | work_queue_interface.cc | 28 tfrt::ConcurrentWorkQueue* work_queue) in DefaultWorkQueueWrapperBase()
69 std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue) in DefaultWorkQueueWrapper()
75 DefaultWorkQueueWrapper(std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue, in DefaultWorkQueueWrapper()
103 std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue) { in WrapDefaultWorkQueue()
108 std::unique_ptr<tfrt::ConcurrentWorkQueue> work_queue, in WrapDefaultWorkQueue()
|
| D | runtime.cc | 130 std::unique_ptr<WorkQueueInterface> work_queue) { in Create()
159 WorkQueueInterface* work_queue) in Runtime()
|
| D | runtime.h | 64 WorkQueueInterface* work_queue() const { return work_queue_; } in work_queue() function
|
| /external/pigweed/pw_work_queue/ |
| D | work_queue_test.cc | 24 namespace pw::work_queue { namespace
33 WorkQueueWithBuffer<10> work_queue; in TEST() local
71 WorkQueueWithBuffer<10> work_queue; in TEST() local
|
| D | stl_test_thread.cc | 18 namespace pw::work_queue::test { namespace
|
| D | work_queue.cc | 21 namespace pw::work_queue { namespace
|
| /external/pigweed/pw_system/ |
| D | work_queue.cc | 27 static pw::work_queue::WorkQueueWithBuffer<kMaxWorkQueueEntries> work_queue; in GetWorkQueue() local
|
| /external/pigweed/pw_software_update/public/pw_software_update/ |
| D | bundled_update_service.h | 35 work_queue::WorkQueue& work_queue) in BundledUpdateService() argument
|
| D | bundled_update_service_pwpb.h | 38 work_queue::WorkQueue& work_queue) in BundledUpdateService() argument
|
| /external/tensorflow/tensorflow/core/tfrt/graph_executor/ |
| D | graph_executor.cc | 84 tensorflow::tfrt_stub::WorkQueueInterface* work_queue, in SetUpRequestContext()
466 tensorflow::tfrt_stub::WorkQueueInterface* work_queue) { in LoadClientGraph()
527 tensorflow::tfrt_stub::WorkQueueInterface* work_queue) { in InitBef()
558 tensorflow::tfrt_stub::WorkQueueInterface* work_queue) { in GetOrCreateLoadedClientGraph()
|
| D | graph_execution_options.h | 73 tensorflow::tfrt_stub::WorkQueueInterface* work_queue = nullptr; member
|
| /external/llvm/utils/ |
| D | llvm-compilers-check | 255 def __init__(self, work_queue, jobs, argument
595 work_queue = queue.Queue() variable
|
| /external/tensorflow/tensorflow/core/tfrt/common/ |
| D | global_state.cc | 34 std::unique_ptr<::tfrt::ConcurrentWorkQueue> work_queue = in GetStaticHostContext() local
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_rma_distributed.h | 31 std::shared_ptr<UnboundedWorkQueue> work_queue, in CollectiveRemoteAccessDistributed()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | base_collective_executor.h | 101 std::shared_ptr<UnboundedWorkQueue> work_queue) in BaseCollectiveExecutor()
|
| D | collective_test_util.h | 80 std::shared_ptr<UnboundedWorkQueue> work_queue; member
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | bef_thunk.cc | 86 tensorflow::tfrt_stub::WorkQueueInterface* work_queue; member
184 auto work_queue = tensorflow::tfrt_stub::WrapDefaultWorkQueue( in GetCoreRuntimeAndWorkQueue() local
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | convert_mover.cc | 151 std::deque<HloInstruction*> work_queue; in MoveConvertPrecisionOps() local
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | thread.py | 69 def _worker(executor_reference, work_queue, initializer, initargs): argument
|