Searched refs:cluster_state (Results 1 – 7 of 7) sorted by relevance
1012 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate() local1013 if (cluster_state.update.has_value() && in AcceptCdsUpdate()1014 *cluster_state.update == cds_update) { in AcceptCdsUpdate()1023 cluster_state.update = std::move(cds_update); in AcceptCdsUpdate()1025 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()1026 p.first->OnClusterChanged(cluster_state.update.value()); in AcceptCdsUpdate()1034 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate() local1041 if (!cluster_state.update.has_value()) continue; in AcceptCdsUpdate()1042 cluster_state.update.reset(); in AcceptCdsUpdate()1043 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()[all …]
1012 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate() local1013 if (cluster_state.update.has_value() && in AcceptCdsUpdate()1014 cds_update.eds_service_name == cluster_state.update->eds_service_name && in AcceptCdsUpdate()1016 cluster_state.update->lrs_load_reporting_server_name) { in AcceptCdsUpdate()1025 cluster_state.update = std::move(cds_update); in AcceptCdsUpdate()1027 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()1028 p.first->OnClusterChanged(cluster_state.update.value()); in AcceptCdsUpdate()1036 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate() local1037 cluster_state.update.reset(); in AcceptCdsUpdate()1038 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()[all …]
471 ClusterState* cluster_state = it->second->Ref().release(); in GetCallConfig() local479 call_config.on_call_committed = [resolver, cluster_state]() { in GetCallConfig()480 cluster_state->Unref(); in GetCallConfig()691 RefCountedPtr<ClusterState> cluster_state = it->second->RefIfNonZero(); in MaybeRemoveUnusedClusters() local692 if (cluster_state != nullptr) { in MaybeRemoveUnusedClusters()
102 ClusterState cluster_state = 1; field131 ClusterState cluster_state = 4; field
733 auto cluster_state = node_manager_.GetClusterState(); in ProcessGetClusterState() local734 js["cluster_state"] = CommUtil::ClusterStateToString(cluster_state); in ProcessGetClusterState()1034 …OnRequestReceive cluster_state = std::bind(&SchedulerNode::ProcessGetClusterState, this, std::plac… in StartRestfulServer() local1035 callbacks_["/state"] = cluster_state; in StartRestfulServer()
130 ClusterState cluster_state() const;
446 ClusterState AbstractNode::cluster_state() const { return current_cluster_state_; } in cluster_state() function in mindspore::ps::core::AbstractNode574 current_cluster_state_ = heartbeat_resp_message.cluster_state(); in ProcessHeartbeatResp()654 current_cluster_state_ = send_meta_message.cluster_state(); in ProcessSendMetadata()