19 #ifndef GRPCPP_IMPL_CODEGEN_INTERCEPTED_CHANNEL_H
20 #define GRPCPP_IMPL_CODEGEN_INTERCEPTED_CHANNEL_H
25 class CompletionQueue;
29 class InterceptorBatchMethodsImpl;
42 return channel_->
GetState(try_to_connect);
47 : channel_(channel), interceptor_pos_(pos) {}
51 return channel_->CreateCallInternal(method, context, cq, interceptor_pos_);
54 void PerformOpsOnCall(CallOpSetInterface* ops, Call* call)
override {
55 return channel_->PerformOpsOnCall(ops, call);
57 void* RegisterMethod(
const char* method)
override {
58 return channel_->RegisterMethod(method);
65 return channel_->NotifyOnStateChangeImpl(last_observed, deadline, cq, tag);
69 return channel_->WaitForStateChangeImpl(last_observed, deadline);
73 return channel_->CallbackCQ();
76 ChannelInterface* channel_;
77 size_t interceptor_pos_;
Codegen interface for grpc::Channel.
Definition: channel_interface.h:71
virtual grpc_connectivity_state GetState(bool try_to_connect)=0
Get the current channel state.
A ClientContext allows the person implementing a service client to:
Definition: client_context.h:193
A thin wrapper around grpc_completion_queue (see src/core/lib/surface/completion_queue....
Definition: completion_queue.h:102
An InterceptedChannel is available to client Interceptors.
Definition: intercepted_channel.h:35
grpc_connectivity_state GetState(bool try_to_connect) override
Get the current channel state.
Definition: intercepted_channel.h:41
~InterceptedChannel() override
Definition: intercepted_channel.h:37
Definition: interceptor_common.h:37
grpc_connectivity_state
Connectivity state of a channel.
Definition: connectivity_state.h:27
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
Analogous to struct timespec.
Definition: gpr_types.h:47