| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121 | /* * * Copyright 2016 gRPC authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * *     http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * */#ifndef GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H#define GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H#include <grpc/impl/codegen/connectivity_state.h>#include <grpcpp/impl/codegen/status.h>#include <grpcpp/impl/codegen/time.h>namespace grpc {class ChannelInterface;class ClientContext;class CompletionQueue;template <class R>class ClientReader;template <class W>class ClientWriter;template <class W, class R>class ClientReaderWriter;namespace internal {class Call;class CallOpSetInterface;class RpcMethod;template <class InputMessage, class OutputMessage>class BlockingUnaryCallImpl;template <class R>class ClientAsyncReaderFactory;template <class W>class ClientAsyncWriterFactory;template <class W, class R>class ClientAsyncReaderWriterFactory;template <class R>class ClientAsyncResponseReaderFactory;}  // namespace internal/// Codegen interface for \a grpc::Channel.class ChannelInterface { public:  virtual ~ChannelInterface() {}  /// Get the current channel state. If the channel is in IDLE and  /// \a try_to_connect is set to true, try to connect.  virtual grpc_connectivity_state GetState(bool try_to_connect) = 0;  /// Return the \a tag on \a cq when the channel state is changed or \a  /// deadline expires. \a GetState needs to called to get the current state.  template <typename T>  void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline,                           CompletionQueue* cq, void* tag) {    TimePoint<T> deadline_tp(deadline);    NotifyOnStateChangeImpl(last_observed, deadline_tp.raw_time(), cq, tag);  }  /// Blocking wait for channel state change or \a deadline expiration.  /// \a GetState needs to called to get the current state.  template <typename T>  bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline) {    TimePoint<T> deadline_tp(deadline);    return WaitForStateChangeImpl(last_observed, deadline_tp.raw_time());  }  /// Wait for this channel to be connected  template <typename T>  bool WaitForConnected(T deadline) {    grpc_connectivity_state state;    while ((state = GetState(true)) != GRPC_CHANNEL_READY) {      if (!WaitForStateChange(state, deadline)) return false;    }    return true;  } private:  template <class R>  friend class ::grpc::ClientReader;  template <class W>  friend class ::grpc::ClientWriter;  template <class W, class R>  friend class ::grpc::ClientReaderWriter;  template <class R>  friend class ::grpc::internal::ClientAsyncReaderFactory;  template <class W>  friend class ::grpc::internal::ClientAsyncWriterFactory;  template <class W, class R>  friend class ::grpc::internal::ClientAsyncReaderWriterFactory;  template <class R>  friend class ::grpc::internal::ClientAsyncResponseReaderFactory;  template <class InputMessage, class OutputMessage>  friend class ::grpc::internal::BlockingUnaryCallImpl;  friend class ::grpc::internal::RpcMethod;  virtual internal::Call CreateCall(const internal::RpcMethod& method,                                    ClientContext* context,                                    CompletionQueue* cq) = 0;  virtual void PerformOpsOnCall(internal::CallOpSetInterface* ops,                                internal::Call* call) = 0;  virtual void* RegisterMethod(const char* method) = 0;  virtual void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,                                       gpr_timespec deadline,                                       CompletionQueue* cq, void* tag) = 0;  virtual bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,                                      gpr_timespec deadline) = 0;};}  // namespace grpc#endif  // GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H
 |