Actual implementation of bi-directional streaming. More...

Classes
class	AlarmImpl

class	AsyncReaderInterface
	An interface that yields a sequence of messages of type R. More...

class	AsyncWriterInterface
	An interface that can be fed a sequence of messages of type W. More...

class	BidiStreamingHandler

class	BlockingUnaryCallImpl

class	Call
	Straightforward wrapping of the C call object. More...

class	CallbackBidiHandler

class	CallbackClientStreamingHandler

class	CallbackServerStreamingHandler

class	CallbackUnaryCallImpl

class	CallbackUnaryHandler

class	CallbackWithStatusTag

class	CallbackWithSuccessTag

class	CallHook

class	CallNoOp

class	CallOpClientRecvStatus

class	CallOpClientSendClose

class	CallOpGenericRecvMessage

class	CallOpRecvInitialMetadata

class	CallOpRecvMessage

class	CallOpSendInitialMetadata

class	CallOpSendMessage

class	CallOpServerSendStatus

class	CallOpSet

class	CallOpSetInterface

class	CancelInterceptorBatchMethods

class	ChannelFilter

class	ClientAsyncReaderFactory

class	ClientAsyncReaderWriterFactory

class	ClientAsyncResponseReaderFactory

class	ClientAsyncResponseReaderHelper

class	ClientAsyncStreamingInterface
	Common interface for all client side asynchronous streaming. More...

class	ClientAsyncWriterFactory

class	ClientCallbackReaderFactory

class	ClientCallbackReaderImpl

class	ClientCallbackReaderWriterFactory

class	ClientCallbackReaderWriterImpl

class	ClientCallbackUnaryFactory

class	ClientCallbackUnaryImpl

class	ClientCallbackWriterFactory

class	ClientCallbackWriterImpl

class	ClientReactor

class	ClientReaderFactory

class	ClientReaderWriterFactory

class	ClientStreamingHandler
	A wrapper class of an application provided client streaming handler. More...

class	ClientStreamingInterface
	Common interface for all synchronous client side streaming. More...

class	ClientWriterFactory

class	CompletionQueueTag
	An interface allowing implementors to process and filter event tags. More...

class	CondVar

class	DefaultMessageHolder

class	DeserializeFunc

class	DeserializeFuncType

class	ErrorMethodHandler

class	ExternalConnectionAcceptorImpl

class	FinishOnlyReactor

class	GrpcByteBufferPeer

class	GrpcLibrary

class	GrpcLibraryInitializer
	Instantiating this class ensures the proper initialization of gRPC. More...

class	InterceptedChannel

class	InterceptorBatchMethodsImpl

class	MetadataMap

class	MethodHandler
	Base class for running an RPC handler. More...

class	Mutex

class	MutexLock

class	ProtoBufferWriterPeer

class	ProtoUtilsTest

class	ReaderInterface
	An interface that yields a sequence of messages of type R. More...

class	ReleasableMutexLock

class	RpcMethod
	Descriptor of an RPC method. More...

class	RpcMethodHandler
	A wrapper class of an application provided rpc method handler. More...

class	RpcServiceMethod
	Server side rpc method class. More...

class	ServerAsyncStreamingInterface

class	ServerCallbackCall
	The base class of ServerCallbackUnary etc. More...

class	ServerReactor

class	ServerReaderWriterBody

class	ServerStreamingHandler
	A wrapper class of an application provided server streaming handler. More...

class	ServerStreamingInterface
	Common interface for all synchronous server side streaming. More...

class	SplitServerStreamingHandler

class	StreamedUnaryHandler

class	TemplatedBidiStreamingHandler

class	WriterInterface
	An interface that can be fed a sequence of messages of type W. More...

Typedefs
typedef ErrorMethodHandler< grpc::StatusCode::RESOURCE_EXHAUSTED >	ResourceExhaustedHandler

template<class Request , class Response >
using	UnimplementedBidiReactor = FinishOnlyReactor< ServerBidiReactor< Request, Response > >

template<class Request >
using	UnimplementedReadReactor = FinishOnlyReactor< ServerReadReactor< Request > >

using	UnimplementedUnaryReactor = FinishOnlyReactor< ServerUnaryReactor >

template<class Response >
using	UnimplementedWriteReactor = FinishOnlyReactor< ServerWriteReactor< Response > >

typedef ErrorMethodHandler< grpc::StatusCode::UNIMPLEMENTED >	UnknownMethodHandler

Functions
template<class InputMessage , class OutputMessage , class BaseInputMessage = InputMessage, class BaseOutputMessage = OutputMessage>
Status	BlockingUnaryCall (ChannelInterface channel, const RpcMethod &method, grpc::ClientContext context, const InputMessage &request, OutputMessage *result)

template<class InputMessage , class OutputMessage , class BaseInputMessage = InputMessage, class BaseOutputMessage = OutputMessage>
void	CallbackUnaryCall (grpc::ChannelInterface channel, const grpc::internal::RpcMethod &method, grpc::ClientContext context, const InputMessage request, OutputMessage result, std::function< void(grpc::Status)> on_completion)

template<class Func , class... Args>
void	CatchingCallback (Func &&func, Args &&... args)
	An exception-safe way of invoking a user-specified callback function. More...

template<class Callable >
::grpc::Status	CatchingFunctionHandler (Callable &&handler)

template<class Reactor , class Func , class... Args>
Reactor *	CatchingReactorGetter (Func &&func, Args &&... args)

grpc_channel *	CreateClientBinderChannelImpl (const grpc_channel_args *args)

grpc_channel *	CreateDirectBinderChannelImplForTesting (std::unique_ptr< grpc_binder::Binder > endpoint_binder, const grpc_channel_args *args, std::shared_ptr< grpc::experimental::binder::SecurityPolicy > security_policy)

grpc_metadata *	FillMetadataArray (const std::multimap< std::string, std::string > &metadata, size_t *metadata_count, const std::string &optional_error_details)

void	RegisterChannelFilter (grpc_channel_stack_type stack_type, int priority, std::function< bool(const grpc_channel_args &)> include_filter, const grpc_channel_filter *filter)

	TEST_F (ProtoUtilsTest, TinyBackupThenNext)

template<class RequestType >
void *	UnaryDeserializeHelper (grpc_byte_buffer req, grpc::Status status, RequestType *request)
	A helper function with reduced templating to do deserializing. More...

template<class ResponseType >
void	UnaryRunHandlerHelper (const grpc::internal::MethodHandler::HandlerParameter &, ResponseType *, grpc::Status &)

template<typename Predicate >
static void	WaitUntil (CondVar cv, Mutex mu, Predicate pred)

std::shared_ptr< ChannelCredentials >	WrapChannelCredentials (grpc_channel_credentials *creds)

Variables
experimental::ClientInterceptorFactoryInterface *	g_global_client_interceptor_factory = nullptr

const char	kBinaryErrorDetailsKey [] = "grpc-status-details-bin"

Detailed Description

Actual implementation of bi-directional streaming.

Models a gRPC server.

Servers are configured and started via grpc::ServerBuilder.

Typedef Documentation

◆ ResourceExhaustedHandler

typedef ErrorMethodHandler<grpc::StatusCode::RESOURCE_EXHAUSTED> grpc::internal::ResourceExhaustedHandler

Definition at line 401 of file impl/codegen/method_handler.h.

◆ UnimplementedBidiReactor

template<class Request , class Response >

using grpc::internal::UnimplementedBidiReactor = typedef FinishOnlyReactor<ServerBidiReactor<Request, Response> >

Definition at line 784 of file impl/codegen/server_callback.h.

◆ UnimplementedReadReactor

template<class Request >

using grpc::internal::UnimplementedReadReactor = typedef FinishOnlyReactor<ServerReadReactor<Request> >

Definition at line 778 of file impl/codegen/server_callback.h.

◆ UnimplementedUnaryReactor

using grpc::internal::UnimplementedUnaryReactor = typedef FinishOnlyReactor<ServerUnaryReactor>

Definition at line 776 of file impl/codegen/server_callback.h.

◆ UnimplementedWriteReactor

template<class Response >

using grpc::internal::UnimplementedWriteReactor = typedef FinishOnlyReactor<ServerWriteReactor<Response> >

Definition at line 781 of file impl/codegen/server_callback.h.

◆ UnknownMethodHandler

typedef ErrorMethodHandler<grpc::StatusCode::UNIMPLEMENTED> grpc::internal::UnknownMethodHandler

Definition at line 399 of file impl/codegen/method_handler.h.

Function Documentation

◆ BlockingUnaryCall()

template<class InputMessage , class OutputMessage , class BaseInputMessage = InputMessage, class BaseOutputMessage = OutputMessage>

Status grpc::internal::BlockingUnaryCall	(	ChannelInterface *	channel,
		const RpcMethod &	method,
		grpc::ClientContext *	context,
		const InputMessage &	request,
		OutputMessage *	result
	)

Wrapper that performs a blocking unary call. May optionally specify the base class of the Request and Response so that the internal calls and structures below this may be based on those base classes and thus achieve code reuse across different RPCs (e.g., for protobuf, MessageLite would be a base class).

Definition at line 45 of file grpcpp/impl/codegen/client_unary_call.h.

◆ CallbackUnaryCall()

template<class InputMessage , class OutputMessage , class BaseInputMessage = InputMessage, class BaseOutputMessage = OutputMessage>

void grpc::internal::CallbackUnaryCall	(	grpc::ChannelInterface *	channel,
		const grpc::internal::RpcMethod &	method,
		grpc::ClientContext *	context,
		const InputMessage *	request,
		OutputMessage *	result,
		std::function< void(grpc::Status)>	on_completion
	)

Perform a callback-based unary call. May optionally specify the base class of the Request and Response so that the internal calls and structures below this may be based on those base classes and thus achieve code reuse across different RPCs (e.g., for protobuf, MessageLite would be a base class). TODO(vjpai): Combine as much as possible with the blocking unary call code

Definition at line 51 of file impl/codegen/client_callback.h.

◆ CatchingCallback()

template<class Func , class... Args>

void grpc::internal::CatchingCallback	(	Func &&	func,
		Args &&...	args
	)

An exception-safe way of invoking a user-specified callback function.

Definition at line 41 of file callback_common.h.

◆ CatchingFunctionHandler()

template<class Callable >

::grpc::Status grpc::internal::CatchingFunctionHandler ( Callable && handler )

Definition at line 41 of file impl/codegen/method_handler.h.

◆ CatchingReactorGetter()

template<class Reactor , class Func , class... Args>

Reactor* grpc::internal::CatchingReactorGetter	(	Func &&	func,
		Args &&...	args
	)

Definition at line 54 of file callback_common.h.

◆ CreateClientBinderChannelImpl()

grpc_channel * grpc::internal::CreateClientBinderChannelImpl ( const grpc_channel_args * args )

Definition at line 67 of file channel_create_impl.cc.

◆ CreateDirectBinderChannelImplForTesting()

grpc_channel * grpc::internal::CreateDirectBinderChannelImplForTesting	(	std::unique_ptr< grpc_binder::Binder >	endpoint_binder,
		const grpc_channel_args *	args,
		std::shared_ptr< grpc::experimental::binder::SecurityPolicy >	security_policy
	)

Definition at line 43 of file channel_create_impl.cc.

◆ FillMetadataArray()

grpc_metadata* grpc::internal::FillMetadataArray	(	const std::multimap< std::string, std::string > &	metadata,
		size_t *	metadata_count,
		const std::string &	optional_error_details
	)

inline

Definition at line 55 of file call_op_set.h.

◆ RegisterChannelFilter()

void grpc::internal::RegisterChannelFilter	(	grpc_channel_stack_type	stack_type,
		int	priority,
		std::function< bool(const grpc_channel_args &)>	include_filter,
		const grpc_channel_filter *	filter
	)

Definition at line 73 of file common/channel_filter.cc.

◆ TEST_F()

grpc::internal::TEST_F	(	ProtoUtilsTest	,
		TinyBackupThenNext
	)

Definition at line 72 of file proto_utils_test.cc.

◆ UnaryDeserializeHelper()

template<class RequestType >

void * grpc::internal::UnaryDeserializeHelper	(	grpc_byte_buffer *	req,
		grpc::Status *	status,
		RequestType *	request
	)

A helper function with reduced templating to do deserializing.

Definition at line 82 of file impl/codegen/method_handler.h.

◆ UnaryRunHandlerHelper()

template<class ResponseType >

void grpc::internal::UnaryRunHandlerHelper	(	const grpc::internal::MethodHandler::HandlerParameter &	,
		ResponseType *	,
		grpc::Status &
	)

A helper function with reduced templating to do the common work needed to actually send the server response. Uses non-const parameter for Status since this should only ever be called from the end of the RunHandler method.

Definition at line 59 of file impl/codegen/method_handler.h.

◆ WaitUntil()

template<typename Predicate >

static void grpc::internal::WaitUntil	(	CondVar *	cv,
		Mutex *	mu,
		Predicate	pred
	)

static

Definition at line 149 of file include/grpcpp/impl/codegen/sync.h.

◆ WrapChannelCredentials()

std::shared_ptr< ChannelCredentials > grpc::internal::WrapChannelCredentials ( grpc_channel_credentials * creds )

Definition at line 96 of file secure_credentials.cc.

Variable Documentation

◆ g_global_client_interceptor_factory

experimental::ClientInterceptorFactoryInterface * grpc::internal::g_global_client_interceptor_factory = nullptr

Definition at line 26 of file client_interceptor.cc.

◆ kBinaryErrorDetailsKey

const char grpc::internal::kBinaryErrorDetailsKey[] = "grpc-status-details-bin"

Definition at line 33 of file grpcpp/impl/codegen/metadata_map.h.

Classes

Typedefs

Functions

Variables