| /dports/devel/grpc134/grpc-1.34.1/test/cpp/end2end/ |
| H A D | flaky_network_test.cc | 295 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
306 GRPC_CHANNEL_READY) { in WaitForChannelReady()
370 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
392 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
417 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
439 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
452 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
487 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
496 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
513 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
[all …]
|
| H A D | delegating_channel_test.cc | 52 return GRPC_CHANNEL_READY; in GetState()
81 EXPECT_EQ(test_channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
|
| /dports/devel/grpc130/grpc-1.30.2/test/cpp/end2end/ |
| H A D | flaky_network_test.cc | 290 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
301 GRPC_CHANNEL_READY) { in WaitForChannelReady()
365 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
387 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
412 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
434 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
447 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
482 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
491 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
508 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
[all …]
|
| H A D | delegating_channel_test.cc | 52 return GRPC_CHANNEL_READY; in GetState()
81 EXPECT_EQ(test_channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
|
| /dports/devel/grpc/grpc-1.42.0/test/cpp/end2end/ |
| H A D | flaky_network_test.cc | 287 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
298 GRPC_CHANNEL_READY) { in WaitForChannelReady()
362 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
384 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
409 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
431 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
444 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
479 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
488 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
505 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
[all …]
|
| H A D | delegating_channel_test.cc | 53 return GRPC_CHANNEL_READY; in GetState()
82 EXPECT_EQ(test_channel->GetState(false), GRPC_CHANNEL_READY); in TEST_F()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/cpp/end2end/ |
| H A D | flaky_network_test.cc | 289 GRPC_CHANNEL_READY) { in WaitForChannelNotReady()
300 GRPC_CHANNEL_READY) { in WaitForChannelReady()
364 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
386 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
411 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
433 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
446 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
481 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
490 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
507 EXPECT_EQ(channel->GetState(false), GRPC_CHANNEL_READY); in TEST_P()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 215 if (state == GRPC_CHANNEL_READY) { in AttemptToConnectUsingLatestUpdateArgsLocked()
301 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
347 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
349 GRPC_CHANNEL_READY, in ProcessConnectivityChangeLocked()
371 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
449 GRPC_CHANNEL_READY, absl::make_unique<Picker>(subchannel()->Ref())); in ProcessUnselectedReadyLocked()
468 if (current_state == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 211 if (state == GRPC_CHANNEL_READY) { in AttemptToConnectUsingLatestUpdateArgsLocked()
297 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
343 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
345 GRPC_CHANNEL_READY, absl::Status(), in ProcessConnectivityChangeLocked()
368 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
461 GRPC_CHANNEL_READY, absl::Status(), in ProcessUnselectedReadyLocked()
481 if (current_state == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 216 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()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 215 if (state == GRPC_CHANNEL_READY) { in AttemptToConnectUsingLatestUpdateArgsLocked()
301 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
348 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
350 GRPC_CHANNEL_READY, UniquePtr<SubchannelPicker>(New<Picker>( in ProcessConnectivityChangeLocked()
372 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
448 GRPC_CHANNEL_READY, in ProcessUnselectedReadyLocked()
471 if (current_state == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 211 if (state == GRPC_CHANNEL_READY) { in AttemptToConnectUsingLatestUpdateArgsLocked()
297 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
343 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
345 GRPC_CHANNEL_READY, absl::Status(), in ProcessConnectivityChangeLocked()
368 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
461 GRPC_CHANNEL_READY, absl::Status(), in ProcessUnselectedReadyLocked()
481 if (current_state == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 211 if (state == GRPC_CHANNEL_READY) { in AttemptToConnectUsingLatestUpdateArgsLocked()
297 if (connectivity_state != GRPC_CHANNEL_READY && in ProcessConnectivityChangeLocked()
343 if (connectivity_state == GRPC_CHANNEL_READY) { in ProcessConnectivityChangeLocked()
345 GRPC_CHANNEL_READY, absl::Status(), in ProcessConnectivityChangeLocked()
368 case GRPC_CHANNEL_READY: { in ProcessConnectivityChangeLocked()
461 GRPC_CHANNEL_READY, absl::Status(), in ProcessUnselectedReadyLocked()
481 if (current_state == GRPC_CHANNEL_READY) { in CheckConnectivityStateAndStartWatchingLocked()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 190 if (sd->connectivity_state() == GRPC_CHANNEL_READY) { in Picker()
280 if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
290 if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
323 GRPC_CHANNEL_READY, absl::Status(), absl::make_unique<Picker>(p, this)); in MaybeUpdateRoundRobinConnectivityStateLocked()
398 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 189 if (sd->connectivity_state() == GRPC_CHANNEL_READY) { in Picker()
282 if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
292 if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
325 GRPC_CHANNEL_READY, absl::make_unique<Picker>(p, this)); in MaybeUpdateRoundRobinConnectivityStateLocked()
397 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 190 if (sd->connectivity_state() == GRPC_CHANNEL_READY) { in Picker()
280 if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
290 if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
323 GRPC_CHANNEL_READY, absl::Status(), absl::make_unique<Picker>(p, this)); in MaybeUpdateRoundRobinConnectivityStateLocked()
398 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 190 if (sd->connectivity_state() == GRPC_CHANNEL_READY) { in Picker()
280 if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
290 if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
323 GRPC_CHANNEL_READY, absl::Status(), absl::make_unique<Picker>(p, this)); in MaybeUpdateRoundRobinConnectivityStateLocked()
398 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 190 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()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/end2end/tests/ |
| H A 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()
|
| /dports/devel/grpc130/grpc-1.30.2/test/core/transport/ |
| H A D | connectivity_state_test.cc | 37 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()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/ |
| H A D | ring_hash.cc | 427 case GRPC_CHANNEL_READY: in Pick()
448 if (entry.connectivity_state == GRPC_CHANNEL_READY) { in Pick()
499 GRPC_CHANNEL_READY, absl::Status(), in StartWatchingLocked()
510 } else if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
522 } else if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
548 GRPC_CHANNEL_READY, absl::Status(), in UpdateRingHashConnectivityStateLocked()
603 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/ |
| H A D | ring_hash.cc | 427 case GRPC_CHANNEL_READY:
448 if (entry.connectivity_state == GRPC_CHANNEL_READY) {
499 GRPC_CHANNEL_READY, absl::Status(),
510 } else if (old_state == GRPC_CHANNEL_READY) {
522 } else if (new_state == GRPC_CHANNEL_READY) {
548 GRPC_CHANNEL_READY, absl::Status(),
603 if (connectivity_state == GRPC_CHANNEL_READY) {
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/ |
| H A D | ring_hash.cc | 427 case GRPC_CHANNEL_READY: in Pick()
448 if (entry.connectivity_state == GRPC_CHANNEL_READY) { in Pick()
499 GRPC_CHANNEL_READY, absl::Status(), in StartWatchingLocked()
510 } else if (old_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
522 } else if (new_state == GRPC_CHANNEL_READY) { in UpdateStateCountersLocked()
548 GRPC_CHANNEL_READY, absl::Status(), in UpdateRingHashConnectivityStateLocked()
603 if (connectivity_state == GRPC_CHANNEL_READY) { in UpdateConnectivityStateLocked()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/ |
| H A D | subchannel.cc | 379 grpc_connectivity_state pending_connectivity_state_ = GRPC_CHANNEL_READY;
400 if (state == GRPC_CHANNEL_READY) { in NotifyLocked()
428 state_(subchannel_state == GRPC_CHANNEL_READY ? GRPC_CHANNEL_CONNECTING in HealthWatcher()
434 if (subchannel_state == GRPC_CHANNEL_READY) StartHealthCheckingLocked(); in HealthWatcher()
451 if (state_ == GRPC_CHANNEL_READY) { in AddWatcherLocked()
467 if (state == GRPC_CHANNEL_READY) { in NotifyLocked()
580 return subchannel->state_ == GRPC_CHANNEL_READY ? GRPC_CHANNEL_CONNECTING in CheckConnectivityStateLocked()
810 if (connected_subchannel != nullptr && state == GRPC_CHANNEL_READY) { in CheckConnectivityState()
915 case GRPC_CHANNEL_READY: in SubchannelConnectivityStateChangeString()
1089 SetConnectivityStateLocked(GRPC_CHANNEL_READY); in PublishTransportLocked()
|
| /dports/devel/grpc134/grpc-1.34.1/test/core/end2end/tests/ |
| H A D | ping.cc | 67 while (state != GRPC_CHANNEL_READY) { in test_ping()
77 GPR_ASSERT(state == GRPC_CHANNEL_READY || in test_ping()
|