| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/core/ |
| D | cluster_metadata.h | 36 uint32_t server_num; member
|
| D | node_recovery.cc | 39 …int32_t server_num = std::strtol(recovery_storage_->Get(kRecoveryServerNum, "").c_str(), nullptr, … in Recover() local
|
| D | node_manager.cc | 377 void NodeManager::set_server_num(const uint32_t &server_num) { meta_data_->server_num = server_num;… in set_server_num()
381 uint32_t NodeManager::server_num() const { return meta_data_->server_num; } in server_num() function in mindspore::ps::core::NodeManager
|
| D | abstract_node.cc | 576 uint32_t AbstractNode::server_num() const { return server_num_; } in server_num() function in mindspore::ps::core::AbstractNode
580 void AbstractNode::set_server_num(const uint32_t &server_num) { server_num_ = server_num; } in set_server_num()
952 int32_t server_num = scale_out_message.server_num(); in ProcessScaleOut() local
972 int32_t server_num = scale_in_message.server_num(); in ProcessScaleIn() local
|
| D | ps_scheduler_node.cc | 48 uint32_t server_num = clusterConfig.initial_server_num; in RunRecovery() local
|
| D | scheduler_node.cc | 114 uint32_t server_num = clusterConfig.initial_server_num; in RunRecovery() local
|
| /third_party/mindspore/mindspore-src/source/tests/ut/cpp/ps/core/ |
| D | cluster_metadata_test.cc | 38 std::string server_num = "1"; in TEST_F() local
|
| D | cluster_available_timeout_test.cc | 36 std::string server_num = "1"; in TEST_F() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/ |
| D | util.cc | 79 int64_t Util::LocalShard(int64_t first_dim, int64_t rank_id, int64_t server_num) { in LocalShard()
87 …int64_t, int64_t> Util::AllRankLocalShard(int64_t first_dim, int64_t rank_id, int64_t server_num) { in AllRankLocalShard()
|
| D | ps_context.cc | 263 void PSContext::set_server_num(uint32_t server_num) { server_num_ = server_num; } in set_server_num()
264 uint32_t PSContext::server_num() const { return server_num_; } in server_num() function in mindspore::ps::PSContext
|
| /third_party/mindspore/mindspore-src/source/config/ |
| D | hccl_evb_multi_rank.json | 9 "server_num": "1", string
|
| D | hccl_single_machine_multi_rank.json | 8 "server_num": "1", string
98 "server_num": "single machine is 1", string
|
| D | hccl_multi_machine_multi_rank.json | 8 "server_num": "2", string
162 "server_num": "number of multiple machines, single machine is 1", string
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/core/protos/ |
| D | comm.proto | 205 uint32 server_num = 3; field
227 uint32 server_num = 2; field
235 uint32 server_num = 2; field
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/runtime/graph_scheduler/actor/embedding_cache/ |
| D | device_sparse_embedding_operation.cc | 136 …size_t vocab_size, size_t server_num, std::vector<std::pair<size_t, size_t>> *remote_embedding_sli… in GetRemoteEmbeddingSliceBound() argument
|
| D | device_dense_embedding_operation.cc | 192 …size_t vocab_size, size_t server_num, std::vector<std::pair<size_t, size_t>> *remote_embedding_sli… in GetRemoteEmbeddingSliceBound() argument
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/embedding_cache/ |
| D | embedding_cache_utils.cc | 203 auto server_num = ps::PSContext::instance()->server_num(); in GetEmbeddingTableSliceBound() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/frontend/parallel/graph_util/ |
| D | graph_splitter.cc | 633 uint32_t server_num = ClusterContext::instance()->node_num(distributed::kEnvRoleOfServer); in PostBuildDistributedGraph() local
678 uint32_t server_num = ClusterContext::instance()->node_num(distributed::kEnvRoleOfServer); in PostBuildDistributedGraph() local
742 uint32_t server_num = ClusterContext::instance()->node_num(distributed::kEnvRoleOfServer); in ProcessForSplitOptimizer() local
|