| /external/grpc-grpc/src/ruby/end2end/ |
| multiple_killed_watching_threads_driver.rb | 25 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}"
|
| sig_int_during_channel_watch_client.rb | 22 # middle of a blocking connectivity_state call.
41 state = child_thread_channel.connectivity_state(false)
50 state = main_channel.connectivity_state(false)
|
| channel_state_client.rb | 34 state = ch.connectivity_state
|
| channel_closing_client.rb | 57 state = ch.connectivity_state(true)
|
| /external/grpc-grpc/src/ruby/spec/ |
| channel_connection_spec.rb | 57 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
|
| channel_spec.rb | 185 describe '#connectivity_state' do
196 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/core/ext/filters/client_channel/lb_policy/round_robin/ |
| round_robin.cc | 43 #include "src/core/lib/transport/connectivity_state.h"
116 grpc_connectivity_state connectivity_state() const { function in class:grpc_core::__anon22977::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) {
567 grpc_connectivity_state_name(connectivity_state));
570 connectivity_state, error);
571 last_connectivity_state_ = connectivity_state;
575 grpc_connectivity_state connectivity_state, grpc_error* error) {
583 if (connectivity_state == GRPC_CHANNEL_TRANSIENT_FAILURE)
[all...] |
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| pick_first.cc | 33 #include "src/core/lib/transport/connectivity_state.h"
84 grpc_connectivity_state connectivity_state, grpc_error* error) override;
442 grpc_connectivity_state connectivity_state, grpc_error* error) {
449 GPR_ASSERT(connectivity_state != GRPC_CHANNEL_SHUTDOWN);
458 if (connectivity_state != GRPC_CHANNEL_READY &&
479 if (connectivity_state == GRPC_CHANNEL_TRANSIENT_FAILURE) {
494 grpc_connectivity_state_set(&p->state_tracker_, connectivity_state,
512 switch (connectivity_state) {
|
| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| max_age_filter.cc | 93 grpc_connectivity_state connectivity_state; member in struct:__anon22997::channel_data
231 op->connectivity_state = &chand->connectivity_state;
352 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) {
355 op->connectivity_state = &chand->connectivity_state;
|
| /external/grpc-grpc/src/core/lib/surface/ |
| lame_client.cc | 100 GPR_ASSERT(*op->connectivity_state != GRPC_CHANNEL_SHUTDOWN);
101 *op->connectivity_state = GRPC_CHANNEL_SHUTDOWN;
|
| server.cc | 96 grpc_connectivity_state connectivity_state; member in struct:__anon23235::channel_data
826 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) {
829 op->connectivity_state = &chand->connectivity_state;
888 chand->connectivity_state = GRPC_CHANNEL_IDLE;
[all...] |
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| channel_interface.h | 22 #include <grpc/impl/codegen/connectivity_state.h>
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| subchannel.cc | 51 #include "src/core/lib/transport/connectivity_state.h"
66 grpc_connectivity_state connectivity_state; member in struct:__anon22989::state_watcher
560 switch (connected_subchannel_watcher->connectivity_state) {
570 connected_subchannel_watcher->connectivity_state));
580 connected_subchannel_watcher->connectivity_state =
587 &c->state_tracker, connected_subchannel_watcher->connectivity_state,
591 nullptr, &connected_subchannel_watcher->connectivity_state,
630 connected_subchannel_watcher->connectivity_state = GRPC_CHANNEL_READY;
653 c->pollset_set, &connected_subchannel_watcher->connectivity_state,
828 op->connectivity_state = state
[all...] |
| client_channel.cc | 57 #include "src/core/lib/transport/connectivity_state.h"
380 // If the new policy is created successfully, sets *connectivity_state and
385 grpc_connectivity_state* connectivity_state,
427 *connectivity_state =
433 watch_lb_policy_locked(chand, chand->lb_policy.get(), *connectivity_state);
496 grpc_connectivity_state connectivity_state = GRPC_CHANNEL_TRANSIENT_FAILURE; local
530 &connectivity_state, &connectivity_error);
547 chand, connectivity_state, connectivity_error, "resolver_result");
565 &chand->state_tracker, op->connectivity_state,
568 op->connectivity_state = nullptr
[all...] |
| /external/grpc-grpc/src/core/lib/transport/ |
| connectivity_state.cc | 21 #include "src/core/lib/transport/connectivity_state.h"
29 grpc_core::TraceFlag grpc_connectivity_state_trace(false, "connectivity_state");
102 grpc_connectivity_state_tracker* connectivity_state) {
103 return connectivity_state->watchers != nullptr;
|
| transport_op_string.cc | 32 #include "src/core/lib/transport/connectivity_state.h"
140 if (op->connectivity_state != nullptr) {
143 grpc_connectivity_state_name(*op->connectivity_state));
|
| transport.h | 254 /** connectivity monitoring - set connectivity_state to NULL to unsubscribe */
256 grpc_connectivity_state* connectivity_state; member in struct:grpc_transport_op
|
| /external/grpc-grpc/test/core/surface/ |
| lame_client_test.cc | 54 op->connectivity_state = &state;
|
| public_headers_must_be_c89.c | 31 #include <grpc/impl/codegen/connectivity_state.h>
|
| /external/grpc-grpc/include/grpc/ |
| grpc.h | 27 #include <grpc/impl/codegen/connectivity_state.h>
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| subchannel_list.h | 40 #include "src/core/lib/transport/connectivity_state.h"
53 grpc_connectivity_state connectivity_state, grpc_error* error) override {
156 grpc_connectivity_state connectivity_state,
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| inproc_transport.cc | 34 #include "src/core/lib/transport/connectivity_state.h"
[all...] |
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| chttp2_transport.cc | [all...] |
