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