Home
last modified time | relevance | path

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

/third_party/grpc/test/core/transport/
Dconnectivity_state_test.cc40 EXPECT_STREQ("SHUTDOWN", ConnectivityStateName(GRPC_CHANNEL_SHUTDOWN)); in TEST()
128 tracker.SetState(GRPC_CHANNEL_SHUTDOWN, "shutting down"); in TEST()
131 EXPECT_EQ(state, GRPC_CHANNEL_SHUTDOWN); in TEST()
138 ConnectivityStateTracker tracker("xxx", GRPC_CHANNEL_SHUTDOWN); in TEST()
145 EXPECT_EQ(state, GRPC_CHANNEL_SHUTDOWN); in TEST()
162 EXPECT_EQ(state, GRPC_CHANNEL_SHUTDOWN); in TEST()
167 grpc_connectivity_state state = GRPC_CHANNEL_SHUTDOWN; in TEST()
169 ConnectivityStateTracker tracker("xxx", GRPC_CHANNEL_SHUTDOWN); in TEST()
170 tracker.AddWatcher(GRPC_CHANNEL_SHUTDOWN, in TEST()
175 EXPECT_EQ(state, GRPC_CHANNEL_SHUTDOWN); in TEST()
[all …]
/third_party/grpc/src/core/lib/transport/
Dconnectivity_state.cc46 case GRPC_CHANNEL_SHUTDOWN: in ConnectivityStateName()
105 if (current_state == GRPC_CHANNEL_SHUTDOWN) return; in ~ConnectivityStateTracker()
111 ConnectivityStateName(GRPC_CHANNEL_SHUTDOWN)); in ~ConnectivityStateTracker()
113 p.second->Notify(GRPC_CHANNEL_SHUTDOWN, absl::Status()); in ~ConnectivityStateTracker()
136 if (current_state != GRPC_CHANNEL_SHUTDOWN) { in AddWatcher()
173 if (state == GRPC_CHANNEL_SHUTDOWN) watchers_.clear(); in SetState()
/third_party/grpc/test/core/surface/
Dlame_client_test.cc34 GPR_ASSERT(new_state == GRPC_CHANNEL_SHUTDOWN); in Notify()
84 GPR_ASSERT(GRPC_CHANNEL_SHUTDOWN == in main()
/third_party/grpc/include/grpc/impl/codegen/
Dconnectivity_state.h37 GRPC_CHANNEL_SHUTDOWN enumerator
/third_party/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc323 case GRPC_CHANNEL_SHUTDOWN: { in OnConnectivityStateChange()
341 new_state == GRPC_CHANNEL_SHUTDOWN in OnConnectivityStateChange()
496 if (new_state != GRPC_CHANNEL_SHUTDOWN && health_check_client_ != nullptr) { in OnConnectivityStateChange()
702 channelz_node_->UpdateConnectivityState(GRPC_CHANNEL_SHUTDOWN); in ~Subchannel()
947 case GRPC_CHANNEL_SHUTDOWN: in SubchannelConnectivityStateChangeString()
Dchannel_connectivity.cc55 return GRPC_CHANNEL_SHUTDOWN; in grpc_channel_check_connectivity_state()
Dclient_channel.cc1630 if (state != GRPC_CHANNEL_SHUTDOWN) { in Notify()
2392 if (picker == nullptr || state == GRPC_CHANNEL_SHUTDOWN) { in UpdateStateAndPickerLocked()
2533 GRPC_CHANNEL_SHUTDOWN, absl::Status(), "shutdown from API", in StartTransportOpLocked()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc281 GPR_ASSERT(old_state != GRPC_CHANNEL_SHUTDOWN); in UpdateStateCountersLocked()
282 GPR_ASSERT(new_state != GRPC_CHANNEL_SHUTDOWN); in UpdateStateCountersLocked()
/third_party/grpc/src/ruby/ext/grpc/
Drb_channel.c280 stack->out = GRPC_CHANNEL_SHUTDOWN; in get_state_without_gil()
584 if (conn_state == GRPC_CHANNEL_SHUTDOWN) { in grpc_rb_channel_try_register_connection_polling()
788 LONG2NUM(GRPC_CHANNEL_SHUTDOWN)); in Init_grpc_connectivity_states()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc292 GPR_ASSERT(connectivity_state != GRPC_CHANNEL_SHUTDOWN); in ProcessConnectivityChangeLocked()
419 case GRPC_CHANNEL_SHUTDOWN: in ProcessConnectivityChangeLocked()
/third_party/grpc/src/core/lib/surface/
Dlame_client.cc43 ChannelData() : state_tracker("lame_channel", GRPC_CHANNEL_SHUTDOWN) {} in ChannelData()
Dserver.cc971 if (new_state != GRPC_CHANNEL_SHUTDOWN) return; in OnConnectivityStateChange()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Drecords.pyx.pxi40 shutdown = GRPC_CHANNEL_SHUTDOWN
Dgrpc.pxi245 GRPC_CHANNEL_SHUTDOWN
/third_party/grpc/src/php/ext/grpc/
Dphp_grpc.c541 GRPC_CHANNEL_SHUTDOWN, in PHP_MINIT_FUNCTION()
Dchannel.c637 case GRPC_CHANNEL_SHUTDOWN: in grpc_connectivity_state_name()
/third_party/grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc234 if (new_state != GRPC_CHANNEL_SHUTDOWN) return; in OnConnectivityStateChange()
/third_party/grpc/src/core/lib/channel/
Dchannelz.cc160 case GRPC_CHANNEL_SHUTDOWN: in GetChannelConnectivityStateChangeString()
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc1130 t->state_tracker.SetState(GRPC_CHANNEL_SHUTDOWN, absl::Status(), in close_transport_locked()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc547 connectivity_state_set(t, GRPC_CHANNEL_SHUTDOWN, absl::Status(), in close_transport_locked()