GRPC C++  1.39.1
intercepted_channel.h
Go to the documentation of this file.
1 /*
2  *
3  * Copyright 2018 gRPC authors.
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  */
18 
19 #ifndef GRPCPP_IMPL_CODEGEN_INTERCEPTED_CHANNEL_H
20 #define GRPCPP_IMPL_CODEGEN_INTERCEPTED_CHANNEL_H
21 
23 
24 namespace grpc {
25 class CompletionQueue;
26 
27 namespace internal {
28 
29 class InterceptorBatchMethodsImpl;
30 
36  public:
37  ~InterceptedChannel() override { channel_ = nullptr; }
38 
41  grpc_connectivity_state GetState(bool try_to_connect) override {
42  return channel_->GetState(try_to_connect);
43  }
44 
45  private:
46  InterceptedChannel(ChannelInterface* channel, size_t pos)
47  : channel_(channel), interceptor_pos_(pos) {}
48 
49  Call CreateCall(const RpcMethod& method, ::grpc::ClientContext* context,
50  ::grpc::CompletionQueue* cq) override {
51  return channel_->CreateCallInternal(method, context, cq, interceptor_pos_);
52  }
53 
54  void PerformOpsOnCall(CallOpSetInterface* ops, Call* call) override {
55  return channel_->PerformOpsOnCall(ops, call);
56  }
57  void* RegisterMethod(const char* method) override {
58  return channel_->RegisterMethod(method);
59  }
60 
61  void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
62  gpr_timespec deadline,
64  void* tag) override {
65  return channel_->NotifyOnStateChangeImpl(last_observed, deadline, cq, tag);
66  }
67  bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
68  gpr_timespec deadline) override {
69  return channel_->WaitForStateChangeImpl(last_observed, deadline);
70  }
71 
72  ::grpc::CompletionQueue* CallbackCQ() override {
73  return channel_->CallbackCQ();
74  }
75 
76  ChannelInterface* channel_;
77  size_t interceptor_pos_;
78 
80 };
81 } // namespace internal
82 } // namespace grpc
83 
84 #endif // GRPCPP_IMPL_CODEGEN_INTERCEPTED_CHANNEL_H
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