Home
last modified time | relevance | path

Searched refs:GRPC_CHANNEL_SHUTDOWN (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc/test/core/transport/
Dconnectivity_state_test.cc56 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/
Dconnectivity_state.cc41 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/
Dlame_client_test.cc37 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/
Dclient_channel_channelz.cc58 state = GRPC_CHANNEL_SHUTDOWN; in PopulateConnectivityState()
128 state = GRPC_CHANNEL_SHUTDOWN; in PopulateConnectivityState()
Dchannel_connectivity.cc54 return GRPC_CHANNEL_SHUTDOWN; in grpc_channel_check_connectivity_state()
Dsubchannel.cc562 case GRPC_CHANNEL_SHUTDOWN: { in on_connected_subchannel_connectivity_changed()
581 GRPC_CHANNEL_SHUTDOWN; in on_connected_subchannel_connectivity_changed()
Dclient_channel.cc170 } 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/
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.cc826 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) { in channel_connectivity_changed()
/external/grpc-grpc/include/grpc/impl/codegen/
Dconnectivity_state.h37 GRPC_CHANNEL_SHUTDOWN enumerator
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc203 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/
Dround_robin.cc280 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/
Drb_channel.c277 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/
Dphp_grpc.c214 GRPC_CHANNEL_SHUTDOWN, in PHP_MINIT_FUNCTION()
Dchannel.c605 case GRPC_CHANNEL_SHUTDOWN: in grpc_connectivity_state_name()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc1109 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/
Drecords.pyx.pxi42 shutdown = GRPC_CHANNEL_SHUTDOWN
Dgrpc.pxi233 GRPC_CHANNEL_SHUTDOWN
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc352 if (chand->connectivity_state != GRPC_CHANNEL_SHUTDOWN) { in channel_connectivity_changed()
/external/grpc-grpc/test/core/end2end/fuzzers/
Dapi_fuzzer.cc890 if (st != GRPC_CHANNEL_SHUTDOWN) { in LLVMFuzzerTestOneInput()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc1089 &t->connectivity, GRPC_CHANNEL_SHUTDOWN, in close_transport_locked()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc613 connectivity_state_set(t, GRPC_CHANNEL_SHUTDOWN, GRPC_ERROR_REF(error), in close_transport_locked()