Searched refs:load_reporter_ (Results 1 – 3 of 3) sorted by relevance
| /third_party/grpc/test/cpp/server/load_reporter/ |
| D | load_reporter_test.cc | 80 load_reporter_->census_view_provider()); in mock_census_view_provider()
85 load_reporter_->cpu_stats_provider()); in PrepareCpuExpectation()
99 std::unique_ptr<LoadReporter> load_reporter_; member in grpc::testing::__anona80a3c8a0111::LoadReporterTest
143 load_reporter_ = std::unique_ptr<LoadReporter>( in SetUp()
195 load_reporter_->FetchAndSample(); in TEST_F()
197 load_reporter_->GenerateLoadBalancingFeedback(); in TEST_F()
282 load_reporter_->FetchAndSample(); in TEST_F()
284 VerifyLbFeedback(load_reporter_->GenerateLoadBalancingFeedback(), 0, in TEST_F()
290 load_reporter_->FetchAndSample(); in TEST_F()
292 VerifyLbFeedback(load_reporter_->GenerateLoadBalancingFeedback(), 0, in TEST_F()
[all …]
|
| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 45 load_reporter_ = absl::make_unique<LoadReporter>( in LoadReporterAsyncServiceImpl()
87 load_reporter_->FetchAndSample(); in FetchAndSample()
100 service->load_reporter_.get()); in Work()
148 load_reporter_(load_reporter), in ReportLoadHandler()
170 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
185 lb_id_ = load_reporter_->GenerateLbId(); in OnRequestDelivered()
215 load_reporter_->ReportStreamCreated(load_balanced_hostname_, lb_id_, in OnReadDone()
289 auto loads = load_reporter_->GenerateLoads(load_balanced_hostname_, lb_id_); in SendReport()
291 auto feedback = load_reporter_->GenerateLoadBalancingFeedback(); in SendReport()
343 load_reporter_->ReportStreamClosed(load_balanced_hostname_, lb_id_); in Shutdown()
|
| D | load_reporter_async_service_impl.h | 150 LoadReporter* load_reporter_; variable
188 std::unique_ptr<LoadReporter> load_reporter_; variable
|