Searched refs:node_id_ (Results 1 – 14 of 14) sorted by relevance
33 register_message.set_node_id(node_info_.node_id_); in Register()39 << " the node id:" << node_info_.node_id_ << " begin to register to the scheduler!"; in Register()44 << " the node id:" << node_info_.node_id_ << " register timeout!"; in Register()53 if (register_resp_message.node_id() != node_info_.node_id_) { in ProcessRegisterResp()55 << " is not match the current node id:" << node_info_.node_id_; in ProcessRegisterResp()62 MS_LOG(INFO) << "The node id is:" << node_info_.node_id_ << " registered scheduler success!"; in ProcessRegisterResp()89 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in Broadcast()116 scale_out_done_message.set_node_id(node_info_.node_id_); in set_scale_out_done()121 << " the node id:" << node_info_.node_id_ << " scale_out_done timeout!"; in set_scale_out_done()126 … << " the node id:" << node_info_.node_id_ << "is send scale_out_done to scheduler successful!"; in set_scale_out_done()[all …]
22 std::string Node::node_id() const { return node_info_.node_id_; } in node_id()37 MS_LOG(INFO) << "The node id:" << node_info_.node_id_ << " is success start!"; in WaitForStart()53 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in SendMessageSync()68 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in SendMessageAsync()83 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in SendMessageSync()148 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in ProcessSendDataResp()
88 node_info_.node_id_ = config_->Get(kNodeId, ""); in Initialize()90 node_info_.node_id_ = PSContext::instance()->node_id(); in Initialize()93 if (node_info_.node_id_.empty()) { in Initialize()94 node_info_.node_id_ = CommUtil::GenerateUUID(); in Initialize()101 << ", the node id is:" << node_info_.node_id_ << " create a tcp server."; in Initialize()358 << " the node id:" << node_info_.node_id_ << " send metadata timeout!"; in SendMetadata()362 … << " the node id:" << node_info_.node_id_ << "is sending metadata to workers and servers!"; in SendMetadata()376 << " the node id:" << node_info_.node_id_ << " send finish timeout!"; in SendFinish()380 … << " the node id:" << node_info_.node_id_ << "is sending finish to workers and servers!"; in SendFinish()394 << " the node id:" << node_info_.node_id_ << " send scale_out_done timeout!"; in SendScaleOutDone()[all …]
45 std::string node_id_; member
79 node_info.node_id_ = node_id; in NextRankId()118 node_info.node_id_ = node_id; in NextRankId()159 servers_meta.set_node_id(it->second.node_id_); in FetchAllNodesMeta()
28 … << " the node id:" << node_info_.node_id_ << " successfully registered to the scheduler!"; in Start()
32 NodeMemory() : node_name_(""), node_id_(0) {} in NodeMemory()36 void SetNodeId(uint64_t node_id) { node_id_ = node_id; } in SetNodeId()41 uint64_t GetNodeId() const { return node_id_; } in GetNodeId()48 uint64_t node_id_; variable
82 int OsrAXNodeId() const { return node_id_; } in OsrAXNodeId()105 int node_id_; variable
19 node_id_(nodeId), in OsrAXNode()
658 node_id_); in NotifyAccessibilityEvent()
67 node_id_ = common::GetEnv(kEnvNodeId); in SetPSEnable()68 if (node_id_.length() > kLength) { in SetPSEnable()425 void PSContext::set_node_id(const std::string &node_id) { node_id_ = node_id; } in set_node_id()427 const std::string &PSContext::node_id() const { return node_id_; } in node_id()
226 node_id_(""), in PSContext()319 std::string node_id_; variable
378 auto &id = node_id_[node]; in GetId()380 id = node_id_.size(); in GetId()395 std::map<std::pair<NodePtr, int>, size_t> node_id_; member in mindspore::opt::Mutator