grpc::load_reporter::LoadReporterAsyncServiceImpl Class Reference

#include <load_reporter_async_service_impl.h>

Inheritance diagram for grpc::load_reporter::LoadReporterAsyncServiceImpl:

Classes
class	CallableTag
class	ReportLoadHandler

Public Member Functions
	LoadReporterAsyncServiceImpl (const LoadReporterAsyncServiceImpl &)=delete
	LoadReporterAsyncServiceImpl (std::unique_ptr< ServerCompletionQueue > cq)
LoadReporterAsyncServiceImpl &	operator= (const LoadReporterAsyncServiceImpl &)=delete
void	StartThread ()
	~LoadReporterAsyncServiceImpl () override

Private Member Functions
void	FetchAndSample (bool ok)
void	ScheduleNextFetchAndSample ()

Static Private Member Functions
static void	Work (void *arg)

Private Attributes
std::unique_ptr< ServerCompletionQueue >	cq_
grpc_core::Mutex	cq_shutdown_mu_
std::unique_ptr< LoadReporter >	load_reporter_
std::unique_ptr< Alarm >	next_fetch_and_sample_alarm_
std::atomic_bool	shutdown_ {false}
std::unique_ptr< grpc_core::Thread >	thread_

Detailed Description

Definition at line 51 of file load_reporter_async_service_impl.h.

Constructor & Destructor Documentation

LoadReporterAsyncServiceImpl() [1/2]

grpc::load_reporter::LoadReporterAsyncServiceImpl::LoadReporterAsyncServiceImpl ( std::unique_ptr< ServerCompletionQueue >  cq )

explicit

Definition at line 45 of file load_reporter_async_service_impl.cc.

~LoadReporterAsyncServiceImpl()

grpc::load_reporter::LoadReporterAsyncServiceImpl::~LoadReporterAsyncServiceImpl ( )

override

Definition at line 60 of file load_reporter_async_service_impl.cc.

LoadReporterAsyncServiceImpl() [2/2]

grpc::load_reporter::LoadReporterAsyncServiceImpl::LoadReporterAsyncServiceImpl ( const LoadReporterAsyncServiceImpl &  )

delete

Member Function Documentation

FetchAndSample()

void grpc::load_reporter::LoadReporterAsyncServiceImpl::FetchAndSample ( bool  ok )

private

Definition at line 90 of file load_reporter_async_service_impl.cc.

operator=()

LoadReporterAsyncServiceImpl& grpc::load_reporter::LoadReporterAsyncServiceImpl::operator= ( const LoadReporterAsyncServiceImpl &  )

delete

ScheduleNextFetchAndSample()

void grpc::load_reporter::LoadReporterAsyncServiceImpl::ScheduleNextFetchAndSample ( )

private

Definition at line 73 of file load_reporter_async_service_impl.cc.

StartThread()

void grpc::load_reporter::LoadReporterAsyncServiceImpl::StartThread

(

)

Definition at line 127 of file load_reporter_async_service_impl.cc.

Work()

void grpc::load_reporter::LoadReporterAsyncServiceImpl::Work ( void *  arg )

staticprivate

Definition at line 100 of file load_reporter_async_service_impl.cc.

Member Data Documentation

cq_

std::unique_ptr<ServerCompletionQueue> grpc::load_reporter::LoadReporterAsyncServiceImpl::cq_

private

Definition at line 194 of file load_reporter_async_service_impl.h.

cq_shutdown_mu_

grpc_core::Mutex grpc::load_reporter::LoadReporterAsyncServiceImpl::cq_shutdown_mu_

private

Definition at line 197 of file load_reporter_async_service_impl.h.

load_reporter_

std::unique_ptr<LoadReporter> grpc::load_reporter::LoadReporterAsyncServiceImpl::load_reporter_

private

Definition at line 200 of file load_reporter_async_service_impl.h.

next_fetch_and_sample_alarm_

std::unique_ptr<Alarm> grpc::load_reporter::LoadReporterAsyncServiceImpl::next_fetch_and_sample_alarm_

private

Definition at line 201 of file load_reporter_async_service_impl.h.

shutdown_

std::atomic_bool grpc::load_reporter::LoadReporterAsyncServiceImpl::shutdown_ {false}

private

Definition at line 198 of file load_reporter_async_service_impl.h.

thread_

std::unique_ptr<grpc_core::Thread> grpc::load_reporter::LoadReporterAsyncServiceImpl::thread_

private

Definition at line 199 of file load_reporter_async_service_impl.h.

---

The documentation for this class was generated from the following files:

• load_reporter_async_service_impl.h
• load_reporter_async_service_impl.cc