Home
last modified time | relevance | path

Searched refs:grpc_connectivity_state (Results 1 – 25 of 70) sorted by relevance

123

/third_party/grpc/src/core/lib/transport/
Dconnectivity_state.h43 const char* ConnectivityStateName(grpc_connectivity_state state);
56 virtual void Notify(grpc_connectivity_state new_state,
72 void Notify(grpc_connectivity_state new_state,
85 virtual void OnConnectivityStateChange(grpc_connectivity_state new_state,
101 const char* name, grpc_connectivity_state state = GRPC_CHANNEL_IDLE,
112 void AddWatcher(grpc_connectivity_state initial_state,
121 void SetState(grpc_connectivity_state state, const absl::Status& status,
126 grpc_connectivity_state state() const;
134 Atomic<grpc_connectivity_state> state_;
Dconnectivity_state.cc36 const char* ConnectivityStateName(grpc_connectivity_state state) { in ConnectivityStateName()
61 grpc_connectivity_state state, const absl::Status& status, in Notifier()
88 const grpc_connectivity_state state_;
94 grpc_connectivity_state state, const absl::Status& status) { in Notify()
104 grpc_connectivity_state current_state = state_.Load(MemoryOrder::RELAXED); in ~ConnectivityStateTracker()
118 grpc_connectivity_state initial_state, in AddWatcher()
124 grpc_connectivity_state current_state = state_.Load(MemoryOrder::RELAXED); in AddWatcher()
150 void ConnectivityStateTracker::SetState(grpc_connectivity_state state, in SetState()
153 grpc_connectivity_state current_state = state_.Load(MemoryOrder::RELAXED); in SetState()
176 grpc_connectivity_state ConnectivityStateTracker::state() const { in state()
[all …]
/third_party/grpc/test/core/transport/
Dconnectivity_state_test.cc45 Watcher(int* count, grpc_connectivity_state* output, in Watcher()
53 void Notify(grpc_connectivity_state new_state) override { in Notify()
60 grpc_connectivity_state* output_;
73 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in TEST()
83 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in TEST()
96 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in TEST()
116 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in TEST()
136 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in TEST()
150 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in TEST()
167 grpc_connectivity_state state = GRPC_CHANNEL_SHUTDOWN; in TEST()
/third_party/grpc/src/core/ext/filters/client_channel/
Dsubchannel_interface.h43 grpc_connectivity_state new_state) = 0;
56 virtual grpc_connectivity_state CheckConnectivityState() = 0;
70 grpc_connectivity_state initial_state,
105 grpc_connectivity_state CheckConnectivityState() override { in CheckConnectivityState()
109 grpc_connectivity_state initial_state, in WatchConnectivityState()
Dsubchannel.h177 grpc_connectivity_state state;
252 grpc_connectivity_state CheckConnectivityState(
265 grpc_connectivity_state initial_state,
309 void NotifyLocked(Subchannel* subchannel, grpc_connectivity_state state,
336 Subchannel* subchannel, grpc_connectivity_state initial_state,
343 void NotifyLocked(grpc_connectivity_state state,
346 grpc_connectivity_state CheckConnectivityStateLocked(
362 void SetConnectivityStateLocked(grpc_connectivity_state state,
405 grpc_connectivity_state state_ = GRPC_CHANNEL_IDLE;
Dclient_channel.h41 grpc_connectivity_state grpc_client_channel_check_connectivity_state(
58 grpc_connectivity_state* state, grpc_closure* on_complete,
69 grpc_channel_element* elem, grpc_connectivity_state initial_state,
Dsubchannel.cc317 void OnConnectivityStateChange(grpc_connectivity_state new_state, in OnConnectivityStateChange()
369 Subchannel* subchannel, grpc_connectivity_state state, in AsyncWatcherNotifierLocked()
411 Subchannel* subchannel, grpc_connectivity_state state, in NotifyLocked()
428 grpc_connectivity_state subchannel_state) in HealthWatcher()
446 grpc_connectivity_state state() const { return state_; } in state()
449 grpc_connectivity_state initial_state, in AddWatcherLocked()
464 void NotifyLocked(grpc_connectivity_state state, const absl::Status& status) { in NotifyLocked()
493 void OnConnectivityStateChange(grpc_connectivity_state new_state, in OnConnectivityStateChange()
513 grpc_connectivity_state state_;
523 Subchannel* subchannel, grpc_connectivity_state initial_state, in AddWatcherLocked()
[all …]
Dchannel_connectivity.cc33 grpc_connectivity_state grpc_channel_check_connectivity_state( in grpc_channel_check_connectivity_state()
40 grpc_connectivity_state state; in grpc_channel_check_connectivity_state()
72 grpc_connectivity_state state;
216 grpc_channel* channel, grpc_connectivity_state last_observed_state, in grpc_channel_watch_connectivity_state()
Dclient_channel_channelz.h40 void UpdateConnectivityState(grpc_connectivity_state state);
64 Atomic<grpc_connectivity_state> connectivity_state_{GRPC_CHANNEL_IDLE};
Dclient_channel_channelz.cc41 void SubchannelNode::UpdateConnectivityState(grpc_connectivity_state state) { in UpdateConnectivityState()
52 grpc_connectivity_state state = in RenderJson()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc88 grpc_connectivity_state connectivity_state() const { in connectivity_state()
97 grpc_connectivity_state connectivity_state);
103 grpc_connectivity_state connectivity_state) override;
105 grpc_connectivity_state last_connectivity_state_ = GRPC_CHANNEL_IDLE;
135 void UpdateStateCountersLocked(grpc_connectivity_state old_state,
136 grpc_connectivity_state new_state);
262 grpc_connectivity_state state = in StartWatchingLocked()
280 grpc_connectivity_state old_state, grpc_connectivity_state new_state) { in UpdateStateCountersLocked()
374 grpc_connectivity_state connectivity_state) { in UpdateConnectivityStateLocked()
409 grpc_connectivity_state connectivity_state) { in ProcessConnectivityChangeLocked()
/third_party/grpc/include/grpcpp/impl/codegen/
Dchannel_interface.h76 virtual grpc_connectivity_state GetState(bool try_to_connect) = 0;
81 void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, in NotifyOnStateChange()
90 bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline) { in WaitForStateChange()
98 grpc_connectivity_state state; in WaitForConnected()
139 virtual void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
143 virtual bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
Dintercepted_channel.h41 grpc_connectivity_state GetState(bool try_to_connect) override { in GetState()
61 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl()
67 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl()
Ddelegating_channel.h37 grpc_connectivity_state GetState(bool try_to_connect) override { in GetState()
61 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl()
69 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl()
/third_party/grpc/include/grpcpp/
Dchannel.h63 grpc_connectivity_state GetState(bool try_to_connect) override;
95 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
98 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
Dchannel_impl.h65 grpc_connectivity_state GetState(bool try_to_connect) override;
97 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
101 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h98 grpc_connectivity_state CheckConnectivityStateLocked() { in CheckConnectivityStateLocked()
132 grpc_connectivity_state connectivity_state) = 0;
149 void OnConnectivityStateChange(grpc_connectivity_state new_state) override;
171 grpc_connectivity_state connectivity_state_;
241 OnConnectivityStateChange(grpc_connectivity_state new_state) { in OnConnectivityStateChange()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc132 grpc_connectivity_state connectivity_state() const { in connectivity_state()
149 void UpdateState(grpc_connectivity_state state,
165 grpc_connectivity_state state, const absl::Status& status,
181 grpc_connectivity_state connectivity_state_ = GRPC_CHANNEL_CONNECTING;
364 grpc_connectivity_state connectivity_state; in UpdateStateLocked()
517 grpc_connectivity_state state, const absl::Status& status, in OnConnectivityStateUpdateLocked()
600 grpc_connectivity_state state, const absl::Status& status, in UpdateState()
/third_party/grpc/src/cpp/client/
Dchannel_cc.cc167 grpc_connectivity_state Channel::GetState(bool try_to_connect) { in GetState()
189 void Channel::NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl()
197 bool Channel::WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h149 void SetHealthStatus(grpc_connectivity_state state, const char* reason);
150 void SetHealthStatusLocked(grpc_connectivity_state state,
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc74 grpc_connectivity_state connectivity_state) override;
215 grpc_connectivity_state state = sd->CheckConnectivityStateLocked(); in AttemptToConnectUsingLatestUpdateArgsLocked()
286 grpc_connectivity_state connectivity_state) { in ProcessConnectivityChangeLocked()
467 grpc_connectivity_state current_state = CheckConnectivityStateLocked(); in CheckConnectivityStateAndStartWatchingLocked()
/third_party/grpc/include/grpc/impl/codegen/
Dconnectivity_state.h38 } grpc_connectivity_state; typedef
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc131 grpc_connectivity_state connectivity_state() const { in connectivity_state()
150 void UpdateState(grpc_connectivity_state state,
177 grpc_connectivity_state connectivity_state_ = GRPC_CHANNEL_IDLE;
326 grpc_connectivity_state connectivity_state; in UpdateStateLocked()
550 grpc_connectivity_state state, const absl::Status& status, in UpdateState()
/third_party/grpc/src/core/lib/channel/
Dchannelz.cc150 grpc_connectivity_state state) { in GetChannelConnectivityStateChangeString()
174 grpc_connectivity_state state = in RenderJson()
175 static_cast<grpc_connectivity_state>(state_field >> 1); in RenderJson()
223 void ChannelNode::SetConnectivityState(grpc_connectivity_state state) { in SetConnectivityState()
/third_party/grpc/test/core/tsi/alts/handshaker/
Dalts_concurrent_connectivity_test.cc206 grpc_connectivity_state expected_connectivity_states, in ConnectLoopRunner()
231 grpc_connectivity_state state = in ConnectLoop()
249 grpc_connectivity_state prev_state = state; in ConnectLoop()
279 grpc_connectivity_state expected_connectivity_states_;

123