/external/tensorflow/tensorflow/core/kernels/batching_util/ |
D | serial_device_batch_scheduler_test.cc | 124 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue1)); in TEST() 125 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue2)); in TEST() 126 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue3)); in TEST() 188 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 239 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue1)); in TEST() 241 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue2)); in TEST() 243 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue3)); in TEST() 281 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 335 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 372 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue1)); in TEST() [all …]
|
D | shared_batch_scheduler_test.cc | 105 scheduler->AddQueue(queue_options, queue_0_callback, &queue_0)); in TEST() 108 scheduler->AddQueue(queue_options, queue_1_callback, &queue_1)); in TEST() 162 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST() 224 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST() 280 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST() 326 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST() 379 scheduler->AddQueue(queue_options, queue_0_callback, &queues[0])); in TEST() 381 scheduler->AddQueue(queue_options, queue_1_callback, &queues[1])); in TEST() 430 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST() 501 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_0_callback, &queue_0)); in TEST() [all …]
|
D | adaptive_shared_batch_scheduler_test.cc | 125 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 164 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 239 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue1)); in TEST() 241 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue2)); in TEST() 288 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 327 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST() 364 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue)); in TEST()
|
D | basic_batch_scheduler.h | 235 TF_RETURN_IF_ERROR(shared_scheduler->AddQueue(shared_scheduler_queue_options, in Create()
|
D | serial_device_batch_scheduler.h | 116 Status AddQueue(const QueueOptions& options, 332 Status SerialDeviceBatchScheduler<TaskType>::AddQueue( in AddQueue() function
|
D | shared_batch_scheduler.h | 162 Status AddQueue(const QueueOptions& options, 392 Status SharedBatchScheduler<TaskType>::AddQueue( in AddQueue() function
|
D | adaptive_shared_batch_scheduler.h | 137 Status AddQueue(const QueueOptions& options, 364 Status AdaptiveSharedBatchScheduler<TaskType>::AddQueue( in AddQueue() function
|
/external/libchrome/base/task/sequence_manager/ |
D | task_queue_selector.cc | 59 void TaskQueueSelector::AddQueue(internal::TaskQueueImpl* queue) { in AddQueue() function in base::sequence_manager::internal::TaskQueueSelector 62 prioritizing_selector_.AddQueue(queue, TaskQueue::kNormalPriority); in AddQueue() 75 prioritizing_selector_.AddQueue(queue, queue->GetQueuePriority()); in EnableQueue() 114 void TaskQueueSelector::PrioritizingSelector::AddQueue( in AddQueue() function in base::sequence_manager::internal::TaskQueueSelector::PrioritizingSelector 120 delayed_work_queue_sets_.AddQueue(queue->delayed_work_queue(), priority); in AddQueue() 121 immediate_work_queue_sets_.AddQueue(queue->immediate_work_queue(), priority); in AddQueue()
|
D | task_queue_selector.h | 30 void AddQueue(internal::TaskQueueImpl* queue); 81 void AddQueue(internal::TaskQueueImpl* queue,
|
D | work_queue_sets.h | 35 void AddQueue(WorkQueue* queue, size_t set_index);
|
D | task_queue_selector_unittest.cc | 155 selector_.AddQueue(task_queue.get()); in SetUp() 768 selector.AddQueue(task_queue.get()); in TEST_F() 794 selector.AddQueue(task_queue.get()); in TEST_F() 795 selector.AddQueue(task_queue2.get()); in TEST_F()
|
D | work_queue_sets.cc | 18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue() function in base::sequence_manager::internal::WorkQueueSets
|
D | work_queue_sets_unittest.cc | 42 work_queue_sets_->AddQueue(queue, TaskQueue::kControlPriority); in NewTaskQueue()
|
D | work_queue_unittest.cc | 44 work_queue_sets_->AddQueue(work_queue_.get(), 0); in SetUp()
|
D | sequence_manager_impl.cc | 160 main_thread_only().selector.AddQueue(task_queue.get()); in CreateTaskQueueImpl()
|
/external/tensorflow/tensorflow/core/kernels/ |
D | batch_kernels.cc | 669 TF_RETURN_IF_ERROR(batcher_->AddQueue(batcher_queue_options_, in LookupOrCreateBatcherQueue()
|