Home
last modified time | relevance | path

Searched refs:AddQueue (Results 1 – 16 of 16) sorted by relevance

/external/tensorflow/tensorflow/core/kernels/batching_util/
Dserial_device_batch_scheduler_test.cc124 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 …]
Dshared_batch_scheduler_test.cc105 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 …]
Dadaptive_shared_batch_scheduler_test.cc125 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()
Dbasic_batch_scheduler.h235 TF_RETURN_IF_ERROR(shared_scheduler->AddQueue(shared_scheduler_queue_options, in Create()
Dserial_device_batch_scheduler.h116 Status AddQueue(const QueueOptions& options,
332 Status SerialDeviceBatchScheduler<TaskType>::AddQueue( in AddQueue() function
Dshared_batch_scheduler.h162 Status AddQueue(const QueueOptions& options,
392 Status SharedBatchScheduler<TaskType>::AddQueue( in AddQueue() function
Dadaptive_shared_batch_scheduler.h137 Status AddQueue(const QueueOptions& options,
364 Status AdaptiveSharedBatchScheduler<TaskType>::AddQueue( in AddQueue() function
/external/libchrome/base/task/sequence_manager/
Dtask_queue_selector.cc59 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()
Dtask_queue_selector.h30 void AddQueue(internal::TaskQueueImpl* queue);
81 void AddQueue(internal::TaskQueueImpl* queue,
Dwork_queue_sets.h35 void AddQueue(WorkQueue* queue, size_t set_index);
Dtask_queue_selector_unittest.cc155 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()
Dwork_queue_sets.cc18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue() function in base::sequence_manager::internal::WorkQueueSets
Dwork_queue_sets_unittest.cc42 work_queue_sets_->AddQueue(queue, TaskQueue::kControlPriority); in NewTaskQueue()
Dwork_queue_unittest.cc44 work_queue_sets_->AddQueue(work_queue_.get(), 0); in SetUp()
Dsequence_manager_impl.cc160 main_thread_only().selector.AddQueue(task_queue.get()); in CreateTaskQueueImpl()
/external/tensorflow/tensorflow/core/kernels/
Dbatch_kernels.cc669 TF_RETURN_IF_ERROR(batcher_->AddQueue(batcher_queue_options_, in LookupOrCreateBatcherQueue()