| /external/libchrome/base/task_scheduler/ |
| D | sequence_unittest.cc | 27 Task CreateTask(MockTask* mock_task) { in CreateTask() function
51 EXPECT_TRUE(sequence->PushTask(CreateTask(&mock_task_a))); in TEST()
55 EXPECT_FALSE(sequence->PushTask(CreateTask(&mock_task_b))); in TEST()
56 EXPECT_FALSE(sequence->PushTask(CreateTask(&mock_task_c))); in TEST()
57 EXPECT_FALSE(sequence->PushTask(CreateTask(&mock_task_d))); in TEST()
80 EXPECT_FALSE(sequence->PushTask(CreateTask(&mock_task_e))); in TEST()
|
| D | task_tracker_unittest.cc | 171 Task CreateTask(TaskShutdownBehavior shutdown_behavior) { in CreateTask() function in base::internal::__anona049bffc0111::TaskSchedulerTaskTrackerTest
283 Task task(CreateTask(GetParam())); in TEST_P()
347 Task task(CreateTask(GetParam())); in TEST_P()
352 Task block_shutdown_task(CreateTask(TaskShutdownBehavior::BLOCK_SHUTDOWN)); in TEST_P()
376 Task task(CreateTask(GetParam())); in TEST_P()
406 Task block_shutdown_task(CreateTask(TaskShutdownBehavior::BLOCK_SHUTDOWN)); in TEST_P()
415 Task task(CreateTask(GetParam())); in TEST_P()
424 Task task(CreateTask(GetParam())); in TEST_P()
441 Task task(CreateTask(GetParam())); in TEST_P()
898 &tracker_, CreateTask(TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN), in TEST_F()
[all …]
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | dispatcher_state_test.cc | 125 Status CreateTask(int64_t task_id, int64_t job_id, in CreateTask() function
338 TEST(DispatcherState, CreateTask) { in TEST() argument
346 TF_EXPECT_OK(CreateTask(task_id, job_id, worker_address, state)); in TEST()
376 TF_EXPECT_OK(CreateTask(task_id_1, job_id, worker_address, state)); in TEST()
377 TF_EXPECT_OK(CreateTask(task_id_2, job_id, worker_address, state)); in TEST()
396 TF_EXPECT_OK(CreateTask(task_id_1, job_id_1, worker_address, state)); in TEST()
397 TF_EXPECT_OK(CreateTask(task_id_2, job_id_2, worker_address, state)); in TEST()
419 TF_EXPECT_OK(CreateTask(task_id_1, job_id, worker_address, state)); in TEST()
420 TF_EXPECT_OK(CreateTask(task_id_2, job_id, worker_address, state)); in TEST()
438 TF_EXPECT_OK(CreateTask(task_id_1, job_id, worker_address_1, state)); in TEST()
[all …]
|
| D | dispatcher_state.cc | 75 CreateTask(update.create_task()); in Apply()
243 void DispatcherState::CreateTask(const CreateTaskUpdate& create_task) { in CreateTask() function in tensorflow::data::DispatcherState
|
| D | dispatcher_impl.h | 229 Status CreateTask(std::shared_ptr<const DispatcherState::Job> job,
|
| D | dispatcher_state.h | 270 void CreateTask(const CreateTaskUpdate& create_task);
|
| D | dispatcher_impl.cc | 668 TF_RETURN_IF_ERROR(CreateTask(job, worker_address, task)); in CreateTasksForWorker()
695 TF_RETURN_IF_ERROR(CreateTask(job, worker->address, task)); in CreateTasksForJob()
718 Status DataServiceDispatcherImpl::CreateTask(std::shared_ptr<const Job> job, in CreateTask() function in tensorflow::data::DataServiceDispatcherImpl
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | ThreadEnvironment.h | 34 Task CreateTask(std::function<void()> f) { return Task{std::move(f)}; } in CreateTask() function
|
| D | NonBlockingThreadPool.h | 107 Task t = env_.CreateTask(std::move(fn)); in ScheduleWithHint()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | run_handler.h | 134 Task CreateTask(std::function<void()> f);
|
| D | run_handler.cc | 68 RunHandlerEnvironment::Task RunHandlerEnvironment::CreateTask( in CreateTask() function in tensorflow::internal::RunHandlerEnvironment
386 Task t = env_.CreateTask(std::move(fn)); in AddWorkToQueue()
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | threadpool.cc | 66 Task CreateTask(std::function<void()> f) { in CreateTask() function
|
| /external/tensorflow/tensorflow/core/tfrt/run_handler_thread_pool/ |
| D | run_handler.h | 189 Task CreateTask(TaskFunction f);
|
| D | run_handler.cc | 63 RunHandlerEnvironment::Task RunHandlerEnvironment::CreateTask(TaskFunction f) { in CreateTask() function in tfrt::tf::internal::RunHandlerEnvironment
412 Task t = env_.CreateTask(std::move(fn)); in AddWorkToQueue()
|