| /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::__anonfe92a6570111::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 | 106 Status CreateTask(int64 task_id, int64 job_id, in CreateTask() function
261 TEST(DispatcherState, CreateTask) { in TEST() argument
269 TF_EXPECT_OK(CreateTask(task_id, job_id, worker_address, state)); in TEST()
299 TF_EXPECT_OK(CreateTask(task_id_1, job_id, worker_address, state)); in TEST()
300 TF_EXPECT_OK(CreateTask(task_id_2, job_id, worker_address, state)); in TEST()
319 TF_EXPECT_OK(CreateTask(task_id_1, job_id_1, worker_address, state)); in TEST()
320 TF_EXPECT_OK(CreateTask(task_id_2, job_id_2, worker_address, state)); in TEST()
342 TF_EXPECT_OK(CreateTask(task_id_1, job_id, worker_address, state)); in TEST()
343 TF_EXPECT_OK(CreateTask(task_id_2, job_id, worker_address, state)); in TEST()
361 TF_EXPECT_OK(CreateTask(task_id_1, job_id, worker_address_1, state)); in TEST()
[all …]
|
| D | dispatcher_state.cc | 55 CreateTask(update.create_task()); in Apply()
186 void DispatcherState::CreateTask(const CreateTaskUpdate& create_task) { in CreateTask() function in tensorflow::data::DispatcherState
|
| D | dispatcher_impl.h | 201 Status CreateTask(std::shared_ptr<const DispatcherState::Job> job,
|
| D | dispatcher_state.h | 221 void CreateTask(const CreateTaskUpdate& create_task);
|
| D | dispatcher_impl.cc | 553 TF_RETURN_IF_ERROR(CreateTask(job, worker_address, task)); in CreateTasksForWorker()
580 TF_RETURN_IF_ERROR(CreateTask(job, worker->address, task)); in CreateTasksForJob()
603 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 | 32 Task CreateTask(std::function<void()> f) { return Task{std::move(f)}; } in CreateTask() function
|
| D | SimpleThreadPool.h | 59 Task t = env_.CreateTask(std::move(fn)); in Schedule()
|
| D | NonBlockingThreadPool.h | 75 Task t = env_.CreateTask(std::move(fn)); in Schedule()
|
| /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
|