| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/cluster/ |
| D | cluster_context.cc | 127 const std::string &ClusterContext::node_role() const { return node_role_; } in node_role() function in mindspore::distributed::cluster::ClusterContext
129 uint32_t ClusterContext::node_num(const std::string &node_role) { in node_num()
|
| D | dummy_cluster_context.cc | 36 std::string ClusterContext::node_role() const { return ""; } in node_role() function in mindspore::distributed::cluster::ClusterContext
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/core/ |
| D | ps_scheduler_node.cc | 95 auto node_role = node_info.node_role_; in ProcessSendHostName() local
137 NodeRole node_role = node_info.node_role_; in ProcessQueryHostNames() local
221 auto node_role = node_info.node_role_; in ProcessQueryUniqueID() local
303 auto node_role = node_info.node_role_; in ProcessQueryFinishTransform() local
|
| D | worker_node.cc | 66 std::string node_role = CommUtil::NodeRoleToString(node_info_.node_role_); in Initialize() local
|
| D | server_node.cc | 73 std::string node_role = CommUtil::NodeRoleToString(node_info_.node_role_); in Initialize() local
|
| D | abstract_node.cc | 78 void AbstractNode::SendFailMessageToScheduler(const std::string &node_role, const std::string &even… in SendFailMessageToScheduler()
130 bool AbstractNode::Broadcast(const NodeRole &node_role, const std::string &message, int command, in Broadcast()
252 bool AbstractNode::Send(const NodeRole &node_role, const uint32_t &rank_id, const void *message, si… in Send()
290 bool AbstractNode::Send(const NodeRole &node_role, const uint32_t &rank_id, const std::string &msg,… in Send()
295 bool AbstractNode::Send(const NodeRole &node_role, const std::vector<uint32_t> &rank_ids, in Send()
379 uint64_t AbstractNode::CollectiveSendAsync(const NodeRole &node_role, const uint32_t &rank_id, cons… in CollectiveSendAsync()
524 std::pair<uint32_t, uint64_t> AbstractNode::CollectiveReceiveAsync(const NodeRole &node_role, const… in CollectiveReceiveAsync()
|
| D | scheduler_node.cc | 179 NodeRole node_role = nodeInfo.node_role_; in ProcessHeartbeat() local
599 std::string node_role = failure_event_message.node_role(); in ProcessFailureEvent() local
947 std::string node_role = CommUtil::NodeRoleToString(node_info_.node_role_); in RecordSchedulerRestartInfo() local
|
| D | comm_util.cc | 184 bool CommUtil::ValidateRankId(const enum NodeRole &node_role, const uint32_t &rank_id, const int32_… in ValidateRankId()
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/frontend/parallel/cache_embedding/ |
| D | ps_embedding_cache_inserter.h | 34 …beddingCacheInserter(const FuncGraphPtr &root_graph, int64_t rank_id, const std::string &node_role, in PsEmbeddingCacheInserter()
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/core/protos/ |
| D | comm.proto | 148 string node_role = 1; field
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/cluster/topology/ |
| D | meta_server_node.cc | 414 auto node_role = message->body; in ProcessGetHostNames() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/pipeline/jit/ps/ |
| D | pass.cc | 1206 auto node_role = distributed::cluster::ClusterContext::instance()->node_role(); in AddEmbeddingCachePass() local
|
| D | action.cc | 1737 auto node_role = distributed::cluster::ClusterContext::instance()->node_role(); in DistributedSplitAction() local
|