Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | List of all members
grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler Class Reference
Inheritance diagram for grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler:
Inheritance graph
[legend]

Public Member Functions

void SendHealth (std::shared_ptr< CallHandler > self, ServingStatus status) override
 
 WatchCallHandler (ServerCompletionQueue *cq, DefaultHealthCheckService *database, HealthCheckServiceImpl *service)
 
- Public Member Functions inherited from grpc::DefaultHealthCheckService::HealthCheckServiceImpl::CallHandler
virtual ~CallHandler ()=default
 

Static Public Member Functions

static void CreateAndStart (ServerCompletionQueue *cq, DefaultHealthCheckService *database, HealthCheckServiceImpl *service)
 

Private Member Functions

void OnCallReceived (std::shared_ptr< CallHandler > self, bool ok)
 
void OnDoneNotified (std::shared_ptr< CallHandler > self, bool ok)
 
void OnFinishDone (std::shared_ptr< CallHandler > self, bool ok)
 
void OnSendHealthDone (std::shared_ptr< CallHandler > self, bool ok)
 
void SendFinish (std::shared_ptr< CallHandler > self, const Status &status)
 
void SendFinishLocked (std::shared_ptr< CallHandler > self, const Status &status)
 
void SendHealthLocked (std::shared_ptr< CallHandler > self, ServingStatus status)
 

Private Attributes

ServerCompletionQueue * cq_
 
ServerContext ctx_
 
DefaultHealthCheckService * database_
 
bool finish_called_ = false
 
CallableTag next_
 
CallableTag on_done_notified_
 
CallableTag on_finish_done_
 
ServingStatus pending_status_ = NOT_FOUND
 
ByteBuffer request_
 
bool send_in_flight_ = false
 
grpc_core::Mutex send_mu_
 
HealthCheckServiceImpl * service_
 
std::string service_name_
 
GenericServerAsyncWriter stream_
 

Detailed Description

Definition at line 156 of file default_health_check_service.h.

Constructor & Destructor Documentation

◆ WatchCallHandler()

grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::WatchCallHandler ( ServerCompletionQueue *  cq,
DefaultHealthCheckService *  database,
HealthCheckServiceImpl *  service 
)

Definition at line 369 of file default_health_check_service.cc.

Member Function Documentation

◆ CreateAndStart()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::CreateAndStart ( ServerCompletionQueue *  cq,
DefaultHealthCheckService *  database,
HealthCheckServiceImpl *  service 
)
static

Definition at line 342 of file default_health_check_service.cc.

◆ OnCallReceived()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::OnCallReceived ( std::shared_ptr< CallHandler >  self,
bool  ok 
)
private

Definition at line 375 of file default_health_check_service.cc.

◆ OnDoneNotified()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::OnDoneNotified ( std::shared_ptr< CallHandler >  self,
bool  ok 
)
private

Definition at line 488 of file default_health_check_service.cc.

◆ OnFinishDone()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::OnFinishDone ( std::shared_ptr< CallHandler >  self,
bool  ok 
)
private

Definition at line 474 of file default_health_check_service.cc.

◆ OnSendHealthDone()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::OnSendHealthDone ( std::shared_ptr< CallHandler >  self,
bool  ok 
)
private

Definition at line 439 of file default_health_check_service.cc.

◆ SendFinish()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::SendFinish ( std::shared_ptr< CallHandler >  self,
const Status &  status 
)
private

Definition at line 456 of file default_health_check_service.cc.

◆ SendFinishLocked()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::SendFinishLocked ( std::shared_ptr< CallHandler >  self,
const Status &  status 
)
private

Definition at line 464 of file default_health_check_service.cc.

◆ SendHealth()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::SendHealth ( std::shared_ptr< CallHandler >  self,
ServingStatus  status 
)
overridevirtual

Implements grpc::DefaultHealthCheckService::HealthCheckServiceImpl::CallHandler.

Definition at line 403 of file default_health_check_service.cc.

◆ SendHealthLocked()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::SendHealthLocked ( std::shared_ptr< CallHandler >  self,
ServingStatus  status 
)
private

Definition at line 416 of file default_health_check_service.cc.

Member Data Documentation

◆ cq_

ServerCompletionQueue* grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::cq_
private

Definition at line 199 of file default_health_check_service.h.

◆ ctx_

ServerContext grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::ctx_
private

Definition at line 206 of file default_health_check_service.h.

◆ database_

DefaultHealthCheckService* grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::database_
private

Definition at line 200 of file default_health_check_service.h.

◆ finish_called_

bool grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::finish_called_ = false
private

Definition at line 212 of file default_health_check_service.h.

◆ next_

CallableTag grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::next_
private

Definition at line 213 of file default_health_check_service.h.

◆ on_done_notified_

CallableTag grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::on_done_notified_
private

Definition at line 214 of file default_health_check_service.h.

◆ on_finish_done_

CallableTag grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::on_finish_done_
private

Definition at line 215 of file default_health_check_service.h.

◆ pending_status_

ServingStatus grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::pending_status_ = NOT_FOUND
private

Definition at line 210 of file default_health_check_service.h.

◆ request_

ByteBuffer grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::request_
private

Definition at line 203 of file default_health_check_service.h.

◆ send_in_flight_

bool grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::send_in_flight_ = false
private

Definition at line 209 of file default_health_check_service.h.

◆ send_mu_

grpc_core::Mutex grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::send_mu_
private

Definition at line 208 of file default_health_check_service.h.

◆ service_

HealthCheckServiceImpl* grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::service_
private

Definition at line 201 of file default_health_check_service.h.

◆ service_name_

std::string grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::service_name_
private

Definition at line 204 of file default_health_check_service.h.

◆ stream_

GenericServerAsyncWriter grpc::DefaultHealthCheckService::HealthCheckServiceImpl::WatchCallHandler::stream_
private

Definition at line 205 of file default_health_check_service.h.

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

grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:30