Home
last modified time | relevance | path

Searched refs:ReportLoadHandler (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc94 ReportLoadHandler::CreateAndStart(service->cq_.get(), service, in Work()
115 void LoadReporterAsyncServiceImpl::ReportLoadHandler::CreateAndStart( in CreateAndStart()
118 std::shared_ptr<ReportLoadHandler> handler = in CreateAndStart()
119 std::make_shared<ReportLoadHandler>(cq, service, load_reporter); in CreateAndStart()
120 ReportLoadHandler* p = handler.get(); in CreateAndStart()
125 CallableTag(std::bind(&ReportLoadHandler::OnDoneNotified, p, in CreateAndStart()
129 CallableTag(std::bind(&ReportLoadHandler::OnRequestDelivered, p, in CreateAndStart()
138 LoadReporterAsyncServiceImpl::ReportLoadHandler::ReportLoadHandler( in ReportLoadHandler() function in grpc::load_reporter::LoadReporterAsyncServiceImpl::ReportLoadHandler
147 void LoadReporterAsyncServiceImpl::ReportLoadHandler::OnRequestDelivered( in OnRequestDelivered()
148 std::shared_ptr<ReportLoadHandler> self, bool ok) { in OnRequestDelivered()
[all …]
Dload_reporter_async_service_impl.h54 class ReportLoadHandler;
66 std::function<void(std::shared_ptr<ReportLoadHandler>, bool)>;
71 std::shared_ptr<ReportLoadHandler> handler) in CallableTag()
82 std::shared_ptr<ReportLoadHandler> ReleaseHandler() { in ReleaseHandler()
88 std::shared_ptr<ReportLoadHandler> handler_;
94 class ReportLoadHandler {
105 ReportLoadHandler(ServerCompletionQueue* cq,
113 void OnRequestDelivered(std::shared_ptr<ReportLoadHandler> self, bool ok);
120 void OnReadDone(std::shared_ptr<ReportLoadHandler> self, bool ok);
125 void SendReport(std::shared_ptr<ReportLoadHandler> self, bool ok);
[all …]