Home
last modified time | relevance | path

Searched refs:connectivity_state (Results 1 – 25 of 56) sorted by relevance

123

/external/grpc-grpc/src/ruby/spec/
Dchannel_connection_spec.rb57 expect(ch.connectivity_state).to be(GRPC::Core::ConnectivityStates::IDLE)
59 state = ch.connectivity_state(true)
64 state = ch.connectivity_state(true)
72 state = ch.connectivity_state
77 state = ch.connectivity_state
85 state = ch.connectivity_state(true)
90 state = ch.connectivity_state(true)
109 while ch.connectivity_state(true) != ConnectivityStates::READY
Dchannel_spec.rb196 expect(valid_states).to include(ch.connectivity_state)
201 ch.connectivity_state(true)
210 expect(valid_states).to include(ch.connectivity_state)
/external/grpc-grpc/src/ruby/end2end/
Dmultiple_killed_watching_threads_driver.rb25 state = ch.connectivity_state(false)
46 connectivity_state = c.connectivity_state(false)
50 unless [FATAL_FAILURE, IDLE].include?(connectivity_state)
51 fail "unexpected connectivity state: #{connectivity_state}"
Dsig_int_during_channel_watch_client.rb41 state = child_thread_channel.connectivity_state(false)
50 state = main_channel.connectivity_state(false)
Dchannel_state_client.rb34 state = ch.connectivity_state
Dchannel_closing_client.rb57 state = ch.connectivity_state(true)
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc88 grpc_connectivity_state connectivity_state() const { in connectivity_state() function in grpc_core::__anon894e5a0e0111::RoundRobin::RoundRobinSubchannelData
97 grpc_connectivity_state connectivity_state);
103 grpc_connectivity_state connectivity_state) override;
190 if (sd->connectivity_state() == GRPC_CHANNEL_READY) { in Picker()
374 grpc_connectivity_state connectivity_state) { in UpdateConnectivityStateLocked() argument
384 ConnectivityStateName(connectivity_state)); in UpdateConnectivityStateLocked()
392 if (connectivity_state == GRPC_CHANNEL_TRANSIENT_FAILURE) { in UpdateConnectivityStateLocked()
396 connectivity_state); in UpdateConnectivityStateLocked()
398 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
401 GRPC_CHANNEL_TRANSIENT_FAILURE, connectivity_state); in UpdateConnectivityStateLocked()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc74 grpc_connectivity_state connectivity_state) override;
286 grpc_connectivity_state connectivity_state) { in ProcessConnectivityChangeLocked() argument
292 GPR_ASSERT(connectivity_state != GRPC_CHANNEL_SHUTDOWN); in ProcessConnectivityChangeLocked()
298 ConnectivityStateName(connectivity_state)); in ProcessConnectivityChangeLocked()
302 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
331 if (connectivity_state == GRPC_CHANNEL_TRANSIENT_FAILURE) { in ProcessConnectivityChangeLocked()
350 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
356 connectivity_state, absl::Status(), in ProcessConnectivityChangeLocked()
374 switch (connectivity_state) { in ProcessConnectivityChangeLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc116 grpc_connectivity_state connectivity_state() const { in connectivity_state() function in grpc_core::__anone1f0a73a0111::RoundRobin::RoundRobinSubchannelData
121 grpc_connectivity_state connectivity_state, grpc_error* error);
125 grpc_connectivity_state connectivity_state, grpc_error* error) override;
557 grpc_connectivity_state connectivity_state, grpc_error* error) { in UpdateConnectivityStateLocked() argument
567 grpc_connectivity_state_name(connectivity_state)); in UpdateConnectivityStateLocked()
570 connectivity_state, error); in UpdateConnectivityStateLocked()
571 last_connectivity_state_ = connectivity_state; in UpdateConnectivityStateLocked()
575 grpc_connectivity_state connectivity_state, grpc_error* error) { in ProcessConnectivityChangeLocked() argument
583 if (connectivity_state == GRPC_CHANNEL_TRANSIENT_FAILURE) { in ProcessConnectivityChangeLocked()
593 UpdateConnectivityStateLocked(connectivity_state, error); in ProcessConnectivityChangeLocked()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc132 grpc_connectivity_state connectivity_state() const { in connectivity_state() function in grpc_core::__anon33b6bffa0111::WeightedTargetLb::WeightedChild
338 ConnectivityStateName(child->connectivity_state()), in UpdateStateLocked()
341 switch (child->connectivity_state()) { in UpdateStateLocked()
364 grpc_connectivity_state connectivity_state; in UpdateStateLocked() local
366 connectivity_state = GRPC_CHANNEL_READY; in UpdateStateLocked()
368 connectivity_state = GRPC_CHANNEL_CONNECTING; in UpdateStateLocked()
370 connectivity_state = GRPC_CHANNEL_IDLE; in UpdateStateLocked()
372 connectivity_state = GRPC_CHANNEL_TRANSIENT_FAILURE; in UpdateStateLocked()
376 this, ConnectivityStateName(connectivity_state)); in UpdateStateLocked()
380 switch (connectivity_state) { in UpdateStateLocked()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc131 grpc_connectivity_state connectivity_state() const { in connectivity_state() function in grpc_core::__anon2bdcc6850111::XdsClusterManagerLb::ClusterChild
304 switch (child->connectivity_state()) { in UpdateStateLocked()
326 grpc_connectivity_state connectivity_state; in UpdateStateLocked() local
328 connectivity_state = GRPC_CHANNEL_READY; in UpdateStateLocked()
330 connectivity_state = GRPC_CHANNEL_CONNECTING; in UpdateStateLocked()
332 connectivity_state = GRPC_CHANNEL_IDLE; in UpdateStateLocked()
334 connectivity_state = GRPC_CHANNEL_TRANSIENT_FAILURE; in UpdateStateLocked()
338 this, ConnectivityStateName(connectivity_state)); in UpdateStateLocked()
342 switch (connectivity_state) { in UpdateStateLocked()
379 channel_control_helper()->UpdateState(connectivity_state, status, in UpdateStateLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc117 grpc_connectivity_state connectivity_state() const { in connectivity_state() function in grpc_core::__anon47a44ab00111::PriorityLb::ChildPriority
345 if (child->connectivity_state() == GRPC_CHANNEL_READY || in HandleChildConnectivityStateChangeLocked()
346 child->connectivity_state() == GRPC_CHANNEL_IDLE) { in HandleChildConnectivityStateChangeLocked()
349 channel_control_helper()->UpdateState(child->connectivity_state(), in HandleChildConnectivityStateChangeLocked()
378 if (child->connectivity_state() == GRPC_CHANNEL_TRANSIENT_FAILURE) { in HandleChildConnectivityStateChangeLocked()
388 if (child->connectivity_state() == GRPC_CHANNEL_READY || in HandleChildConnectivityStateChangeLocked()
389 child->connectivity_state() == GRPC_CHANNEL_IDLE) { in HandleChildConnectivityStateChangeLocked()
396 channel_control_helper()->UpdateState(child->connectivity_state(), in HandleChildConnectivityStateChangeLocked()
441 if (child->connectivity_state() == GRPC_CHANNEL_READY || in TryNextPriorityLocked()
442 child->connectivity_state() == GRPC_CHANNEL_IDLE) { in TryNextPriorityLocked()
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc84 grpc_connectivity_state connectivity_state, grpc_error* error) override;
442 grpc_connectivity_state connectivity_state, grpc_error* error) { in ProcessConnectivityChangeLocked() argument
449 GPR_ASSERT(connectivity_state != GRPC_CHANNEL_SHUTDOWN); in ProcessConnectivityChangeLocked()
458 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
479 if (connectivity_state == GRPC_CHANNEL_TRANSIENT_FAILURE) { in ProcessConnectivityChangeLocked()
494 grpc_connectivity_state_set(&p->state_tracker_, connectivity_state, in ProcessConnectivityChangeLocked()
512 switch (connectivity_state) { in ProcessConnectivityChangeLocked()
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc93 grpc_connectivity_state connectivity_state; member
231 op->connectivity_state = &chand->connectivity_state; in start_max_age_timer_after_init()
352 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) { in channel_connectivity_changed()
355 op->connectivity_state = &chand->connectivity_state; in channel_connectivity_changed()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc66 grpc_connectivity_state connectivity_state; member
560 switch (connected_subchannel_watcher->connectivity_state) { in on_connected_subchannel_connectivity_changed()
570 connected_subchannel_watcher->connectivity_state)); in on_connected_subchannel_connectivity_changed()
580 connected_subchannel_watcher->connectivity_state = in on_connected_subchannel_connectivity_changed()
587 &c->state_tracker, connected_subchannel_watcher->connectivity_state, in on_connected_subchannel_connectivity_changed()
591 nullptr, &connected_subchannel_watcher->connectivity_state, in on_connected_subchannel_connectivity_changed()
630 connected_subchannel_watcher->connectivity_state = GRPC_CHANNEL_READY; in publish_transport_locked()
653 c->pollset_set, &connected_subchannel_watcher->connectivity_state, in publish_transport_locked()
828 op->connectivity_state = state; in NotifyOnStateChange()
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc100 GPR_ASSERT(*op->connectivity_state != GRPC_CHANNEL_SHUTDOWN); in lame_start_transport_op()
101 *op->connectivity_state = GRPC_CHANNEL_SHUTDOWN; in lame_start_transport_op()
Dserver.cc96 grpc_connectivity_state connectivity_state; member
826 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) { in channel_connectivity_changed()
829 op->connectivity_state = &chand->connectivity_state; in channel_connectivity_changed()
888 chand->connectivity_state = GRPC_CHANNEL_IDLE; in init_channel_elem()
1181 op->connectivity_state = &chand->connectivity_state; in grpc_server_setup_transport()
/external/grpc-grpc/src/core/lib/transport/
Dconnectivity_state.cc102 grpc_connectivity_state_tracker* connectivity_state) { in grpc_connectivity_state_has_watchers() argument
103 return connectivity_state->watchers != nullptr; in grpc_connectivity_state_has_watchers()
Dtransport_op_string.cc140 if (op->connectivity_state != nullptr) { in grpc_transport_op_string()
143 grpc_connectivity_state_name(*op->connectivity_state)); in grpc_transport_op_string()
Dtransport.h256 grpc_connectivity_state* connectivity_state; member
/external/grpc-grpc/test/core/end2end/fuzzers/
Dapi_fuzzer.dictionary5 "connectivity_state\x00"
/external/rust/crates/grpcio-sys/grpc/include/grpc/
Dmodule.modulemap9 header "impl/codegen/connectivity_state.h"
/external/grpc-grpc/test/core/surface/
Dlame_client_test.cc54 op->connectivity_state = &state; in test_transport_op()
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/
Dmodule.modulemap9 header "impl/codegen/connectivity_state.h"
/external/grpc-grpc/include/grpc/
Dmodule.modulemap27 header "impl/codegen/connectivity_state.h"

123