19 #ifndef GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H
20 #define GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H
32 template <
class W,
class R>
33 class ClientReaderWriter;
35 template <
class InputMessage,
class OutputMessage>
36 class CallbackUnaryCallImpl;
38 class ClientAsyncReaderFactory;
40 class ClientAsyncWriterFactory;
41 template <
class W,
class R>
42 class ClientAsyncReaderWriterFactory;
43 class ClientAsyncResponseReaderHelper;
44 template <
class W,
class R>
45 class ClientCallbackReaderWriterFactory;
47 class ClientCallbackReaderFactory;
49 class ClientCallbackWriterFactory;
50 class ClientCallbackUnaryFactory;
53 class ChannelInterface;
55 class CompletionQueue;
57 namespace experimental {
58 class DelegatingChannel;
63 class CallOpSetInterface;
65 class InterceptedChannel;
66 template <
class InputMessage,
class OutputMessage>
67 class BlockingUnaryCallImpl;
84 NotifyOnStateChangeImpl(last_observed, deadline_tp.
raw_time(), cq, tag);
92 return WaitForStateChangeImpl(last_observed, deadline_tp.
raw_time());
107 friend class ::grpc::ClientReader;
109 friend class ::grpc::ClientWriter;
110 template <
class W,
class R>
111 friend class ::grpc::ClientReaderWriter;
113 friend class ::grpc::internal::ClientAsyncReaderFactory;
115 friend class ::grpc::internal::ClientAsyncWriterFactory;
116 template <
class W,
class R>
117 friend class ::grpc::internal::ClientAsyncReaderWriterFactory;
118 friend class ::grpc::internal::ClientAsyncResponseReaderHelper;
119 template <
class W,
class R>
120 friend class ::grpc::internal::ClientCallbackReaderWriterFactory;
122 friend class ::grpc::internal::ClientCallbackReaderFactory;
124 friend class ::grpc::internal::ClientCallbackWriterFactory;
125 friend class ::grpc::internal::ClientCallbackUnaryFactory;
126 template <
class InputMessage,
class OutputMessage>
127 friend class ::grpc::internal::BlockingUnaryCallImpl;
128 template <
class InputMessage,
class OutputMessage>
129 friend class ::grpc::internal::CallbackUnaryCallImpl;
130 friend class ::grpc::internal::RpcMethod;
131 friend class ::grpc::experimental::DelegatingChannel;
132 friend class ::grpc::internal::InterceptedChannel;
138 virtual void* RegisterMethod(
const char* method) = 0;
167 virtual ::grpc::CompletionQueue* CallbackCQ() {
return nullptr; }
Codegen interface for grpc::Channel.
Definition: channel_interface.h:71
bool WaitForConnected(T deadline)
Wait for this channel to be connected.
Definition: channel_interface.h:97
virtual ~ChannelInterface()
Definition: channel_interface.h:73
virtual grpc_connectivity_state GetState(bool try_to_connect)=0
Get the current channel state.
bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline)
Blocking wait for channel state change or deadline expiration.
Definition: channel_interface.h:90
void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, ::grpc::CompletionQueue *cq, void *tag)
Return the tag on cq when the channel state is changed or deadline expires.
Definition: channel_interface.h:81
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
If you are trying to use CompletionQueue::AsyncNext with a time class that isn't either gpr_timespec ...
Definition: time.h:40
gpr_timespec raw_time()=delete
Straightforward wrapping of the C call object.
Definition: call.h:35
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:34
Descriptor of an RPC method.
Definition: rpc_method.h:29
grpc_connectivity_state
Connectivity state of a channel.
Definition: connectivity_state.h:27
@ GRPC_CHANNEL_READY
channel is ready for work
Definition: connectivity_state.h:33
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