Home
last modified time | relevance | path

Searched refs:task_index (Results 1 – 25 of 65) sorted by relevance

123

/external/tensorflow/tensorflow/python/training/
Dserver_lib.py27 def _make_server_def(server_or_cluster_def, job_name, task_index, protocol, argument
58 if task_index is not None:
59 server_def.task_index = task_index
75 if task_index is None:
78 task_index = task_indices[0]
87 task_index=task_index,
110 task_index=None, argument
143 task_index, protocol, config)
414 def task_address(self, job_name, task_index): argument
433 return job[task_index]
[all …]
Dserver_lib_test.py196 task_index=0,
264 }, job_name="local", task_index=0)
396 cluster=cluster_def, job_name="local", task_index=0, protocol="grpc")
414 cluster=cluster_def, job_name="local", task_index=1, protocol="grpc")
434 cluster=cluster_def, job_name="worker", task_index=2, protocol="grpc")
460 cluster=cluster_def, job_name="worker", task_index=2, protocol="grpc")
/external/cronet/tot/base/task/
Dsingle_thread_task_executor_unittest.cc989 int task_index = 0; in TEST_P() local
990 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, true)); in TEST_P()
991 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 2, true)); in TEST_P()
992 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 2, false)); in TEST_P()
993 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, false)); in TEST_P()
994 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 3, true)); in TEST_P()
995 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 3, false)); in TEST_P()
996 EXPECT_EQ(static_cast<size_t>(task_index), order.Size()); in TEST_P()
1021 int task_index = 0; in TEST_P() local
1022 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, true)); in TEST_P()
[all …]
/external/cronet/stable/base/task/
Dsingle_thread_task_executor_unittest.cc989 int task_index = 0; in TEST_P() local
990 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, true)); in TEST_P()
991 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 2, true)); in TEST_P()
992 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 2, false)); in TEST_P()
993 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, false)); in TEST_P()
994 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 3, true)); in TEST_P()
995 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 3, false)); in TEST_P()
996 EXPECT_EQ(static_cast<size_t>(task_index), order.Size()); in TEST_P()
1021 int task_index = 0; in TEST_P() local
1022 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, true)); in TEST_P()
[all …]
/external/mesa3d/src/vulkan/runtime/bvh/
Dploc_internal.comp63 prefix_scan(uvec4 ballot, REF(ploc_prefix_scan_partition) partitions, uint32_t task_index)
67 if (task_index >= gl_WorkGroupSize.x) {
69 …c_prefix_scan_partition)(INDEX(ploc_prefix_scan_partition, partitions, task_index / gl_WorkGroupSi…
196 load_bounds(VOID_REF ids, uint32_t iter, uint32_t task_index, uint32_t lds_base,
199 for (uint32_t i = task_index - 2 * neighbourhood_overlap; i < search_bound;
278 uint32_t task_index = fetch_task(args.header, false);
282 if (task_index == TASK_INDEX_INVALID)
287 uint32_t base_index = task_index - gl_LocalInvocationID.x;
298 load_bounds(src_ids, iter, task_index, lds_base, neighbourhood_overlap, search_bound);
304 for (uint32_t i = task_index - double_neighbourhood_overlap; i < write_bound;
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_tensorflow_server.cc42 int task_index, ServerDef* options) { in FillServerDef() argument
45 options->set_task_index(task_index); in FillServerDef()
76 if (options->task_index() >= my_num_tasks) { in FillServerDef()
77 return errors::InvalidArgument("Task index ", options->task_index(), in FillServerDef()
101 int task_index = 0; in main() local
105 tensorflow::Flag("task_id", &task_index, "task id"), in main()
117 task_index, &server_def); in main()
Dgrpc_testlib_server.cc39 int num_cpus, int num_gpus, int task_index, in FillServerDef() argument
43 options->set_task_index(task_index); in FillServerDef()
84 int task_index = 0; in main() local
88 tensorflow::Flag("tf_task", &task_index, "task index"), in main()
101 num_gpus, task_index, &def); in main()
Dgrpc_server_lib.cc143 auto iter = job.tasks().find(server_def.task_index()); in GetHostAndPort()
145 return errors::Internal("Task ", server_def.task_index(), in GetHostAndPort()
197 "/task:", server_def_.task_index()); in Init()
356 if (job.name() == *options.job_name && task.first == options.task_index) { in ParseChannelSpec()
389 "/task:", options.task_index); in WorkerCacheFactory()
/external/tensorflow/tensorflow/core/protobuf/
Dcluster.proto38 // cluster { $CLUSTER } job_name: 'local' task_index: 0
47 // cluster { $CLUSTER } job_name: 'local' task_index: 0
48 // cluster { $CLUSTER } job_name: 'local' task_index: 1
61 // cluster { $CLUSTER } job_name: 'worker' task_index: 0
62 // cluster { $CLUSTER } job_name: 'worker' task_index: 1
63 // cluster { $CLUSTER } job_name: 'worker' task_index: 2
64 // cluster { $CLUSTER } job_name: 'ps' task_index: 0
65 // cluster { $CLUSTER } job_name: 'ps' task_index: 1
/external/libchrome/base/message_loop/
Dmessage_loop_unittest.cc1371 int task_index = 0; in TEST_P() local
1372 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, true)); in TEST_P()
1373 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 2, true)); in TEST_P()
1374 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 2, false)); in TEST_P()
1375 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, false)); in TEST_P()
1376 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 3, true)); in TEST_P()
1377 EXPECT_EQ(order.Get(task_index++), TaskItem(ORDERED, 3, false)); in TEST_P()
1378 EXPECT_EQ(static_cast<size_t>(task_index), order.Size()); in TEST_P()
1403 int task_index = 0; in TEST_P() local
1404 EXPECT_EQ(order.Get(task_index++), TaskItem(RUNS, 1, true)); in TEST_P()
[all …]
/external/libchrome/base/task_scheduler/
Dtest_task_factory.cc50 void TestTaskFactory::RunTaskCallback(size_t task_index, in RunTaskCallback() argument
82 DCHECK_LE(task_index, num_posted_tasks_); in RunTaskCallback()
86 task_index != ran_tasks_.size()) { in RunTaskCallback()
93 if (ran_tasks_.find(task_index) != ran_tasks_.end()) in RunTaskCallback()
95 ran_tasks_.insert(task_index); in RunTaskCallback()
Dtest_task_factory.h66 void RunTaskCallback(size_t task_index,
/external/cronet/tot/base/task/thread_pool/
Dtest_task_factory.cc50 void TestTaskFactory::RunTaskCallback(size_t task_index, in RunTaskCallback() argument
89 DCHECK_LE(task_index, num_posted_tasks_); in RunTaskCallback()
93 task_index != ran_tasks_.size()) { in RunTaskCallback()
100 if (ran_tasks_.find(task_index) != ran_tasks_.end()) in RunTaskCallback()
102 ran_tasks_.insert(task_index); in RunTaskCallback()
/external/cronet/stable/base/task/thread_pool/
Dtest_task_factory.cc50 void TestTaskFactory::RunTaskCallback(size_t task_index, in RunTaskCallback() argument
89 DCHECK_LE(task_index, num_posted_tasks_); in RunTaskCallback()
93 task_index != ran_tasks_.size()) { in RunTaskCallback()
100 if (ran_tasks_.find(task_index) != ran_tasks_.end()) in RunTaskCallback()
102 ran_tasks_.insert(task_index); in RunTaskCallback()
/external/tensorflow/tensorflow/python/eager/
Dremote.py79 task_index=0, argument
169 current_server_def.task_index != task_index):
190 task_index=task_index,
Dremote_execution_test.py43 task_index): argument
56 task_index=task_index,
82 task_index=0))
183 task_index=0))
198 task_index=0))
Dremote_cluster_test.py44 task_index): argument
57 task_index=task_index,
82 task_index=0)
89 task_index=0)
96 task_index=0)
103 task_index=0)
111 task_index=0)
119 task_index=0)
138 task_index=0))
/external/toolchain-utils/bestflags/
Dsteering_test.py82 task_index = 0
91 test_ranges = range(task_index, task_index + NUMBER_OF_TASKS)
105 task_index += NUMBER_OF_TASKS
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster_env.h41 int task_index; member
54 task_index = server_def.task_index(); in WorkerCacheFactoryOptions()
/external/crosvm/base/src/sys/windows/
Dpriority.rs22 let mut task_index: u32 = 0; in set_audio_thread_priority() localVariable
27 AvSetMmThreadCharacteristicsA(pro_audio.as_ptr(), &mut task_index) in set_audio_thread_priority()
/external/tensorflow/tensorflow/tools/api/golden/v2/
Dtensorflow.config.experimental.-cluster-device-filters.pbtxt11 …argspec: "args=[\'self\', \'job_name\', \'task_index\', \'device_filters\'], varargs=None, keyword…
/external/tensorflow/tensorflow/tools/api/golden/v1/
Dtensorflow.config.experimental.-cluster-device-filters.pbtxt11 …argspec: "args=[\'self\', \'job_name\', \'task_index\', \'device_filters\'], varargs=None, keyword…
/external/tensorflow/tensorflow/python/distribute/coordinator/
Dutils.py35 task_index=cluster_resolver.task_id,
/external/cronet/tot/base/threading/
Dscoped_blocking_call_unittest.cc511 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() argument
519 resume_thread[task_index].Wait(); in TEST_F()
521 exited_blocking_scope[task_index].Signal(); in TEST_F()
578 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() argument
586 resume_thread[task_index].Wait(); in TEST_F()
588 exited_blocking_scope[task_index].Signal(); in TEST_F()
/external/cronet/stable/base/threading/
Dscoped_blocking_call_unittest.cc511 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() argument
519 resume_thread[task_index].Wait(); in TEST_F()
521 exited_blocking_scope[task_index].Signal(); in TEST_F()
578 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() argument
586 resume_thread[task_index].Wait(); in TEST_F()
588 exited_blocking_scope[task_index].Signal(); in TEST_F()

123