GRPC C++  1.66.0
channel.h
Go to the documentation of this file.
1 //
2 //
3 // Copyright 2015 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_CHANNEL_H
20 #define GRPCPP_CHANNEL_H
21 
22 #include <memory>
23 
24 #include <grpc/grpc.h>
26 #include <grpcpp/impl/call.h>
29 #include <grpcpp/impl/sync.h>
31 #include <grpcpp/support/config.h>
32 
33 struct grpc_channel;
34 
35 namespace grpc {
36 namespace testing {
37 class ChannelTestPeer;
38 } // namespace testing
39 
40 std::shared_ptr<Channel> CreateChannelInternal(
41  const std::string& host, grpc_channel* c_channel,
42  std::vector<
43  std::unique_ptr<experimental::ClientInterceptorFactoryInterface>>
44  interceptor_creators);
45 
46 namespace experimental {
51 } // namespace experimental
52 
54 class Channel final : public grpc::ChannelInterface,
56  public std::enable_shared_from_this<Channel>,
58  public:
59  ~Channel() override;
60 
63  grpc_connectivity_state GetState(bool try_to_connect) override;
64 
66  std::string GetLoadBalancingPolicyName() const;
67 
70  std::string GetServiceConfigJSON() const;
71 
72  private:
73  template <class InputMessage, class OutputMessage>
77  friend std::shared_ptr<Channel> grpc::CreateChannelInternal(
78  const std::string& host, grpc_channel* c_channel,
79  std::vector<std::unique_ptr<
81  interceptor_creators);
83  Channel(const std::string& host, grpc_channel* c_channel,
84  std::vector<std::unique_ptr<
86  interceptor_creators);
87 
88  grpc::internal::Call CreateCall(const grpc::internal::RpcMethod& method,
89  grpc::ClientContext* context,
90  grpc::CompletionQueue* cq) override;
91  void PerformOpsOnCall(grpc::internal::CallOpSetInterface* ops,
92  grpc::internal::Call* call) override;
93  void* RegisterMethod(const char* method) override;
94 
95  void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
96  gpr_timespec deadline, grpc::CompletionQueue* cq,
97  void* tag) override;
98  bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
99  gpr_timespec deadline) override;
100 
101  grpc::CompletionQueue* CallbackCQ() override;
102 
103  grpc::internal::Call CreateCallInternal(
104  const grpc::internal::RpcMethod& method, grpc::ClientContext* context,
105  grpc::CompletionQueue* cq, size_t interceptor_pos) override;
106 
107  const std::string host_;
108  grpc_channel* const c_channel_; // owned
109 
110  // mu_ protects callback_cq_ (the per-channel callbackable completion queue)
112 
113  // callback_cq_ references the callbackable completion queue associated
114  // with this channel (if any). It is set on the first call to CallbackCQ().
115  // It is _not owned_ by the channel; ownership belongs with its internal
116  // shutdown callback tag (invoked when the CQ is fully shutdown).
117  std::atomic<CompletionQueue*> callback_cq_{nullptr};
118 
119  std::vector<
120  std::unique_ptr<grpc::experimental::ClientInterceptorFactoryInterface>>
121  interceptor_creators_;
122 };
123 
124 } // namespace grpc
125 
126 #endif // GRPCPP_CHANNEL_H
grpc::CreateChannelInternal
std::shared_ptr< Channel > CreateChannelInternal(const std::string &host, grpc_channel *c_channel, std::vector< std::unique_ptr< experimental::ClientInterceptorFactoryInterface >> interceptor_creators)
grpc::experimental::ChannelResetConnectionBackoff
void ChannelResetConnectionBackoff(Channel *channel)
Resets the channel's connection backoff.
grpc
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
grpc::internal::CallHook
This is an interface that Channel and Server implement to allow them to hook performing ops.
Definition: call_hook.h:30
grpc::internal::BlockingUnaryCallImpl
Definition: client_context.h:103
grpc::internal::Call
Straightforward wrapping of the C call object.
Definition: call.h:36
grpc::Channel::GetServiceConfigJSON
std::string GetServiceConfigJSON() const
Returns the service config in JSON form, or the empty string if not available.
client_interceptor.h
completion_queue.h
grpc::ClientContext
A ClientContext allows the person implementing a service client to:
Definition: client_context.h:195
grpc_connectivity_state
grpc_connectivity_state
Connectivity state of a channel.
Definition: connectivity_state.h:30
grpc.h
grpc::internal::CallOpSetInterface
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:36
channel_interface.h
grpc::ChannelInterface
Codegen interface for grpc::Channel.
Definition: channel_interface.h:71
grpc::internal::InterceptedChannel
An InterceptedChannel is available to client Interceptors.
Definition: intercepted_channel.h:35
grpc::internal::GrpcLibrary
Classes that require gRPC to be initialized should inherit from this class.
Definition: grpc_library.h:32
grpc::Channel::ChannelTestPeer
friend class grpc::testing::ChannelTestPeer
Definition: channel.h:75
grpc_library.h
config.h
grpc::experimental::ClientInterceptorFactoryInterface
Definition: client_interceptor.h:49
call.h
grpc::Channel::~Channel
~Channel() override
grpc::CompletionQueue
A thin wrapper around grpc_completion_queue (see src/core/lib/surface/completion_queue....
Definition: completion_queue.h:105
grpc::Channel
Channels represent a connection to an endpoint. Created by CreateChannel.
Definition: channel.h:54
grpc_channel
struct grpc_channel grpc_channel
The Channel interface allows creation of Call objects.
Definition: grpc_types.h:61
grpc::Channel::GetLoadBalancingPolicyName
std::string GetLoadBalancingPolicyName() const
Returns the LB policy name, or the empty string if not yet available.
grpc::internal::Mutex
Definition: sync.h:58
grpc::internal::RpcMethod
Descriptor of an RPC method.
Definition: rpc_method.h:29
gpr_timespec
Analogous to struct timespec.
Definition: time.h:48
sync.h
grpc::Channel::GetState
grpc_connectivity_state GetState(bool try_to_connect) override
Get the current channel state.