Home
last modified time | relevance | path

Searched refs:locality_stats (Results 1 – 11 of 11) sorted by relevance

/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_impl.cc178 RefCountedPtr<XdsClusterLocalityStats> locality_stats) in StatsSubchannelWrapper() argument
180 locality_stats_(std::move(locality_stats)) {} in StatsSubchannelWrapper()
182 XdsClusterLocalityStats* locality_stats() const { in locality_stats() function in grpc_core::__anon93b706d90111::XdsClusterImplLb::StatsSubchannelWrapper
328 XdsClusterLocalityStats* locality_stats = nullptr; in Pick() local
333 locality_stats = subchannel_wrapper->locality_stats()->Ref().release(); in Pick()
335 locality_stats->AddCallStarted(); in Pick()
346 [locality_stats, original_recv_trailing_metadata_ready, call_counter]( in Pick()
350 if (locality_stats != nullptr) { in Pick()
352 locality_stats->AddCallFinished(call_failed); in Pick()
353 locality_stats->Unref(DEBUG_LOCATION, "LocalityStats+call"); in Pick()
[all …]
Dlrs.cc103 RefCountedPtr<XdsClusterLocalityStats> locality_stats) in LoadReportingPicker() argument
105 locality_stats_(std::move(locality_stats)) {} in LoadReportingPicker()
176 XdsClusterLocalityStats* locality_stats = in Pick() local
181 [locality_stats](grpc_error* error, MetadataInterface* /*metadata*/, in Pick()
184 locality_stats->AddCallFinished(call_failed); in Pick()
185 locality_stats->Unref(DEBUG_LOCATION, "LocalityStats+call"); in Pick()
/third_party/grpc/src/core/ext/xds/
Dxds_client.cc1329 for (const auto& q : cluster_snapshot.locality_stats) { in LoadReportCountersAreZero()
2035 load_report_state.locality_stats[locality]; in AddClusterLocalityStats()
2037 if (locality_state.locality_stats != nullptr) { in AddClusterLocalityStats()
2038 cluster_locality_stats = locality_state.locality_stats->RefIfNonZero(); in AddClusterLocalityStats()
2041 if (locality_state.locality_stats != nullptr) { in AddClusterLocalityStats()
2043 locality_state.locality_stats->GetSnapshotAndReset(); in AddClusterLocalityStats()
2049 locality_state.locality_stats = cluster_locality_stats.get(); in AddClusterLocalityStats()
2067 auto locality_it = load_report_state.locality_stats.find(locality); in RemoveClusterLocalityStats()
2068 if (locality_it == load_report_state.locality_stats.end()) return; in RemoveClusterLocalityStats()
2070 if (locality_state.locality_stats == cluster_locality_stats) { in RemoveClusterLocalityStats()
[all …]
Dxds_client.h278 XdsClusterLocalityStats* locality_stats = nullptr; member
286 locality_stats; member
Dxds_api.h362 locality_stats; member
Dxds_api.cc2399 for (const auto& p : load_report.locality_stats) { in CreateLrsRequest()
2402 envoy_config_endpoint_v3_UpstreamLocalityStats* locality_stats = in CreateLrsRequest() local
2405 LocalityStatsPopulate(locality_stats, locality_name, snapshot, in CreateLrsRequest()
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.cc1385 for (const auto& q : cluster_snapshot.locality_stats) { in LoadReportCountersAreZero()
1970 it->second.locality_stats[std::move(locality)].locality_stats.insert( in AddClusterLocalityStats()
1987 auto locality_it = load_report_state.locality_stats.find(locality); in RemoveClusterLocalityStats()
1988 if (locality_it == load_report_state.locality_stats.end()) return; in RemoveClusterLocalityStats()
1989 auto& locality_set = locality_it->second.locality_stats; in RemoveClusterLocalityStats()
2348 for (auto it = load_report.locality_stats.begin(); in BuildLoadReportSnapshot()
2349 it != load_report.locality_stats.end();) { in BuildLoadReportSnapshot()
2353 snapshot.locality_stats[locality_name]; in BuildLoadReportSnapshot()
2354 for (auto& locality_stats : locality_state.locality_stats) { in BuildLoadReportSnapshot() local
2355 locality_snapshot += locality_stats->GetSnapshotAndReset(); in BuildLoadReportSnapshot()
[all …]
Dxds_client.h222 std::set<XdsClusterLocalityStats*> locality_stats; member
230 locality_stats; member
Dxds_api.h290 locality_stats; member
Dxds_api.cc2031 for (const auto& p : load_report.locality_stats) { in CreateLrsRequest()
2034 envoy_api_v2_endpoint_UpstreamLocalityStats* locality_stats = in CreateLrsRequest() local
2037 LocalityStatsPopulate(locality_stats, locality_name, snapshot, in CreateLrsRequest()
/third_party/grpc/test/cpp/end2end/
Dxds_end2end_test.cc329 const std::map<std::string, LocalityStats>& locality_stats() const { in locality_stats() function in grpc::testing::__anon5b583b8e0111::ClientStats
2057 &ClientStats::locality_stats, in TEST_P()
2096 &ClientStats::locality_stats, in TEST_P()
2118 &ClientStats::locality_stats, in TEST_P()