Home
last modified time | relevance | path

Searched refs:load_reporter_ (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc/test/cpp/server/load_reporter/
Dload_reporter_test.cc80 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::__anon44978cb20111::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 …]
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc41 load_reporter_ = std::unique_ptr<LoadReporter>(new LoadReporter( in LoadReporterAsyncServiceImpl()
82 load_reporter_->FetchAndSample(); in FetchAndSample()
95 service->load_reporter_.get()); in Work()
143 load_reporter_(load_reporter), in ReportLoadHandler()
165 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
180 lb_id_ = load_reporter_->GenerateLbId(); in OnRequestDelivered()
210 load_reporter_->ReportStreamCreated(load_balanced_hostname_, lb_id_, in OnReadDone()
284 auto loads = load_reporter_->GenerateLoads(load_balanced_hostname_, lb_id_); in SendReport()
286 auto feedback = load_reporter_->GenerateLoadBalancingFeedback(); in SendReport()
338 load_reporter_->ReportStreamClosed(load_balanced_hostname_, lb_id_); in Shutdown()
Dload_reporter_async_service_impl.h149 LoadReporter* load_reporter_; variable
187 std::unique_ptr<LoadReporter> load_reporter_; variable
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc43 load_reporter_ = absl::make_unique<LoadReporter>( in LoadReporterAsyncServiceImpl()
85 load_reporter_->FetchAndSample(); in FetchAndSample()
98 service->load_reporter_.get()); in Work()
146 load_reporter_(load_reporter), in ReportLoadHandler()
168 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
183 lb_id_ = load_reporter_->GenerateLbId(); in OnRequestDelivered()
213 load_reporter_->ReportStreamCreated(load_balanced_hostname_, lb_id_, in OnReadDone()
287 auto loads = load_reporter_->GenerateLoads(load_balanced_hostname_, lb_id_); in SendReport()
289 auto feedback = load_reporter_->GenerateLoadBalancingFeedback(); in SendReport()
341 load_reporter_->ReportStreamClosed(load_balanced_hostname_, lb_id_); in Shutdown()
Dload_reporter_async_service_impl.h150 LoadReporter* load_reporter_; variable
188 std::unique_ptr<LoadReporter> load_reporter_; variable