Home
last modified time | relevance | path

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

12

/external/grpc-grpc/src/core/lib/transport/
Dconnectivity_state.cc31 const char* grpc_connectivity_state_name(grpc_connectivity_state state) { in grpc_connectivity_state_name()
48 grpc_connectivity_state init_state, in grpc_connectivity_state_init()
76 grpc_connectivity_state grpc_connectivity_state_check( in grpc_connectivity_state_check()
78 grpc_connectivity_state cur = static_cast<grpc_connectivity_state>( in grpc_connectivity_state_check()
87 grpc_connectivity_state grpc_connectivity_state_get( in grpc_connectivity_state_get()
89 grpc_connectivity_state cur = static_cast<grpc_connectivity_state>( in grpc_connectivity_state_get()
107 grpc_connectivity_state_tracker* tracker, grpc_connectivity_state* current, in grpc_connectivity_state_notify_on_state_change()
109 grpc_connectivity_state cur = static_cast<grpc_connectivity_state>( in grpc_connectivity_state_notify_on_state_change()
157 grpc_connectivity_state state, in grpc_connectivity_state_set()
159 grpc_connectivity_state cur = static_cast<grpc_connectivity_state>( in grpc_connectivity_state_set()
Dconnectivity_state.h34 grpc_connectivity_state* current;
51 const char* grpc_connectivity_state_name(grpc_connectivity_state state);
54 grpc_connectivity_state init_state,
61 grpc_connectivity_state state,
71 grpc_connectivity_state grpc_connectivity_state_check(
76 grpc_connectivity_state grpc_connectivity_state_get(
84 grpc_connectivity_state_tracker* tracker, grpc_connectivity_state* current,
Dtransport.h256 grpc_connectivity_state* connectivity_state;
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc66 void NotifyOnStateChangeLocked(grpc_connectivity_state* state,
68 grpc_connectivity_state CheckConnectivityLocked(
116 grpc_connectivity_state connectivity_state() const { in connectivity_state()
121 grpc_connectivity_state connectivity_state, grpc_error* error);
125 grpc_connectivity_state connectivity_state, grpc_error* error) override;
129 grpc_connectivity_state last_connectivity_state_ = GRPC_CHANNEL_IDLE;
164 void UpdateStateCountersLocked(grpc_connectivity_state old_state,
165 grpc_connectivity_state new_state,
444 grpc_connectivity_state state = in StartWatchingLocked()
461 grpc_connectivity_state old_state, grpc_connectivity_state new_state, in UpdateStateCountersLocked()
[all …]
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dchannel_interface.h62 virtual grpc_connectivity_state GetState(bool try_to_connect) = 0;
67 void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, in NotifyOnStateChange()
76 bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline) { in WaitForStateChange()
84 grpc_connectivity_state state; in WaitForConnected()
117 virtual void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
120 virtual bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
/external/grpc-grpc/include/grpcpp/
Dchannel.h51 grpc_connectivity_state GetState(bool try_to_connect) override;
75 void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed,
78 bool WaitForStateChangeImpl(grpc_connectivity_state last_observed,
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc33 grpc_connectivity_state grpc_channel_check_connectivity_state( in grpc_channel_check_connectivity_state()
39 grpc_connectivity_state state; in grpc_channel_check_connectivity_state()
71 grpc_connectivity_state state;
201 grpc_channel* channel, grpc_connectivity_state last_observed_state, in grpc_channel_watch_connectivity_state()
Dclient_channel.h47 grpc_connectivity_state grpc_client_channel_check_connectivity_state(
55 grpc_connectivity_state* state, grpc_closure* on_complete,
Dsubchannel.h94 grpc_connectivity_state* state,
136 grpc_connectivity_state grpc_subchannel_check_connectivity(
143 grpc_connectivity_state* state, grpc_closure* notify);
Dlb_policy.h130 virtual void NotifyOnStateChangeLocked(grpc_connectivity_state* state,
135 virtual grpc_connectivity_state CheckConnectivityLocked(
Dclient_channel_channelz.cc56 grpc_connectivity_state state; in PopulateConnectivityState()
126 grpc_connectivity_state state; in PopulateConnectivityState()
Dsubchannel.cc66 grpc_connectivity_state connectivity_state;
428 grpc_connectivity_state grpc_subchannel_check_connectivity(grpc_subchannel* c, in grpc_subchannel_check_connectivity()
430 grpc_connectivity_state state; in grpc_subchannel_check_connectivity()
517 grpc_connectivity_state* state, grpc_closure* notify) { in grpc_subchannel_notify_on_state_change()
824 grpc_pollset_set* interested_parties, grpc_connectivity_state* state, in NotifyOnStateChange()
Dclient_channel.cc148 grpc_connectivity_state state;
154 grpc_connectivity_state current_state);
157 grpc_connectivity_state state, in set_channel_connectivity_state_locked()
204 grpc_connectivity_state current_state) { in watch_lb_policy_locked()
385 grpc_connectivity_state* connectivity_state, in create_new_lb_policy_locked()
496 grpc_connectivity_state connectivity_state = GRPC_CHANNEL_TRANSIENT_FAILURE; in on_resolver_result_changed_locked()
3301 grpc_connectivity_state grpc_client_channel_check_connectivity_state( in grpc_client_channel_check_connectivity_state()
3304 grpc_connectivity_state out = in grpc_client_channel_check_connectivity_state()
3321 grpc_connectivity_state* state;
3434 grpc_connectivity_state* state, grpc_closure* closure, in grpc_client_channel_watch_connectivity_state()
/external/grpc-grpc/test/core/transport/
Dconnectivity_state_test.cc77 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_subscribe_then_unsubscribe()
99 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_subscribe_then_destroy()
120 grpc_connectivity_state state = GRPC_CHANNEL_SHUTDOWN; in test_subscribe_with_failure_then_destroy()
/external/grpc-grpc/test/core/surface/
Dlame_client_test.cc36 grpc_connectivity_state* state = static_cast<grpc_connectivity_state*>(arg); in verify_connectivity()
46 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_transport_op()
Dconcurrent_connectivity_test.cc70 grpc_connectivity_state state = in create_loop_destroy()
260 grpc_connectivity_state state = in watches_with_short_timeouts()
Dsequential_connectivity_test.cc79 grpc_connectivity_state state; in run_test()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc55 void NotifyOnStateChangeLocked(grpc_connectivity_state* state,
57 grpc_connectivity_state CheckConnectivityLocked(
84 grpc_connectivity_state connectivity_state, grpc_error* error) override;
292 grpc_connectivity_state PickFirst::CheckConnectivityLocked(grpc_error** error) { in CheckConnectivityLocked()
296 void PickFirst::NotifyOnStateChangeLocked(grpc_connectivity_state* current, in NotifyOnStateChangeLocked()
442 grpc_connectivity_state connectivity_state, grpc_error* error) { in ProcessConnectivityChangeLocked()
/external/grpc-grpc/src/cpp/client/
Dchannel_cc.cc154 grpc_connectivity_state Channel::GetState(bool try_to_connect) { in GetState()
176 void Channel::NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, in NotifyOnStateChangeImpl()
184 bool Channel::WaitForStateChangeImpl(grpc_connectivity_state last_observed, in WaitForStateChangeImpl()
/external/grpc-grpc/include/grpc/impl/codegen/
Dconnectivity_state.h38 } grpc_connectivity_state; typedef
/external/grpc-grpc/include/grpc/
Dgrpc.h184 GRPCAPI grpc_connectivity_state grpc_channel_check_connectivity_state(
199 grpc_channel* channel, grpc_connectivity_state last_observed_state,
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h103 grpc_connectivity_state CheckConnectivityStateLocked(grpc_error** error) { in CheckConnectivityStateLocked()
156 grpc_connectivity_state connectivity_state,
184 grpc_connectivity_state pending_connectivity_state_unsafe_;
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc132 void NotifyOnStateChangeLocked(grpc_connectivity_state* state,
134 grpc_connectivity_state CheckConnectivityLocked(
298 grpc_connectivity_state lb_channel_connectivity_;
342 grpc_connectivity_state rr_connectivity_state_;
1273 grpc_connectivity_state GrpcLb::CheckConnectivityLocked( in CheckConnectivityLocked()
1278 void GrpcLb::NotifyOnStateChangeLocked(grpc_connectivity_state* current, in NotifyOnStateChangeLocked()
1766 const grpc_connectivity_state curr_glb_state = in UpdateConnectivityStateFromRoundRobinPolicyLocked()
/external/grpc-grpc/test/core/end2end/tests/
Dping.cc36 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_ping()
Dconnectivity.cc50 grpc_connectivity_state state; in test_connectivity()

12