Home
last modified time | relevance | path

Searched refs:last_observed (Results 1 – 7 of 7) sorted by relevance

/third_party/grpc/include/grpcpp/impl/codegen/
Dintercepted_channel.h61 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl() argument
65 return channel_->NotifyOnStateChangeImpl(last_observed, deadline, cq, tag); in NotifyOnStateChangeImpl()
67 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl() argument
69 return channel_->WaitForStateChangeImpl(last_observed, deadline); in WaitForStateChangeImpl()
Ddelegating_channel.h61 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl() argument
65 delegate_channel()->NotifyOnStateChangeImpl(last_observed, deadline, cq, in NotifyOnStateChangeImpl()
69 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl() argument
71 return delegate_channel()->WaitForStateChangeImpl(last_observed, deadline); in WaitForStateChangeImpl()
Dchannel_interface.h81 void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, in NotifyOnStateChange() argument
84 NotifyOnStateChangeImpl(last_observed, deadline_tp.raw_time(), cq, tag); in NotifyOnStateChange()
90 bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline) { in WaitForStateChange() argument
92 return WaitForStateChangeImpl(last_observed, deadline_tp.raw_time()); in WaitForStateChange()
139 virtual void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
143 virtual bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
/third_party/grpc/src/cpp/client/
Dchannel_cc.cc189 void Channel::NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl() argument
193 grpc_channel_watch_connectivity_state(c_channel_, last_observed, deadline, in NotifyOnStateChangeImpl()
197 bool Channel::WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl() argument
202 NotifyOnStateChangeImpl(last_observed, deadline, &cq, nullptr); in WaitForStateChangeImpl()
/third_party/grpc/test/cpp/qps/
Dclient.h467 grpc_connectivity_state last_observed = channel->GetState(true); in WaitForChannelsToConnect() local
468 if (last_observed == GRPC_CHANNEL_READY) { in WaitForChannelsToConnect()
472 channel->NotifyOnStateChange(last_observed, connect_deadline, &cq, in WaitForChannelsToConnect()
487 grpc_connectivity_state last_observed = channel->GetState(true); in WaitForChannelsToConnect() local
488 if (last_observed == GRPC_CHANNEL_READY) { in WaitForChannelsToConnect()
492 channel->NotifyOnStateChange(last_observed, connect_deadline, &cq, in WaitForChannelsToConnect()
/third_party/grpc/include/grpcpp/
Dchannel.h95 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
98 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
Dchannel_impl.h97 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
101 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,