Searched refs:ReportLoadHandler (Results 1 – 2 of 2) sorted by relevance
/external/grpc-grpc/src/cpp/server/load_reporter/ |
D | load_reporter_async_service_impl.cc | 94 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 …]
|
D | load_reporter_async_service_impl.h | 54 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 …]
|