| /external/grpc-grpc/test/core/end2end/tests/ |
| D | connectivity.cc | 122 while (state != GRPC_CHANNEL_READY) { in test_connectivity()
128 GPR_ASSERT(state == GRPC_CHANNEL_READY || in test_connectivity()
137 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_READY, in test_connectivity()
|
| D | ping.cc | 72 while (state != GRPC_CHANNEL_READY) { in test_ping()
82 GPR_ASSERT(state == GRPC_CHANNEL_READY || in test_ping()
|
| D | max_connection_idle.cc | 195 while (state != GRPC_CHANNEL_READY) { in test_max_connection_idle()
201 GPR_ASSERT(state == GRPC_CHANNEL_READY || in test_max_connection_idle()
211 f.client, GRPC_CHANNEL_READY, in test_max_connection_idle()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 405 if (sd->CheckConnectivityStateLocked(&error) == GRPC_CHANNEL_READY) { in UpdateLocked()
458 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
513 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
579 grpc_connectivity_state_set(&p->state_tracker_, GRPC_CHANNEL_READY, in ProcessUnselectedReadyLocked()
603 CheckConnectivityStateLocked(&error) == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | connectivity_state.h | 33 GRPC_CHANNEL_READY, enumerator
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | connectivity_state.cc | 37 case GRPC_CHANNEL_READY: in grpc_connectivity_state_name()
171 case GRPC_CHANNEL_READY: in grpc_connectivity_state_set()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 465 if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
475 if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
509 grpc_connectivity_state_set(&p->state_tracker_, GRPC_CHANNEL_READY, in MaybeUpdateRoundRobinConnectivityStateLocked()
624 if (subchannel(index)->connectivity_state() == GRPC_CHANNEL_READY) { in GetNextReadySubchannelIndexLocked()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | client_lb_end2end_test.cc | 315 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
508 } while (channel_state == GRPC_CHANNEL_READY); in TEST_F()
509 GPR_ASSERT(channel_state != GRPC_CHANNEL_READY); in TEST_F()
832 } while (channel_state == GRPC_CHANNEL_READY); in TEST_F()
833 GPR_ASSERT(channel_state != GRPC_CHANNEL_READY); in TEST_F()
842 GPR_ASSERT(channel_state == GRPC_CHANNEL_READY); in TEST_F()
|
| D | end2end_test.cc | 1138 EXPECT_TRUE(state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_READY); in TEST_P()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | goaway_server_test.cc | 242 GPR_ASSERT(GRPC_CHANNEL_READY == in main()
244 grpc_channel_watch_connectivity_state(chan, GRPC_CHANNEL_READY, in main()
|
| /external/grpc-grpc/test/core/transport/ |
| D | connectivity_state_test.cc | 52 strcmp(grpc_connectivity_state_name(GRPC_CHANNEL_READY), "READY")); in test_connectivity_state_name()
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | php_grpc.c | 208 GRPC_CHANNEL_READY, in PHP_MINIT_FUNCTION()
|
| D | channel.c | 601 case GRPC_CHANNEL_READY: in grpc_connectivity_state_name()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | channel_interface.h | 85 while ((state = GetState(true)) != GRPC_CHANNEL_READY) { in WaitForConnected()
|
| /external/grpc-grpc/test/core/surface/ |
| D | sequential_connectivity_test.cc | 81 GRPC_CHANNEL_READY) { in run_test()
|
| /external/grpc-grpc/test/core/handshake/ |
| D | verify_peer_options.cc | 174 while (state != GRPC_CHANNEL_READY && retries-- > 0) { in verify_peer_options_test()
|
| D | client_ssl.cc | 285 while (state != GRPC_CHANNEL_READY && retries-- > 0) { in client_ssl_test()
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | records.pyx.pxi | 40 ready = GRPC_CHANNEL_READY
|
| D | grpc.pxi | 231 GRPC_CHANNEL_READY
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.cc | 630 connected_subchannel_watcher->connectivity_state = GRPC_CHANNEL_READY; in publish_transport_locked()
657 grpc_connectivity_state_set(&c->state_tracker, GRPC_CHANNEL_READY, in publish_transport_locked()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 401 if (pending_connectivity_state_unsafe_ == GRPC_CHANNEL_READY) { in UpdateConnectedSubchannelLocked()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 1223 grpc_connectivity_state_init(&st->connectivity, GRPC_CHANNEL_READY, in inproc_transports_create()
1225 grpc_connectivity_state_init(&ct->connectivity, GRPC_CHANNEL_READY, in inproc_transports_create()
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_channel.c | 780 LONG2NUM(GRPC_CHANNEL_READY)); in Init_grpc_connectivity_states()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 1481 case GRPC_CHANNEL_READY: in OnBalancerChannelConnectivityChangedLocked()
1804 case GRPC_CHANNEL_READY: in UpdateConnectivityStateFromRoundRobinPolicyLocked()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 484 &t->channel_callback.state_tracker, GRPC_CHANNEL_READY, in init_transport()
|