Home
last modified time | relevance | path

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

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/xds/
Dxds_resolver.cc119 class ClusterState class in grpc_core::__anon6328d4090111::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::__anon6328d4090111::XdsResolver::ClusterState
128 ->emplace(cluster_name, std::unique_ptr<ClusterState>(this)) in ClusterState()
173 std::map<absl::string_view, RefCountedPtr<ClusterState>> clusters_;
192 ClusterState::ClusterStateMap cluster_state_map_;
354 MakeRefCounted<ClusterState>(name, &resolver_->cluster_state_map_); in MaybeAddCluster()
523 ClusterState* cluster_state = it->second->Ref().release(); in GetCallConfig()
743 RefCountedPtr<ClusterState> cluster_state = it->second->RefIfNonZero(); in MaybeRemoveUnusedClusters()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/
Dxds_client.h261 struct ClusterState { struct
313 std::map<std::string /*cluster_name*/, ClusterState> cluster_map_;
Dxds_client.cc212 ClusterState& state = ads_calld_->xds_client()->cluster_map_[name_]; in OnTimerLocked()
1018 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1040 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1899 ClusterState& cluster_state = cluster_map_[cluster_name_str]; in WatchClusterData()
1920 ClusterState& cluster_state = cluster_map_[cluster_name_str]; in CancelClusterDataWatch()
2106 const ClusterState& cluster_state = p.second; in NotifyOnErrorLocked()