grpc::Server::SyncRequestThreadManager Class Reference

Inheritance diagram for grpc::Server::SyncRequestThreadManager:

Public Member Functions
void	AddSyncMethod (grpc::internal::RpcServiceMethod *method, void *tag)
void	AddUnknownSyncMethod ()
void	DoWork (void *tag, bool ok, bool resources) override
WorkStatus	PollForWork (void **tag, bool *ok) override
void	Shutdown () override
void	Start ()
	SyncRequestThreadManager (Server *server, grpc::CompletionQueue *server_cq, std::shared_ptr< GlobalCallbacks > global_callbacks, grpc_resource_quota *rq, int min_pollers, int max_pollers, int cq_timeout_msec)
void	Wait () override
Public Member Functions inherited from grpc::ThreadManager
int	GetMaxActiveThreadsSoFar ()
void	Initialize ()
bool	IsShutdown ()
	ThreadManager (const char *name, grpc_resource_quota *resource_quota, int min_pollers, int max_pollers)
virtual	~ThreadManager ()

Private Attributes
int	cq_timeout_msec_
std::shared_ptr< Server::GlobalCallbacks >	global_callbacks_
bool	has_sync_method_ = false
Server *	server_
grpc::CompletionQueue *	server_cq_
std::unique_ptr< grpc::internal::RpcServiceMethod >	unknown_method_

Additional Inherited Members
Public Types inherited from grpc::ThreadManager
enum	WorkStatus { WORK_FOUND, SHUTDOWN, TIMEOUT }

Detailed Description

Definition at line 776 of file server_cc.cc.

Constructor & Destructor Documentation

SyncRequestThreadManager()

grpc::Server::SyncRequestThreadManager::SyncRequestThreadManager ( Server *  server, grpc::CompletionQueue *  server_cq, std::shared_ptr< GlobalCallbacks >  global_callbacks, grpc_resource_quota *  rq, int  min_pollers, int  max_pollers, int  cq_timeout_msec  )

inline

Definition at line 778 of file server_cc.cc.

Member Function Documentation

AddSyncMethod()

void grpc::Server::SyncRequestThreadManager::AddSyncMethod ( grpc::internal::RpcServiceMethod *  method, void *  tag  )

inline

Definition at line 821 of file server_cc.cc.

AddUnknownSyncMethod()

void grpc::Server::SyncRequestThreadManager::AddUnknownSyncMethod ( )

inline

Definition at line 831 of file server_cc.cc.

DoWork()

void grpc::Server::SyncRequestThreadManager::DoWork ( void *  tag, bool  ok, bool  resources  )

inlineoverridevirtual

Implements grpc::ThreadManager.

Definition at line 808 of file server_cc.cc.

PollForWork()

WorkStatus grpc::Server::SyncRequestThreadManager::PollForWork ( void **  tag, bool *  ok  )

inlineoverridevirtual

Implements grpc::ThreadManager.

Definition at line 788 of file server_cc.cc.

Shutdown()

void grpc::Server::SyncRequestThreadManager::Shutdown ( )

inlineoverridevirtual

Reimplemented from grpc::ThreadManager.

Definition at line 845 of file server_cc.cc.

Start()

void grpc::Server::SyncRequestThreadManager::Start ( )

inline

Definition at line 862 of file server_cc.cc.

Wait()

void grpc::Server::SyncRequestThreadManager::Wait ( )

inlineoverridevirtual

Reimplemented from grpc::ThreadManager.

Definition at line 850 of file server_cc.cc.

Member Data Documentation

cq_timeout_msec_

int grpc::Server::SyncRequestThreadManager::cq_timeout_msec_

private

Definition at line 871 of file server_cc.cc.

global_callbacks_

std::shared_ptr<Server::GlobalCallbacks> grpc::Server::SyncRequestThreadManager::global_callbacks_

private

Definition at line 874 of file server_cc.cc.

has_sync_method_

bool grpc::Server::SyncRequestThreadManager::has_sync_method_ = false

private

Definition at line 872 of file server_cc.cc.

server_

Server* grpc::Server::SyncRequestThreadManager::server_

private

Definition at line 869 of file server_cc.cc.

server_cq_

grpc::CompletionQueue* grpc::Server::SyncRequestThreadManager::server_cq_

private

Definition at line 870 of file server_cc.cc.

unknown_method_

std::unique_ptr<grpc::internal::RpcServiceMethod> grpc::Server::SyncRequestThreadManager::unknown_method_

private

Definition at line 873 of file server_cc.cc.

---

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

• server_cc.cc