Home
last modified time | relevance | path

Searched refs:default_rank (Results 1 – 18 of 18) sorted by relevance

/external/tensorflow/tensorflow/core/common_runtime/
Dhierarchical_tree_broadcaster_test.cc290 cp->default_rank = 0; in TEST_F()
295 cp->default_rank = 2; in TEST_F()
300 cp->default_rank = 0; in TEST_F()
316 cp->default_rank = 0; in TEST_F()
327 cp->default_rank = 0; in TEST_F()
338 cp->default_rank = 9; in TEST_F()
372 cp->default_rank = 0; in TEST_F()
383 cp->default_rank = 0; in TEST_F()
394 cp->default_rank = 5; in TEST_F()
Dall_to_all.cc114 auto default_rank = col_params_->default_rank; in Run() local
116 DispatchSend(default_rank, i, &input_chunks_[i], CheckCounterAndCallDone()); in Run()
118 DispatchRecv(i, default_rank, &output_chunks_[i], in Run()
Dring_reducer_test.cc234 cp->default_rank = 0; in TEST_F()
251 cp->default_rank = 3; in TEST_F()
272 cp->default_rank = 0; in TEST_F()
308 cp->default_rank = 0; in TEST_F()
324 cp->default_rank = 0; in TEST_F()
332 cp->default_rank = 0; in TEST_F()
351 cp->default_rank = 0; in TEST_F()
369 cp->default_rank = 0; in TEST_F()
Dpermuter.cc69 DispatchSend(col_params_->default_rank, in Run()
70 col_params_->instance.permutation[col_params_->default_rank], in Run()
73 if (col_params_->default_rank == col_params_->instance.permutation[i]) { in Run()
Dcollective_param_resolver_local.cc533 cp->default_rank = i; in SetDefaultRank()
545 ir->shared->default_rank = -1; in InitInstanceSharedParams()
812 CHECK_GE(cp->default_rank, 0); in WaitForGroup()
813 if (!ir->known[cp->default_rank]) { in WaitForGroup()
814 ir->known[cp->default_rank] = true; in WaitForGroup()
822 cp->default_rank); in WaitForGroup()
824 ir->source_rank = cp->default_rank; in WaitForGroup()
Dring_alg.cc182 col_params->group.members[col_params->default_rank].device.name(); in InitializeCollectiveParams()
245 DCHECK_EQ(permuted_di, col_params->default_rank); in InitializeCollectiveParams()
401 VLOG(3) << "DispatchSend rank=" << col_params_->default_rank << " send key " in DispatchSend()
421 VLOG(3) << "DispatchRecv rank=" << col_params_->default_rank << " recv key " in DispatchRecv()
Dring_gatherer_test.cc194 cp->default_rank = 0; in TEST_F()
207 cp->default_rank = 3; in TEST_F()
Dring_gatherer.cc88 << " default_rank " << col_params_->default_rank << "\n" in Run()
Dcollective_param_resolver_local_test.cc205 EXPECT_EQ(cps[i]->default_rank, i); in TEST_F()
259 EXPECT_EQ(cps[i]->default_rank, i); in TEST_F()
Dring_reducer.cc84 << " default_rank " << col_params_->default_rank << "\n" in Run()
Dcollective_test_util.cc192 col_params->default_rank = rank; in CreateCollectiveParams()
Dhierarchical_tree_broadcaster.cc84 col_params->group.members[col_params->default_rank].device.name(); in InitializeCollectiveParams()
Dbase_collective_executor.cc483 col_params.group.members[col_params.default_rank].task; in UnblockDependencies()
/external/tensorflow/tensorflow/core/nccl/
Dcollective_communicator.cc86 col_params->group.members[col_params->default_rank].task); in Enqueue()
94 col_ctx->output, col_ctx->col_params->default_rank, in Enqueue()
124 << col_params->group.members[col_params->default_rank].task in Enqueue()
/external/tensorflow/tensorflow/core/framework/
Dcollective.cc140 strings::StrAppend(&v, " default_rank=", default_rank, in ToString()
173 col_params->group.members[col_params->default_rank].device.name()) {} in CollectiveContext()
Dcollective.h149 int default_rank = -1; // index of this op within device_names member
/external/tensorflow/tensorflow/core/kernels/
Dcollective_nccl_test.cc262 col_params_->default_rank = rank; in DeviceInstance()
353 << col_params_->default_rank; in RunBroadcast()
386 << col_params_->default_rank; in RunGather()
508 di->col_params_->is_source = di->col_params_->default_rank == source_rank_; in InitDevice()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_param_resolver_distributed_test.cc254 EXPECT_EQ(cp_[device_name]->default_rank, idx); in ValidateCollectiveParams()