19 #ifndef GRPCPP_IMPL_CODEGEN_SERVER_INTERFACE_H
20 #define GRPCPP_IMPL_CODEGEN_SERVER_INTERFACE_H
41 class AsyncGenericService;
42 class GenericServerContext;
51 class ServerAsyncStreamingInterface;
54 namespace experimental {
55 class CallbackGenericService;
56 class ServerInterceptorFactoryInterface;
117 friend class ::grpc::Service;
185 void* tag,
bool delete_on_finalize);
191 void ContinueFinalizeResultAfterInterception();
215 void* tag,
const char* name,
226 *
server_->interceptor_creators()));
247 server, context, stream, call_cq, notification_cq, tag,
248 registered_method->name(), registered_method->method_type()) {
255 template <
class Message>
266 server, context, stream, call_cq, notification_cq, tag,
267 registered_method->name(), registered_method->method_type()),
268 registered_method_(registered_method),
285 payload_.bbuf_ptr(), request_)
320 void* tag,
bool delete_on_finalize);
328 template <
class Message>
337 notification_cq, tag, message);
348 notification_cq, tag);
367 std::unique_ptr<experimental::ServerInterceptorFactoryInterface>>*
368 interceptor_creators() {
Definition: async_generic_service.h:75
A sequence of bytes.
Definition: byte_buffer.h:67
void Release()
Forget underlying byte buffer without destroying Use this only for un-owned byte buffers.
Definition: byte_buffer.h:146
bool Valid() const
Is this ByteBuffer valid?
Definition: byte_buffer.h:163
virtual void grpc_call_unref(grpc_call *call)=0
virtual gpr_timespec gpr_inf_future(gpr_clock_type type)=0
virtual grpc_call_error grpc_call_cancel_with_status(grpc_call *call, grpc_status_code status, const char *description, void *reserved)=0
Definition: async_generic_service.h:39
Defines how to serialize and deserialize some type.
Definition: serialization_traits.h:58
Definition: server_interface.h:178
bool FinalizeResult(void **tag, bool *status) override
FinalizeResult must be called before informing user code that the operation bound to the underlying c...
BaseAsyncRequest(ServerInterface *server, ::grpc_impl::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag, bool delete_on_finalize)
virtual ~BaseAsyncRequest()
const bool delete_on_finalize_
Definition: server_interface.h:200
grpc_call * call_
Definition: server_interface.h:201
internal::Call call_wrapper_
Definition: server_interface.h:202
bool done_intercepting_
Definition: server_interface.h:204
::grpc_impl::CompletionQueue *const call_cq_
Definition: server_interface.h:197
::grpc_impl::ServerContext *const context_
Definition: server_interface.h:195
::grpc_impl::ServerCompletionQueue *const notification_cq_
Definition: server_interface.h:198
ServerInterface *const server_
Definition: server_interface.h:194
void *const tag_
Definition: server_interface.h:199
internal::InterceptorBatchMethodsImpl interceptor_methods_
Definition: server_interface.h:203
internal::ServerAsyncStreamingInterface *const stream_
Definition: server_interface.h:196
Definition: server_interface.h:314
bool FinalizeResult(void **tag, bool *status) override
FinalizeResult must be called before informing user code that the operation bound to the underlying c...
GenericAsyncRequest(ServerInterface *server, GenericServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag, bool delete_on_finalize)
Definition: server_interface.h:237
NoPayloadAsyncRequest(internal::RpcServiceMethod *registered_method, ServerInterface *server, ::grpc_impl::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag)
Definition: server_interface.h:239
Definition: server_interface.h:256
~PayloadAsyncRequest()
Definition: server_interface.h:274
bool FinalizeResult(void **tag, bool *status) override
FinalizeResult must be called before informing user code that the operation bound to the underlying c...
Definition: server_interface.h:278
PayloadAsyncRequest(internal::RpcServiceMethod *registered_method, ServerInterface *server, ::grpc_impl::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag, Message *request)
Definition: server_interface.h:258
RegisteredAsyncRequest is not part of the C++ API.
Definition: server_interface.h:208
RegisteredAsyncRequest(ServerInterface *server, ::grpc_impl::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag, const char *name, internal::RpcMethod::RpcType type)
const char * name_
Definition: server_interface.h:233
virtual bool FinalizeResult(void **tag, bool *status) override
FinalizeResult must be called before informing user code that the operation bound to the underlying c...
Definition: server_interface.h:218
void IssueRequest(void *registered_method, grpc_byte_buffer **payload, ::grpc_impl::ServerCompletionQueue *notification_cq)
const internal::RpcMethod::RpcType type_
Definition: server_interface.h:234
NOTE: class experimental_registration_interface is not part of the public API of this class TODO(vjpa...
Definition: server_interface.h:130
virtual ~experimental_registration_interface()
Definition: server_interface.h:132
virtual void RegisterCallbackGenericService(experimental::CallbackGenericService *)
May not be abstract since this is a post-1.0 API addition.
Definition: server_interface.h:134
Definition: server_interface.h:59
void RequestAsyncCall(internal::RpcServiceMethod *method, ::grpc_impl::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag, Message *message)
Definition: server_interface.h:329
void RequestAsyncGenericCall(GenericServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag)
Definition: server_interface.h:351
virtual void PerformOpsOnCall(internal::CallOpSetInterface *ops, internal::Call *call)=0
virtual experimental_registration_interface * experimental_registration()
NOTE: The function experimental_registration() is not stable public API.
Definition: server_interface.h:142
void RequestAsyncCall(internal::RpcServiceMethod *method, ::grpc_impl::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc_impl::CompletionQueue *call_cq, ::grpc_impl::ServerCompletionQueue *notification_cq, void *tag)
Definition: server_interface.h:340
void Shutdown(const T &deadline)
Shutdown does the following things:
Definition: server_interface.h:96
void Shutdown()
Shutdown the server without a deadline and forced cancellation.
Definition: server_interface.h:105
virtual void ShutdownInternal(gpr_timespec deadline)=0
virtual int max_receive_message_size() const =0
virtual grpc_server * server()=0
virtual ~ServerInterface()
Definition: server_interface.h:61
virtual int AddListeningPort(const grpc::string &addr, grpc_impl::ServerCredentials *creds)=0
Tries to bind server to the given addr.
virtual void Wait()=0
Block waiting for all work to complete.
virtual void RegisterAsyncGenericService(AsyncGenericService *service)=0
Register a generic service.
virtual bool RegisterService(const grpc::string *host, Service *service)=0
Register a service.
virtual void Start(::grpc_impl::ServerCompletionQueue **cqs, size_t num_cqs)=0
Start the server.
Desriptor of an RPC service and its various RPC methods.
Definition: service_type.h:60
If you are trying to use CompletionQueue::AsyncNext with a time class that isn't either gpr_timespec ...
Definition: time.h:40
CallbackGenericService is the base class for generic services implemented using the callback API and ...
Definition: async_generic_service.h:121
This is an interface that Channel and Server implement to allow them to hook performing ops.
Definition: call_hook.h:30
Straightforward wrapping of the C call object.
Definition: call.h:38
An abstract collection of call ops, used to generate the grpc_call_op structure to pass down to the l...
Definition: call_op_set_interface.h:34
An interface allowing implementors to process and filter event tags.
Definition: completion_queue_tag.h:26
Definition: interceptor_common.h:37
void AddInterceptionHookPoint(experimental::InterceptionHookPoints type)
Definition: interceptor_common.h:78
void SetRecvMessage(void *message, bool *got_message)
Definition: interceptor_common.h:169
RpcType
Definition: rpc_method.h:31
Server side rpc method class.
Definition: rpc_service_method.h:87
void * server_tag() const
Definition: rpc_service_method.h:106
Definition: service_type.h:41
A thin wrapper around grpc_completion_queue (see src/core/lib/surface/completion_queue....
Definition: completion_queue_impl.h:100
A specific type of completion queue used by the processing of notifications by servers.
Definition: completion_queue_impl.h:389
A ServerContext or CallbackServerContext allows the code implementing a service handler to:
Definition: server_context_impl.h:488
Wrapper around grpc_server_credentials, a way to authenticate a server.
Definition: server_credentials_impl.h:40
@ GPR_CLOCK_MONOTONIC
Monotonic clock.
Definition: gpr_types.h:33
@ GRPC_STATUS_INTERNAL
Internal errors.
Definition: status.h:127
struct grpc_call grpc_call
A Call represents an RPC.
Definition: grpc_types.h:70
struct grpc_server grpc_server
A server listens to some port and responds to request calls.
Definition: grpc_types.h:65
#define GPR_CODEGEN_ASSERT(x)
Codegen specific version of GPR_ASSERT.
Definition: core_codegen_interface.h:146
::google::protobuf::Message Message
Definition: config_protobuf.h:75
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm_impl.h:33
This header provides an object that reads bytes directly from a grpc::ByteBuffer, via the ZeroCopyInp...
Definition: alarm.h:24
::grpc_impl::ServerCompletionQueue ServerCompletionQueue
Definition: completion_queue.h:27
::grpc_impl::ServerCredentials ServerCredentials
Definition: server_credentials.h:30
::grpc_impl::Channel Channel
Definition: channel.h:26
::grpc_impl::CompletionQueue CompletionQueue
Definition: completion_queue.h:26
std::string string
Definition: config.h:35
CoreCodegenInterface * g_core_codegen_interface
Definition: completion_queue_impl.h:90
Analogous to struct timespec.
Definition: gpr_types.h:47
Definition: grpc_types.h:40
Definition: grpc_types.h:535