Home
last modified time | relevance | path

Searched refs:CollectiveParamResolverLocal (Results 1 – 9 of 9) sorted by relevance

/external/tensorflow/tensorflow/core/common_runtime/
Dcollective_param_resolver_local.cc41 CollectiveParamResolverLocal::CollectiveParamResolverLocal( in CollectiveParamResolverLocal() function in tensorflow::CollectiveParamResolverLocal
49 void CollectiveParamResolverLocal::CompleteGroupAsync( in CompleteGroupAsync()
87 void CollectiveParamResolverLocal::CompleteGroupLocal( in CompleteGroupLocal()
512 void CollectiveParamResolverLocal::FinishGroup(GroupRec* gr) { in FinishGroup()
535 void CollectiveParamResolverLocal::CompleteTaskIsLocal(const string& task_name, in CompleteTaskIsLocal()
543 void CollectiveParamResolverLocal::SetDefaultRank(const string& device, in SetDefaultRank()
554 void CollectiveParamResolverLocal::InitInstanceSharedParams( in InitInstanceSharedParams()
570 void CollectiveParamResolverLocal::CompleteDefaultRanking( in CompleteDefaultRanking()
599 CollectiveParamResolverLocal::InstanceRec*
600 CollectiveParamResolverLocal::GetOrCreateInstanceRec(const GroupRec* gr, in GetOrCreateInstanceRec()
[all …]
Dcollective_param_resolver_local.h41 class CollectiveParamResolverLocal : public ParamResolverInterface {
43 CollectiveParamResolverLocal(const ConfigProto& config,
48 ~CollectiveParamResolverLocal() override {} in ~CollectiveParamResolverLocal()
Dcollective_rma_local_test.cc51 prl_ = absl::make_unique<CollectiveParamResolverLocal>( in CollectiveRemoteAccessLocalTest()
63 std::unique_ptr<CollectiveParamResolverLocal> prl_;
Dcollective_executor_mgr_test.cc48 new CollectiveParamResolverLocal(cp, device_mgr_.get(), drl.get(), in CollectiveExecutorMgrTest()
Dcollective_param_resolver_local_test.cc57 prl_.reset(new CollectiveParamResolverLocal(cp, device_mgr_.get(), in ResetParamResolver()
88 std::unique_ptr<CollectiveParamResolverLocal> prl_;
Ddirect_session.cc554 new CollectiveParamResolverLocal(options_.config, device_mgr_.get(), in RunInternal()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_param_resolver_distributed.h29 class CollectiveParamResolverDistributed : public CollectiveParamResolverLocal {
Dcollective_param_resolver_distributed.cc95 : CollectiveParamResolverLocal(config, dev_mgr, dev_resolver, task_name), in CollectiveParamResolverDistributed()
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext.cc121 std::unique_ptr<ParamResolverInterface> cprl(new CollectiveParamResolverLocal(