grpc::Server::SyncRequest Class Reference

Inheritance diagram for grpc::Server::SyncRequest:

Classes
struct	ServerContextWrapper

Public Member Functions
void	Cleanup ()
void	ContinueRunAfterInterception ()
bool	FinalizeResult (void **, bool *status) override
void	Run (const std::shared_ptr< GlobalCallbacks > &global_callbacks, bool resources)
	SyncRequest (Server *server, grpc::internal::RpcServiceMethod *method, grpc_core::Server::BatchCallAllocation *data)
	SyncRequest (Server *server, grpc::internal::RpcServiceMethod *method, grpc_core::Server::RegisteredCallAllocation *data)
	~SyncRequest () override
Public Member Functions inherited from grpc::internal::CompletionQueueTag
virtual	~CompletionQueueTag ()

Private Member Functions
template<class CallAllocation >
void	CommonSetup (CallAllocation *data)
	SyncRequest (Server *server, grpc::internal::RpcServiceMethod *method)

Private Attributes
grpc_call *	call_
grpc_call_details *	call_details_ = nullptr
grpc::CompletionQueue	cq_
grpc_core::ManualConstructor< ServerContextWrapper >	ctx_
gpr_timespec	deadline_
void *	deserialized_request_ = nullptr
std::shared_ptr< GlobalCallbacks >	global_callbacks_
const bool	has_request_payload_
grpc::internal::InterceptorBatchMethodsImpl	interceptor_methods_
grpc::internal::RpcServiceMethod *const	method_
grpc_metadata_array	request_metadata_
grpc_byte_buffer *	request_payload_ = nullptr
grpc::Status	request_status_
bool	resources_
Server *const	server_
grpc_core::ManualConstructor< internal::Call >	wrapped_call_

Detailed Description

Definition at line 365 of file server_cc.cc.

Constructor & Destructor Documentation

SyncRequest() [1/3]

grpc::Server::SyncRequest::SyncRequest ( Server *  server, grpc::internal::RpcServiceMethod *  method, grpc_core::Server::RegisteredCallAllocation *  data  )

inline

Definition at line 367 of file server_cc.cc.

SyncRequest() [2/3]

grpc::Server::SyncRequest::SyncRequest ( Server *  server, grpc::internal::RpcServiceMethod *  method, grpc_core::Server::BatchCallAllocation *  data  )

inline

Definition at line 375 of file server_cc.cc.

~SyncRequest()

grpc::Server::SyncRequest::~SyncRequest ( )

inlineoverride

Definition at line 384 of file server_cc.cc.

SyncRequest() [3/3]

grpc::Server::SyncRequest::SyncRequest ( Server *  server, grpc::internal::RpcServiceMethod *  method  )

inlineprivate

Definition at line 489 of file server_cc.cc.

Member Function Documentation

Cleanup()

void grpc::Server::SyncRequest::Cleanup ( )

inline

Definition at line 482 of file server_cc.cc.

CommonSetup()

template<class CallAllocation >

void grpc::Server::SyncRequest::CommonSetup ( CallAllocation *  data )

inlineprivate

Definition at line 499 of file server_cc.cc.

ContinueRunAfterInterception()

void grpc::Server::SyncRequest::ContinueRunAfterInterception ( )

inline

Definition at line 455 of file server_cc.cc.

FinalizeResult()

bool grpc::Server::SyncRequest::FinalizeResult ( void **  tag, bool *  status  )

inlineoverridevirtual

FinalizeResult must be called before informing user code that the operation bound to the underlying core completion queue tag has completed. In practice, this means:

1. For the sync API - before returning from Pluck
2. For the CQ-based async API - before returning from Next
3. For the callback-based API - before invoking the user callback

This is the method that translates from core-side tag/status to C++ API-observable tag/status.

The return value is the status of the operation (returning status is the general behavior of this function). If this function returns false, the tag is dropped and not returned from the completion queue: this concept is for events that are observed at core but not requested by the user application (e.g., server shutdown, for server unimplemented method responses, or for cases where a server-side RPC doesn't have a completion notification registered using AsyncNotifyWhenDone)

Implements grpc::internal::CompletionQueueTag.

Definition at line 399 of file server_cc.cc.

Run()

void grpc::Server::SyncRequest::Run ( const std::shared_ptr< GlobalCallbacks > &  global_callbacks, bool  resources  )

inline

Definition at line 410 of file server_cc.cc.

Member Data Documentation

call_

grpc_call* grpc::Server::SyncRequest::call_

private

Definition at line 511 of file server_cc.cc.

call_details_

grpc_call_details* grpc::Server::SyncRequest::call_details_ = nullptr

private

Definition at line 512 of file server_cc.cc.

cq_

grpc::CompletionQueue grpc::Server::SyncRequest::cq_

private

Definition at line 516 of file server_cc.cc.

ctx_

grpc_core::ManualConstructor<ServerContextWrapper> grpc::Server::SyncRequest::ctx_

private

Definition at line 532 of file server_cc.cc.

deadline_

gpr_timespec grpc::Server::SyncRequest::deadline_

private

Definition at line 513 of file server_cc.cc.

deserialized_request_

void* grpc::Server::SyncRequest::deserialized_request_ = nullptr

private

Definition at line 520 of file server_cc.cc.

global_callbacks_

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

private

Definition at line 518 of file server_cc.cc.

has_request_payload_

const bool grpc::Server::SyncRequest::has_request_payload_

private

Definition at line 510 of file server_cc.cc.

interceptor_methods_

grpc::internal::InterceptorBatchMethodsImpl grpc::Server::SyncRequest::interceptor_methods_

private

Definition at line 521 of file server_cc.cc.

method_

grpc::internal::RpcServiceMethod* const grpc::Server::SyncRequest::method_

private

Definition at line 509 of file server_cc.cc.

request_metadata_

grpc_metadata_array grpc::Server::SyncRequest::request_metadata_

private

Definition at line 514 of file server_cc.cc.

request_payload_

grpc_byte_buffer* grpc::Server::SyncRequest::request_payload_ = nullptr

private

Definition at line 515 of file server_cc.cc.

request_status_

grpc::Status grpc::Server::SyncRequest::request_status_

private

Definition at line 517 of file server_cc.cc.

resources_

bool grpc::Server::SyncRequest::resources_

private

Definition at line 519 of file server_cc.cc.

server_

Server* const grpc::Server::SyncRequest::server_

private

Definition at line 508 of file server_cc.cc.

wrapped_call_

grpc_core::ManualConstructor<internal::Call> grpc::Server::SyncRequest::wrapped_call_

private

Definition at line 533 of file server_cc.cc.

---

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

• server_cc.cc