Home
last modified time | relevance | path

Searched refs:ReInitForScaling (Results 1 – 17 of 17) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/fl/server/
Dserver.cc464 if (!DistributedMetadataStore::GetInstance().ReInitForScaling()) { in ProcessAfterScalingOut()
467 if (!CollectiveOpsImpl::GetInstance().ReInitForScaling()) { in ProcessAfterScalingOut()
470 if (!DistributedCountService::GetInstance().ReInitForScaling()) { in ProcessAfterScalingOut()
473 …if (!iteration_->ReInitForScaling(IntToUint(server_node_->server_num()), server_node_->rank_id()))… in ProcessAfterScalingOut()
476 if (!Executor::GetInstance().ReInitForScaling()) { in ProcessAfterScalingOut()
492 if (!DistributedMetadataStore::GetInstance().ReInitForScaling()) { in ProcessAfterScalingIn()
495 if (!CollectiveOpsImpl::GetInstance().ReInitForScaling()) { in ProcessAfterScalingIn()
498 if (!DistributedCountService::GetInstance().ReInitForScaling()) { in ProcessAfterScalingIn()
501 …if (!iteration_->ReInitForScaling(IntToUint(server_node_->server_num()), server_node_->rank_id()))… in ProcessAfterScalingIn()
504 if (!Executor::GetInstance().ReInitForScaling()) { in ProcessAfterScalingIn()
Dcollective_ops_impl.h51 bool ReInitForScaling();
Dround.h44 bool ReInitForScaling(uint32_t server_num);
Ddistributed_metadata_store.h65 bool ReInitForScaling();
Dexecutor.h52 bool ReInitForScaling();
Dparameter_aggregator.h69 bool ReInitForScaling();
Ddistributed_count_service.h81 bool ReInitForScaling();
Dexecutor.cc44 bool Executor::ReInitForScaling() { in ReInitForScaling() function in mindspore::fl::server::Executor
46 … [](auto param_aggr) { return !param_aggr.second->ReInitForScaling(); }); in ReInitForScaling()
Dparameter_aggregator.cc50 bool ParameterAggregator::ReInitForScaling() { in ReInitForScaling() function in mindspore::fl::server::ParameterAggregator
54 return !aggregation_kernel.first->ReInitForScaling(); in ReInitForScaling()
Diteration.h88 bool ReInitForScaling(uint32_t server_num, uint32_t server_rank);
Dround.cc87 bool Round::ReInitForScaling(uint32_t server_num) { in ReInitForScaling() function in mindspore::fl::server::Round
Ddistributed_metadata_store.cc152 bool DistributedMetadataStore::ReInitForScaling() { in ReInitForScaling() function in mindspore::fl::server::DistributedMetadataStore
Diteration.cc180 bool Iteration::ReInitForScaling(uint32_t server_num, uint32_t server_rank) { in ReInitForScaling() function in mindspore::fl::server::Iteration
182 if (!round->ReInitForScaling(server_num)) { in ReInitForScaling()
Dcollective_ops_impl.cc227 bool CollectiveOpsImpl::ReInitForScaling() { in ReInitForScaling() function in mindspore::fl::server::CollectiveOpsImpl
Ddistributed_count_service.cc172 bool DistributedCountService::ReInitForScaling() { in ReInitForScaling() function in mindspore::fl::server::DistributedCountService
/third_party/mindspore/mindspore/ccsrc/fl/server/kernel/
Daggregation_kernel.h68 virtual bool ReInitForScaling() { return true; } in ReInitForScaling() function
Dfed_avg_kernel.h176 bool ReInitForScaling() override { in ReInitForScaling() function