Home
last modified time | relevance | path

Searched refs:ClusterState (Results 1 – 14 of 14) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/ps/core/
Dnode_manager.h54 cluster_state_(ClusterState::ClUSTER_STARTING) {} in NodeManager()
102 void UpdateClusterState(const ClusterState &state);
104 ClusterState GetClusterState();
148 ClusterState cluster_state_;
Dscheduler_node.cc42 node_manager_.UpdateClusterState(ClusterState::CLUSTER_READY); in Start()
180 if (node_manager_.GetClusterState() == ClusterState::CLUSTER_SCALE_IN) { in ProcessRegister()
199 node_manager_.UpdateClusterState(ClusterState::CLUSTER_READY); in ProcessRegister()
237 node_manager_.UpdateClusterState(ClusterState::CLUSTER_EXIT); in ProcessFinish()
284 node_manager_.UpdateClusterState(ClusterState::CLUSTER_READY); in ProcessScaleOutDone()
312 node_manager_.UpdateClusterState(ClusterState::CLUSTER_READY); in ProcessScaleInDone()
452 if (node_manager_.GetClusterState() == ClusterState::CLUSTER_EXIT) { in StartUpdateClusterStateTimer()
583 node_manager_.UpdateClusterState(ClusterState::CLUSTER_SCALE_OUT); in ProcessScaleOut()
643 node_manager_.UpdateClusterState(ClusterState::CLUSTER_SCALE_IN); in ProcessScaleIn()
760 node_manager_.UpdateClusterState(ClusterState::CLUSTER_NEW_INSTANCE); in ProcessNewInstance()
[all …]
Dnode_manager.cc181 UpdateClusterState(ClusterState::NODE_TIMEOUT); in UpdateCluster()
191 UpdateClusterState(ClusterState::CLUSTER_EXIT); in UpdateCluster()
202 UpdateClusterState(ClusterState::NODE_TIMEOUT); in CheckClusterTimeout()
243 void NodeManager::UpdateClusterState(const ClusterState &state) { in UpdateClusterState()
255 ClusterState NodeManager::GetClusterState() { in GetClusterState()
263 if (GetClusterState() == ClusterState::CLUSTER_SCALE_IN) { in ResetMetadata()
Dnode.h56 current_cluster_state_(ClusterState::ClUSTER_STARTING) {} in Node()
117 ClusterState current_cluster_state_;
Dabstract_node.cc179 if (current_cluster_state_ == ClusterState::NODE_TIMEOUT) { in Send()
203 if (current_cluster_state_ == ClusterState::NODE_TIMEOUT) { in Send()
242 if (current_cluster_state_ == ClusterState::NODE_TIMEOUT) { in Send()
283 if (current_cluster_state_ == ClusterState::NODE_TIMEOUT) { in Send()
446 ClusterState AbstractNode::cluster_state() const { return current_cluster_state_; } in cluster_state()
595 if (current_cluster_state_ == ClusterState::NODE_TIMEOUT) { in ProcessHeartbeatResp()
672 if (current_cluster_state_ == ClusterState::CLUSTER_SCALE_OUT) { in ProcessSendMetadata()
677 if (current_cluster_state_ == ClusterState::CLUSTER_SCALE_IN) { in ProcessSendMetadata()
708 current_cluster_state_ = ClusterState::CLUSTER_READY; in ProcessScaleOutDone()
721 current_cluster_state_ = ClusterState::CLUSTER_READY; in ProcessScaleInDone()
[all …]
Dcomm_util.h112 static std::string ClusterStateToString(const ClusterState &state);
Dcomm_util.cc185 std::string CommUtil::ClusterStateToString(const ClusterState &state) { in ClusterStateToString()
Dabstract_node.h130 ClusterState cluster_state() const;
/third_party/grpc/src/core/ext/filters/client_channel/resolver/xds/
Dxds_resolver.cc119 class ClusterState class in grpc_core::__anon0bd98fcd0111::XdsResolver
120 : public RefCounted<ClusterState, PolymorphicRefCount, false> {
123 std::map<std::string, std::unique_ptr<ClusterState>>;
125 ClusterState(const std::string& cluster_name, in ClusterState() function in grpc_core::__anon0bd98fcd0111::XdsResolver::ClusterState
128 ->emplace(cluster_name, std::unique_ptr<ClusterState>(this)) in ClusterState()
173 std::map<absl::string_view, RefCountedPtr<ClusterState>> clusters_;
194 ClusterState::ClusterStateMap cluster_state_map_;
356 MakeRefCounted<ClusterState>(name, &resolver_->cluster_state_map_); in MaybeAddCluster()
471 ClusterState* cluster_state = it->second->Ref().release(); in GetCallConfig()
691 RefCountedPtr<ClusterState> cluster_state = it->second->RefIfNonZero(); in MaybeRemoveUnusedClusters()
/third_party/mindspore/mindspore/ccsrc/ps/core/protos/
Dcomm.proto89 enum ClusterState { enum
102 ClusterState cluster_state = 1;
131 ClusterState cluster_state = 4;
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.h205 struct ClusterState { struct
280 std::map<std::string /*cluster_name*/, ClusterState> cluster_map_;
Dxds_client.cc196 ClusterState& state = ads_calld_->xds_client()->cluster_map_[name_]; in OnTimerLocked()
1012 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1036 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1842 ClusterState& cluster_state = cluster_map_[cluster_name_str]; in WatchClusterData()
1862 ClusterState& cluster_state = cluster_map_[cluster_name_str]; in CancelClusterDataWatch()
2395 const ClusterState& cluster_state = p.second; in NotifyOnError()
/third_party/grpc/src/core/ext/xds/
Dxds_client.h261 struct ClusterState { struct
313 std::map<std::string /*cluster_name*/, ClusterState> cluster_map_;
Dxds_client.cc213 ClusterState& state = ads_calld_->xds_client()->cluster_map_[name_]; in OnTimerLocked()
1012 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1034 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1893 ClusterState& cluster_state = cluster_map_[cluster_name_str]; in WatchClusterData()
1914 ClusterState& cluster_state = cluster_map_[cluster_name_str]; in CancelClusterDataWatch()
2100 const ClusterState& cluster_state = p.second; in NotifyOnErrorLocked()