Searched refs:locality_stats (Results 1 – 5 of 5) sorted by relevance
180 RefCountedPtr<XdsClusterLocalityStats> locality_stats) in StatsSubchannelWrapper() argument182 locality_stats_(std::move(locality_stats)) {} in StatsSubchannelWrapper()184 XdsClusterLocalityStats* locality_stats() const { in locality_stats() function in grpc_core::__anonc021a63c0111::XdsClusterImplLb::StatsSubchannelWrapper330 XdsClusterLocalityStats* locality_stats = nullptr; in Pick() local335 locality_stats = subchannel_wrapper->locality_stats()->Ref().release(); in Pick()337 locality_stats->AddCallStarted(); in Pick()348 [locality_stats, original_recv_trailing_metadata_ready, call_counter]( in Pick()352 if (locality_stats != nullptr) { in Pick()354 locality_stats->AddCallFinished(call_failed); in Pick()355 locality_stats->Unref(DEBUG_LOCATION, "LocalityStats+call"); in Pick()[all …]
1335 for (const auto& q : cluster_snapshot.locality_stats) { in LoadReportCountersAreZero()2041 load_report_state.locality_stats[locality]; in AddClusterLocalityStats()2043 if (locality_state.locality_stats != nullptr) { in AddClusterLocalityStats()2044 cluster_locality_stats = locality_state.locality_stats->RefIfNonZero(); in AddClusterLocalityStats()2047 if (locality_state.locality_stats != nullptr) { in AddClusterLocalityStats()2049 locality_state.locality_stats->GetSnapshotAndReset(); in AddClusterLocalityStats()2055 locality_state.locality_stats = cluster_locality_stats.get(); in AddClusterLocalityStats()2073 auto locality_it = load_report_state.locality_stats.find(locality); in RemoveClusterLocalityStats()2074 if (locality_it == load_report_state.locality_stats.end()) return; in RemoveClusterLocalityStats()2076 if (locality_state.locality_stats == cluster_locality_stats) { in RemoveClusterLocalityStats()[all …]
278 XdsClusterLocalityStats* locality_stats = nullptr; member286 locality_stats; member
406 locality_stats; member
2228 for (const auto& p : load_report.locality_stats) { in CreateLrsRequest()2231 envoy_config_endpoint_v3_UpstreamLocalityStats* locality_stats = in CreateLrsRequest() local2234 LocalityStatsPopulate(locality_stats, locality_name, snapshot, in CreateLrsRequest()