/external/grpc-grpc/test/core/transport/ |
D | connectivity_state_test.cc | 56 GPR_ASSERT(0 == strcmp(grpc_connectivity_state_name(GRPC_CHANNEL_SHUTDOWN), in test_connectivity_state_name() 112 GPR_ASSERT(state == GRPC_CHANNEL_SHUTDOWN); in test_subscribe_then_destroy() 120 grpc_connectivity_state state = GRPC_CHANNEL_SHUTDOWN; in test_subscribe_with_failure_then_destroy() 124 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_SHUTDOWN, "xxx"); in test_subscribe_with_failure_then_destroy() 128 GPR_ASSERT(state == GRPC_CHANNEL_SHUTDOWN); in test_subscribe_with_failure_then_destroy() 132 GPR_ASSERT(state == GRPC_CHANNEL_SHUTDOWN); in test_subscribe_with_failure_then_destroy()
|
/external/grpc-grpc/src/core/lib/transport/ |
D | connectivity_state.cc | 41 case GRPC_CHANNEL_SHUTDOWN: in grpc_connectivity_state_name() 62 if (GRPC_CHANNEL_SHUTDOWN != *w->current) { in grpc_connectivity_state_destroy() 63 *w->current = GRPC_CHANNEL_SHUTDOWN; in grpc_connectivity_state_destroy() 174 case GRPC_CHANNEL_SHUTDOWN: in grpc_connectivity_state_set() 184 GPR_ASSERT(cur != GRPC_CHANNEL_SHUTDOWN); in grpc_connectivity_state_set()
|
/external/grpc-grpc/test/core/surface/ |
D | lame_client_test.cc | 37 GPR_ASSERT(GRPC_CHANNEL_SHUTDOWN == *state); in verify_connectivity() 90 GPR_ASSERT(GRPC_CHANNEL_SHUTDOWN == in main()
|
/external/grpc-grpc/src/core/ext/filters/client_channel/ |
D | client_channel_channelz.cc | 58 state = GRPC_CHANNEL_SHUTDOWN; in PopulateConnectivityState() 128 state = GRPC_CHANNEL_SHUTDOWN; in PopulateConnectivityState()
|
D | channel_connectivity.cc | 54 return GRPC_CHANNEL_SHUTDOWN; in grpc_channel_check_connectivity_state()
|
D | subchannel.cc | 562 case GRPC_CHANNEL_SHUTDOWN: { in on_connected_subchannel_connectivity_changed() 581 GRPC_CHANNEL_SHUTDOWN; in on_connected_subchannel_connectivity_changed()
|
D | client_channel.cc | 170 } else if (state == GRPC_CHANNEL_SHUTDOWN) { in set_channel_connectivity_state_locked() 194 if (w->state != GRPC_CHANNEL_SHUTDOWN) { in on_lb_policy_state_changed_locked() 313 chand, GRPC_CHANNEL_SHUTDOWN, in on_resolver_shutdown_locked() 608 chand, GRPC_CHANNEL_SHUTDOWN, in start_transport_op_locked()
|
/external/grpc-grpc/src/core/lib/surface/ |
D | lame_client.cc | 100 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()
|
D | server.cc | 826 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) { in channel_connectivity_changed()
|
/external/grpc-grpc/include/grpc/impl/codegen/ |
D | connectivity_state.h | 37 GRPC_CHANNEL_SHUTDOWN enumerator
|
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
D | pick_first.cc | 203 grpc_connectivity_state_set(&state_tracker_, GRPC_CHANNEL_SHUTDOWN, in ShutdownLocked() 449 GPR_ASSERT(connectivity_state != GRPC_CHANNEL_SHUTDOWN); in ProcessConnectivityChangeLocked() 548 case GRPC_CHANNEL_SHUTDOWN: in ProcessConnectivityChangeLocked()
|
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
D | round_robin.cc | 280 grpc_connectivity_state_set(&state_tracker_, GRPC_CHANNEL_SHUTDOWN, in ShutdownLocked() 463 GPR_ASSERT(old_state != GRPC_CHANNEL_SHUTDOWN); in UpdateStateCountersLocked() 464 GPR_ASSERT(new_state != GRPC_CHANNEL_SHUTDOWN); in UpdateStateCountersLocked()
|
/external/grpc-grpc/src/ruby/ext/grpc/ |
D | rb_channel.c | 277 stack->out = GRPC_CHANNEL_SHUTDOWN; in get_state_without_gil() 581 if (conn_state == GRPC_CHANNEL_SHUTDOWN) { in grpc_rb_channel_try_register_connection_polling() 784 LONG2NUM(GRPC_CHANNEL_SHUTDOWN)); in Init_grpc_connectivity_states()
|
/external/grpc-grpc/src/php/ext/grpc/ |
D | php_grpc.c | 214 GRPC_CHANNEL_SHUTDOWN, in PHP_MINIT_FUNCTION()
|
D | channel.c | 605 case GRPC_CHANNEL_SHUTDOWN: in grpc_connectivity_state_name()
|
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
D | grpclb.cc | 1109 grpc_connectivity_state_set(&state_tracker_, GRPC_CHANNEL_SHUTDOWN, in ShutdownLocked() 1491 case GRPC_CHANNEL_SHUTDOWN: in OnBalancerChannelConnectivityChangedLocked() 1796 GPR_ASSERT(curr_glb_state != GRPC_CHANNEL_SHUTDOWN); in UpdateConnectivityStateFromRoundRobinPolicyLocked() 1799 case GRPC_CHANNEL_SHUTDOWN: in UpdateConnectivityStateFromRoundRobinPolicyLocked()
|
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
D | records.pyx.pxi | 42 shutdown = GRPC_CHANNEL_SHUTDOWN
|
D | grpc.pxi | 233 GRPC_CHANNEL_SHUTDOWN
|
/external/grpc-grpc/src/core/ext/filters/max_age/ |
D | max_age_filter.cc | 352 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) { in channel_connectivity_changed()
|
/external/grpc-grpc/test/core/end2end/fuzzers/ |
D | api_fuzzer.cc | 890 if (st != GRPC_CHANNEL_SHUTDOWN) { in LLVMFuzzerTestOneInput()
|
/external/grpc-grpc/src/core/ext/transport/inproc/ |
D | inproc_transport.cc | 1089 &t->connectivity, GRPC_CHANNEL_SHUTDOWN, in close_transport_locked()
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | chttp2_transport.cc | 613 connectivity_state_set(t, GRPC_CHANNEL_SHUTDOWN, GRPC_ERROR_REF(error), in close_transport_locked()
|