Home
last modified time | relevance | path

Searched refs:GRPC_CHANNEL_READY (Results 1 – 25 of 39) sorted by relevance

12

/third_party/grpc/test/cpp/end2end/
Dflaky_network_test.cc293 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
304 GRPC_CHANNEL_READY) { in WaitForChannelReady()
368 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
390 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
415 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
437 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
450 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
485 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
494 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
511 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
[all …]
Ddelegating_channel_test.cc52 return GRPC_CHANNEL_READY; in GetState()
81 EXPECT_EQ(test_channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
Dcfstream_test.cc220 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
231 GRPC_CHANNEL_READY) { in WaitForChannelReady()
337 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
362 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
Dclient_lb_end2end_test.cc418 return state != GRPC_CHANNEL_READY; in WaitForChannelNotReady()
425 return state == GRPC_CHANNEL_READY; in WaitForChannelReady()
716 } while (channel_state == GRPC_CHANNEL_READY); in TEST_F()
717 ASSERT_NE(channel_state, GRPC_CHANNEL_READY); in TEST_F()
965 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
986 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
1033 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
1048 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
1165 } while (channel_state == GRPC_CHANNEL_READY); in TEST_F()
1166 ASSERT_NE(channel_state, GRPC_CHANNEL_READY); in TEST_F()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc216 if (state == GRPC_CHANNEL_READY) { in AttemptToConnectUsingLatestUpdateArgsLocked()
302 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
350 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
352 GRPC_CHANNEL_READY, absl::Status(), in ProcessConnectivityChangeLocked()
375 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
454 GRPC_CHANNEL_READY, absl::Status(), in ProcessUnselectedReadyLocked()
474 if (current_state == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc190 if (sd->connectivity_state() == GRPC_CHANNEL_READY) { in Picker()
283 if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
293 if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
326 GRPC_CHANNEL_READY, absl::Status(), absl::make_unique<Picker>(p, this)); in MaybeUpdateRoundRobinConnectivityStateLocked()
398 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
/third_party/grpc/test/core/transport/
Dconnectivity_state_test.cc37 EXPECT_STREQ("READY", ConnectivityStateName(GRPC_CHANNEL_READY)); in TEST()
67 tracker.SetState(GRPC_CHANNEL_READY, "whee"); in TEST()
68 EXPECT_EQ(tracker.state(), GRPC_CHANNEL_READY); in TEST()
/third_party/grpc/test/core/end2end/tests/
Dconnectivity.cc133 while (state != GRPC_CHANNEL_READY) { in test_connectivity()
139 GPR_ASSERT(state == GRPC_CHANNEL_READY || in test_connectivity()
148 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_READY, in test_connectivity()
Dping.cc72 while (state != GRPC_CHANNEL_READY) { in test_ping()
82 GPR_ASSERT(state == GRPC_CHANNEL_READY || in test_ping()
Dmax_connection_idle.cc195 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()
/third_party/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc108 op->start_connectivity_watch_state = GRPC_CHANNEL_READY; in StartWatch()
373 if (state == GRPC_CHANNEL_READY) { in AsyncWatcherNotifierLocked()
431 state_(subchannel_state == GRPC_CHANNEL_READY ? GRPC_CHANNEL_CONNECTING in HealthWatcher()
435 if (subchannel_state == GRPC_CHANNEL_READY) StartHealthCheckingLocked(); in HealthWatcher()
465 if (state == GRPC_CHANNEL_READY) { in NotifyLocked()
570 return subchannel->state_ == GRPC_CHANNEL_READY ? GRPC_CHANNEL_CONNECTING in CheckConnectivityStateLocked()
835 if (connected_subchannel != nullptr && state == GRPC_CHANNEL_READY) { in CheckConnectivityState()
943 case GRPC_CHANNEL_READY: in SubchannelConnectivityStateChangeString()
1122 SetConnectivityStateLocked(GRPC_CHANNEL_READY, absl::Status()); in PublishTransportLocked()
/third_party/grpc/include/grpc/impl/codegen/
Dconnectivity_state.h33 GRPC_CHANNEL_READY, enumerator
/third_party/grpc/test/core/tsi/alts/handshaker/
Dalts_concurrent_connectivity_test.cc237 ASSERT_NE(state, GRPC_CHANNEL_READY); // sanity check in ConnectLoop()
239 ASSERT_EQ(self->expected_connectivity_states_, GRPC_CHANNEL_READY); in ConnectLoop()
294 GRPC_CHANNEL_READY /* expected connectivity states */, in TEST()
317 GRPC_CHANNEL_READY /* expected connectivity states */, in TEST()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc305 case GRPC_CHANNEL_READY: { in UpdateStateLocked()
328 connectivity_state = GRPC_CHANNEL_READY; in UpdateStateLocked()
343 case GRPC_CHANNEL_READY: { in UpdateStateLocked()
578 if (state != GRPC_CHANNEL_READY) return; in UpdateState()
Dxds_routing.cc432 case GRPC_CHANNEL_READY: { in UpdateStateLocked()
455 connectivity_state = GRPC_CHANNEL_READY; in UpdateStateLocked()
469 case GRPC_CHANNEL_READY: { in UpdateStateLocked()
680 if (state != GRPC_CHANNEL_READY) return; in UpdateState()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc342 case GRPC_CHANNEL_READY: { in UpdateStateLocked()
366 connectivity_state = GRPC_CHANNEL_READY; in UpdateStateLocked()
381 case GRPC_CHANNEL_READY: in UpdateStateLocked()
541 if (state != GRPC_CHANNEL_READY) return; in OnConnectivityStateUpdateLocked()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc345 if (child->connectivity_state() == GRPC_CHANNEL_READY || in HandleChildConnectivityStateChangeLocked()
390 if (child->connectivity_state() == GRPC_CHANNEL_READY || in HandleChildConnectivityStateChangeLocked()
444 if (child->connectivity_state() == GRPC_CHANNEL_READY || in TryNextPriorityLocked()
624 if (state == GRPC_CHANNEL_READY || state == GRPC_CHANNEL_TRANSIENT_FAILURE) { in OnConnectivityStateUpdateLocked()
/third_party/grpc/test/core/end2end/
Dgoaway_server_test.cc268 GPR_ASSERT(GRPC_CHANNEL_READY == in main()
270 grpc_channel_watch_connectivity_state(chan, GRPC_CHANNEL_READY, in main()
/third_party/grpc/src/core/lib/transport/
Dconnectivity_state.cc42 case GRPC_CHANNEL_READY: in ConnectivityStateName()
/third_party/grpc/include/grpcpp/impl/codegen/
Dchannel_interface.h99 while ((state = GetState(true)) != GRPC_CHANNEL_READY) { in WaitForConnected()
/third_party/grpc/test/core/surface/
Dsequential_connectivity_test.cc112 GRPC_CHANNEL_READY) { in run_test()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc469 healthy ? GRPC_CHANNEL_READY : GRPC_CHANNEL_TRANSIENT_FAILURE; in DoneReadingRecvMessage()
583 self->health_check_client_->SetHealthStatus(GRPC_CHANNEL_READY, in RecvTrailingMetadataReady()
/third_party/grpc/test/cpp/qps/
Dclient.h468 if (last_observed == GRPC_CHANNEL_READY) { in WaitForChannelsToConnect()
488 if (last_observed == GRPC_CHANNEL_READY) { in WaitForChannelsToConnect()
/third_party/grpc/test/core/handshake/
Dclient_ssl.cc286 while (state != GRPC_CHANNEL_READY && retries-- > 0) { in client_ssl_test()
Dverify_peer_options.cc179 while (state != GRPC_CHANNEL_READY && retries-- > 0) { in verify_peer_options_test()

12