19 #ifndef GRPCPP_IMPL_CODEGEN_SERVER_INTERFACE_H
20 #define GRPCPP_IMPL_CODEGEN_SERVER_INTERFACE_H
36 class AsyncGenericService;
38 class CompletionQueue;
39 class GenericServerContext;
40 class ServerCompletionQueue;
41 class ServerCredentials;
50 class ServerAsyncStreamingInterface;
53 class CallbackGenericService;
55 namespace experimental {
56 class ServerInterceptorFactoryInterface;
117 friend class ::grpc::Service;
171 bool delete_on_finalize);
177 void ContinueFinalizeResultAfterInterception();
201 void* tag,
const char* name,
212 *
server_->interceptor_creators()));
233 server, context, stream, call_cq, notification_cq, tag,
234 registered_method->name(), registered_method->method_type()) {
241 template <
class Message>
251 server, context, stream, call_cq, notification_cq, tag,
252 registered_method->name(), registered_method->method_type()),
253 registered_method_(registered_method),
270 payload_.bbuf_ptr(), request_)
305 void* tag,
bool delete_on_finalize);
313 template <
class Message>
322 notification_cq, tag, message);
333 notification_cq, tag);
352 std::unique_ptr<experimental::ServerInterceptorFactoryInterface>>*
353 interceptor_creators() {
365 virtual ::grpc::CompletionQueue* CallbackCQ() {
return nullptr; }
Definition: async_generic_service.h:68
A sequence of bytes.
Definition: byte_buffer.h:60
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
CallbackGenericService is the base class for generic services implemented using the callback API and ...
Definition: async_generic_service.h:102
A thin wrapper around grpc_completion_queue (see src/core/lib/surface/completion_queue....
Definition: completion_queue.h:102
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
A specific type of completion queue used by the processing of notifications by servers.
Definition: completion_queue.h:429
A ServerContext or CallbackServerContext allows the code implementing a service handler to:
Definition: server_context.h:538
Wrapper around grpc_server_credentials, a way to authenticate a server.
Definition: server_credentials.h:70
Definition: server_interface.h:165
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_cc.cc:144
~BaseAsyncRequest() override
Definition: server_cc.cc:140
BaseAsyncRequest(ServerInterface *server, ::grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag, bool delete_on_finalize)
Definition: server_cc.cc:119
const bool delete_on_finalize_
Definition: server_interface.h:186
grpc_call * call_
Definition: server_interface.h:187
internal::Call call_wrapper_
Definition: server_interface.h:188
bool done_intercepting_
Definition: server_interface.h:190
ServerInterface *const server_
Definition: server_interface.h:180
::grpc::ServerContext *const context_
Definition: server_interface.h:181
::grpc::CompletionQueue *const call_cq_
Definition: server_interface.h:183
void *const tag_
Definition: server_interface.h:185
internal::InterceptorBatchMethodsImpl interceptor_methods_
Definition: server_interface.h:189
internal::ServerAsyncStreamingInterface *const stream_
Definition: server_interface.h:182
::grpc::ServerCompletionQueue *const notification_cq_
Definition: server_interface.h:184
Definition: server_interface.h:299
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_cc.cc:241
GenericAsyncRequest(ServerInterface *server, GenericServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag, bool delete_on_finalize)
Definition: server_cc.cc:224
Definition: server_interface.h:223
NoPayloadAsyncRequest(internal::RpcServiceMethod *registered_method, ServerInterface *server, ::grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag)
Definition: server_interface.h:225
Definition: server_interface.h:242
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:263
PayloadAsyncRequest(internal::RpcServiceMethod *registered_method, ServerInterface *server, ::grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag, Message *request)
Definition: server_interface.h:244
~PayloadAsyncRequest() override
Definition: server_interface.h:259
RegisteredAsyncRequest is not part of the C++ API.
Definition: server_interface.h:194
const char * name_
Definition: server_interface.h:219
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:204
void IssueRequest(void *registered_method, grpc_byte_buffer **payload, ::grpc::ServerCompletionQueue *notification_cq)
Definition: server_cc.cc:212
RegisteredAsyncRequest(ServerInterface *server, ::grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag, const char *name, internal::RpcMethod::RpcType type)
Definition: server_cc.cc:202
const internal::RpcMethod::RpcType type_
Definition: server_interface.h:220
Definition: server_interface.h:59
void RequestAsyncGenericCall(GenericServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag)
Definition: server_interface.h:336
virtual bool RegisterService(const std::string *host, Service *service)=0
Register a service.
virtual int AddListeningPort(const std::string &addr, ServerCredentials *creds)=0
Tries to bind server to the given addr.
~ServerInterface() override
Definition: server_interface.h:61
virtual void Start(::grpc::ServerCompletionQueue **cqs, size_t num_cqs)=0
Start the server.
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 void RegisterCallbackGenericService(CallbackGenericService *)
Register a callback generic service.
Definition: server_interface.h:131
virtual int max_receive_message_size() const =0
virtual grpc_server * server()=0
void PerformOpsOnCall(internal::CallOpSetInterface *ops, internal::Call *call) override=0
virtual void Wait()=0
Block waiting for all work to complete.
void RequestAsyncCall(internal::RpcServiceMethod *method, ::grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag)
Definition: server_interface.h:325
void RequestAsyncCall(internal::RpcServiceMethod *method, ::grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, ::grpc::CompletionQueue *call_cq, ::grpc::ServerCompletionQueue *notification_cq, void *tag, Message *message)
Definition: server_interface.h:314
virtual void RegisterAsyncGenericService(AsyncGenericService *service)=0
Register a generic service.
Desriptor of an RPC service and its various RPC methods.
Definition: service_type.h:56
If you are trying to use CompletionQueue::AsyncNext with a time class that isn't either gpr_timespec ...
Definition: time.h:40
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:35
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 *hijacked_recv_message_failed)
Definition: interceptor_common.h:168
RpcType
Definition: rpc_method.h:31
Server side rpc method class.
Definition: rpc_service_method.h:84
void * server_tag() const
Definition: rpc_service_method.h:103
Definition: service_type.h:37
@ GPR_CLOCK_MONOTONIC
Monotonic clock.
Definition: gpr_types.h:33
@ GRPC_STATUS_INTERNAL
Internal errors.
Definition: status.h:127
#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:76
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
CoreCodegenInterface * g_core_codegen_interface
Null-initializes the global gRPC variables for the codegen library.
Definition: completion_queue.h:96
Analogous to struct timespec.
Definition: gpr_types.h:47
Definition: grpc_types.h:40
Definition: grpc_types.h:569
DiscoveryMechanismType type
Definition: xds_cluster_resolver.cc:73