Go to the documentation of this file.
19 #ifndef GRPCPP_SUPPORT_SERVER_INTERCEPTOR_H
20 #define GRPCPP_SUPPORT_SERVER_INTERCEPTOR_H
31 class ServerContextBase;
33 class InterceptorBatchMethodsImpl;
36 namespace experimental {
73 const char*
method()
const {
return method_; }
85 "violated expectation about Type enum");
88 "violated expectation about Type enum");
91 "violated expectation about Type enum");
94 "violated expectation about Type enum");
104 interceptors_[pos]->Intercept(interceptor_methods);
107 void RegisterInterceptors(
109 std::unique_ptr<experimental::ServerInterceptorFactoryInterface>>&
111 for (
const auto& creator : creators) {
112 auto* interceptor = creator->CreateServerInterceptor(
this);
113 if (interceptor !=
nullptr) {
114 interceptors_.push_back(
115 std::unique_ptr<experimental::Interceptor>(interceptor));
120 void Ref() { ref_.fetch_add(1, std::memory_order_relaxed); }
122 if (
GPR_UNLIKELY(ref_.fetch_sub(1, std::memory_order_acq_rel) == 1)) {
127 ServerContextBase* ctx_ =
nullptr;
128 const char* method_ =
nullptr;
130 std::atomic<intptr_t> ref_{1};
131 std::vector<std::unique_ptr<experimental::Interceptor>> interceptors_;
140 #endif // GRPCPP_SUPPORT_SERVER_INTERCEPTOR_H
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
const char * method() const
Return the fully-specified method name.
Definition: server_interceptor.h:73
#define GPR_ASSERT(x)
abort() the process if x is zero, having written a line to the log.
Definition: log.h:95
Base class of ServerContext.
Definition: server_context.h:124
~ServerRpcInfo()
Definition: server_interceptor.h:62
@ CLIENT_STREAMING
Definition: rpc_method.h:33
@ BIDI_STREAMING
Definition: rpc_method.h:35
ServerContextBase * server_context()
Return a pointer to the underlying ServerContext structure associated with the RPC to support feature...
Definition: server_interceptor.h:80
ServerRpcInfo & operator=(const ServerRpcInfo &)=delete
@ SERVER_STREAMING
Definition: rpc_method.h:34
ServerRpcInfo(const ServerRpcInfo &)=delete
RpcType
Definition: rpc_method.h:31
@ NORMAL_RPC
Definition: rpc_method.h:32
ServerRpcInfo represents the state of a particular RPC as it appears to an interceptor.
Definition: server_interceptor.h:57
Interface for an interceptor.
Definition: interceptor.h:218
Definition: server_interceptor.h:44
virtual Interceptor * CreateServerInterceptor(ServerRpcInfo *info)=0
virtual ~ServerInterceptorFactoryInterface()
Definition: server_interceptor.h:46
Class that is passed as an argument to the Intercept method of the application's Interceptor interfac...
Definition: interceptor.h:95
Type type() const
Return the type of the RPC (unary or a streaming flavor)
Definition: server_interceptor.h:76
Type
Type categorizes RPCs by unary or streaming type.
Definition: server_interceptor.h:60
Definition: interceptor_common.h:36