grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl Class Reference

Inheritance diagram for grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl:

Public Member Functions
void	Finish (grpc::Status s) override
void	Read (RequestType *req) override
void	SendInitialMetadata () override
Public Member Functions inherited from grpc::ServerCallbackReader< RequestType >
	~ServerCallbackReader () override
Public Member Functions inherited from grpc::internal::ServerCallbackCall
void	MaybeCallOnCancel ()
void	MaybeCallOnCancel (ServerReactor *reactor)
void	MaybeDone ()
void	MaybeDone (bool inline_ondone)
virtual	~ServerCallbackCall ()

Private Member Functions
void	CallOnDone () override
ServerReactor *	reactor () override
ResponseType *	response ()
	ServerCallbackReaderImpl (grpc::CallbackServerContext *ctx, grpc::internal::Call *call, std::function< void()> call_requester)
void	SetupReactor (ServerReadReactor< RequestType > *reactor)
	~ServerCallbackReaderImpl ()

Private Attributes
grpc::internal::Call	call_
std::function< void()>	call_requester_
std::atomic< intptr_t >	callbacks_outstanding_
grpc::CallbackServerContext *const	ctx_
grpc::internal::CallOpSet< grpc::internal::CallOpSendInitialMetadata, grpc::internal::CallOpSendMessage, grpc::internal::CallOpServerSendStatus >	finish_ops_
grpc::internal::CallbackWithSuccessTag	finish_tag_
grpc::internal::CallOpSet< grpc::internal::CallOpSendInitialMetadata >	meta_ops_
grpc::internal::CallbackWithSuccessTag	meta_tag_
std::atomic< ServerReadReactor< RequestType > * >	reactor_
grpc::internal::CallOpSet< grpc::internal::CallOpRecvMessage< RequestType > >	read_ops_
grpc::internal::CallbackWithSuccessTag	read_tag_
ResponseType	resp_

Friends
class	CallbackClientStreamingHandler< RequestType, ResponseType >

Additional Inherited Members
Protected Member Functions inherited from grpc::ServerCallbackReader< RequestType >
void	BindReactor (ServerReadReactor< RequestType > *reactor)
Protected Member Functions inherited from grpc::internal::ServerCallbackCall
void	Ref ()
	Increases the reference count. More...

Detailed Description

template<class RequestType, class ResponseType>
class grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl

Definition at line 301 of file server_callback_handlers.h.

Constructor & Destructor Documentation

ServerCallbackReaderImpl()

template<class RequestType , class ResponseType >

grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::ServerCallbackReaderImpl ( grpc::CallbackServerContext *  ctx, grpc::internal::Call *  call, std::function< void()>  call_requester  )

inlineprivate

Definition at line 369 of file server_callback_handlers.h.

~ServerCallbackReaderImpl()

template<class RequestType , class ResponseType >

grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::~ServerCallbackReaderImpl ( )

inlineprivate

Definition at line 398 of file server_callback_handlers.h.

Member Function Documentation

CallOnDone()

template<class RequestType , class ResponseType >

void grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::CallOnDone ( )

inlineoverrideprivatevirtual

Implements grpc::internal::ServerCallbackCall.

Definition at line 402 of file server_callback_handlers.h.

Finish()

template<class RequestType , class ResponseType >

void grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::Finish ( grpc::Status  s )

inlineoverridevirtual

Implements grpc::ServerCallbackReader< RequestType >.

Definition at line 303 of file server_callback_handlers.h.

reactor()

template<class RequestType , class ResponseType >

ServerReactor* grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::reactor ( )

inlineoverrideprivatevirtual

Implements grpc::internal::ServerCallbackCall.

Definition at line 414 of file server_callback_handlers.h.

Read()

template<class RequestType , class ResponseType >

void grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::Read ( RequestType *  req )

inlineoverridevirtual

Implements grpc::ServerCallbackReader< RequestType >.

Definition at line 360 of file server_callback_handlers.h.

response()

template<class RequestType , class ResponseType >

ResponseType* grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::response ( )

inlineprivate

Definition at line 400 of file server_callback_handlers.h.

SendInitialMetadata()

template<class RequestType , class ResponseType >

void grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::SendInitialMetadata ( )

inlineoverridevirtual

Implements grpc::ServerCallbackReader< RequestType >.

Definition at line 335 of file server_callback_handlers.h.

SetupReactor()

template<class RequestType , class ResponseType >

void grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::SetupReactor ( ServerReadReactor< RequestType > *  reactor )

inlineprivate

Definition at line 374 of file server_callback_handlers.h.

Friends And Related Function Documentation

CallbackClientStreamingHandler< RequestType, ResponseType >

template<class RequestType , class ResponseType >

friend class CallbackClientStreamingHandler< RequestType, ResponseType >

friend

Definition at line 367 of file server_callback_handlers.h.

Member Data Documentation

call_

template<class RequestType , class ResponseType >

grpc::internal::Call grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::call_

private

Definition at line 431 of file server_callback_handlers.h.

call_requester_

template<class RequestType , class ResponseType >

std::function<void()> grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::call_requester_

private

Definition at line 433 of file server_callback_handlers.h.

callbacks_outstanding_

template<class RequestType , class ResponseType >

std::atomic<intptr_t> grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::callbacks_outstanding_

private

Initial value:

{
        3}

Definition at line 437 of file server_callback_handlers.h.

ctx_

template<class RequestType , class ResponseType >

grpc::CallbackServerContext* const grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::ctx_

private

Definition at line 430 of file server_callback_handlers.h.

finish_ops_

template<class RequestType , class ResponseType >

grpc::internal::CallOpSet<grpc::internal::CallOpSendInitialMetadata, grpc::internal::CallOpSendMessage, grpc::internal::CallOpServerSendStatus> grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::finish_ops_

private

Definition at line 424 of file server_callback_handlers.h.

finish_tag_

template<class RequestType , class ResponseType >

grpc::internal::CallbackWithSuccessTag grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::finish_tag_

private

Definition at line 425 of file server_callback_handlers.h.

meta_ops_

template<class RequestType , class ResponseType >

grpc::internal::CallOpSet<grpc::internal::CallOpSendInitialMetadata> grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::meta_ops_

private

Definition at line 419 of file server_callback_handlers.h.

meta_tag_

template<class RequestType , class ResponseType >

grpc::internal::CallbackWithSuccessTag grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::meta_tag_

private

Definition at line 420 of file server_callback_handlers.h.

reactor_

template<class RequestType , class ResponseType >

std::atomic<ServerReadReactor<RequestType>*> grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::reactor_

private

Definition at line 435 of file server_callback_handlers.h.

read_ops_

template<class RequestType , class ResponseType >

grpc::internal::CallOpSet<grpc::internal::CallOpRecvMessage<RequestType> > grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::read_ops_

private

Definition at line 427 of file server_callback_handlers.h.

read_tag_

template<class RequestType , class ResponseType >

grpc::internal::CallbackWithSuccessTag grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::read_tag_

private

Definition at line 428 of file server_callback_handlers.h.

resp_

template<class RequestType , class ResponseType >

ResponseType grpc::internal::CallbackClientStreamingHandler< RequestType, ResponseType >::ServerCallbackReaderImpl::resp_

private

Definition at line 432 of file server_callback_handlers.h.

---

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

• server_callback_handlers.h