| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | lb_policy.h | 264 class SubchannelPicker {
266 SubchannelPicker() = default;
267 virtual ~SubchannelPicker() = default;
287 std::unique_ptr<SubchannelPicker>) = 0;
373 class QueuePicker : public SubchannelPicker {
388 class TransientFailurePicker : public SubchannelPicker {
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PickFirstBalancerFactory.java | 28 import io.grpc.LoadBalancer.SubchannelPicker;
98 SubchannelPicker picker; in handleSubchannelState()
133 private static final class Picker extends SubchannelPicker {
147 private static final class RequestConnectionPicker extends SubchannelPicker {
|
| D | LoadBalancer.java | 170 public abstract static class SubchannelPicker { class in LoadBalancer
568 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker); in updateBalancingState()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 40 import io.grpc.LoadBalancer.SubchannelPicker;
70 @Mock private SubchannelPicker mockPicker;
346 SubchannelPicker picker = mock(SubchannelPicker.class); in reprocessSemantics()
393 picker = mock(SubchannelPicker.class); in reprocessSemantics()
440 picker = mock(SubchannelPicker.class); in reprocessSemantics()
454 SubchannelPicker picker = mock(SubchannelPicker.class); in reprocess_NoPendingStream()
478 SubchannelPicker picker = mock(SubchannelPicker.class); in reprocess_newStreamRacesWithReprocess()
546 SubchannelPicker picker2 = mock(SubchannelPicker.class); in reprocess_newStreamRacesWithReprocess()
|
| D | AutoConfiguredLoadBalancerFactoryTest.java | 33 import io.grpc.LoadBalancer.SubchannelPicker;
126 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_keepOldBalancer()
160 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_shutsDownOldBalancer()
298 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in channelTracing_lbPolicyChanged()
396 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker) { in updateBalancingState()
|
| D | ManagedChannelImplIdlenessTest.java | 46 import io.grpc.LoadBalancer.SubchannelPicker;
270 SubchannelPicker mockPicker = mock(SubchannelPicker.class); in realTransportsHoldsOffIdleness()
350 SubchannelPicker failingPicker = mock(SubchannelPicker.class); in oobTransportDoesNotAffectIdleness()
|
| D | ManagedChannelImplTest.java | 80 import io.grpc.LoadBalancer.SubchannelPicker;
187 private SubchannelPicker mockPicker;
511 SubchannelPicker picker2 = mock(SubchannelPicker.class); in subtestCallsAndShutdown()
748 SubchannelPicker picker = mock(SubchannelPicker.class); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
929 SubchannelPicker picker = mock(SubchannelPicker.class); in subtestFailRpcFromBalancer()
1029 SubchannelPicker picker2 = mock(SubchannelPicker.class); in allServersFailedToConnect()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/ |
| D | weighted_target.cc | 88 explicit ChildPickerWrapper(std::unique_ptr<SubchannelPicker> picker) in ChildPickerWrapper()
93 std::unique_ptr<SubchannelPicker> picker_;
98 class WeightedPicker : public SubchannelPicker {
151 std::unique_ptr<SubchannelPicker> picker) override;
166 std::unique_ptr<SubchannelPicker> picker);
378 std::unique_ptr<SubchannelPicker> picker; in UpdateStateLocked()
518 std::unique_ptr<SubchannelPicker> picker) { in OnConnectivityStateUpdateLocked()
601 std::unique_ptr<SubchannelPicker> picker) { in UpdateState()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | DelayedClientTransport.java | 28 import io.grpc.LoadBalancer.SubchannelPicker;
80 private SubchannelPicker lastPicker;
134 SubchannelPicker picker; in newStream()
276 final void reprocess(@Nullable SubchannelPicker picker) { in reprocess()
|
| D | OobChannel.java | 43 import io.grpc.LoadBalancer.SubchannelPicker;
71 private SubchannelPicker subchannelPicker;
177 subchannelPicker = new SubchannelPicker() { in setSubchannel()
259 delayedTransport.reprocess(new SubchannelPicker() { in handleSubchannelStateChange()
|
| D | AutoConfiguredLoadBalancerFactory.java | 31 import io.grpc.LoadBalancer.SubchannelPicker;
237 private static final class EmptyPicker extends SubchannelPicker {
245 private static final class FailingPicker extends SubchannelPicker {
|
| D | ManagedChannelImpl.java | 56 import io.grpc.LoadBalancer.SubchannelPicker;
166 private volatile SubchannelPicker subchannelPicker;
424 SubchannelPicker pickerCopy = subchannelPicker; in get()
727 final class PanicSubchannelPicker extends SubchannelPicker { in panic()
751 private void updateSubchannelPicker(SubchannelPicker newPicker) { in updateSubchannelPicker()
1108 final ConnectivityState newState, final SubchannelPicker newPicker) { in updateBalancingState()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 58 import io.grpc.LoadBalancer.SubchannelPicker;
99 private ArgumentCaptor<SubchannelPicker> pickerCaptor;
207 SubchannelPicker picker = pickerCaptor.getValue(); in pickAfterResolvedUpdatedHosts()
314 SubchannelPicker picker = new EmptyPicker(Status.UNKNOWN); in pickerEmptyList()
380 Iterator<SubchannelPicker> pickers = pickerCaptor.getAllValues().iterator(); in subchannelStateIsolation()
410 SubchannelPicker picker = pickerCaptor.getValue(); in noStickinessEnabled_withStickyHeader()
443 SubchannelPicker picker = pickerCaptor.getValue(); in stickinessEnabled_withoutStickyHeader()
475 SubchannelPicker picker = pickerCaptor.getValue(); in stickinessEnabled_withStickyHeader()
505 SubchannelPicker picker = pickerCaptor.getValue(); in stickinessEnabled_withDifferentStickyHeaders()
550 SubchannelPicker picker = pickerCaptor.getValue(); in stickiness_goToTransientFailure_pick_backToReady()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 41 import io.grpc.LoadBalancer.SubchannelPicker;
68 private ArgumentCaptor<SubchannelPicker> pickerCaptor;
125 .updateBalancingState(isA(ConnectivityState.class), isA(SubchannelPicker.class)); in pickAfterResolvedAndUnchanged()
205 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in nameResolutionSuccessAfterError()
253 SubchannelPicker picker = pickerCaptor.getValue(); in requestConnection()
|
| D | LoadBalancerTest.java | 210 ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker) {} in updateBalancingState()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | ForwardingLoadBalancerHelper.java | 25 import io.grpc.LoadBalancer.SubchannelPicker;
72 ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState()
|
| D | RoundRobinLoadBalancerFactory.java | 39 import io.grpc.LoadBalancer.SubchannelPicker;
404 private abstract static class RoundRobinPicker extends SubchannelPicker {
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/ |
| D | priority.cc | 113 std::unique_ptr<SubchannelPicker> GetPicker() { in GetPicker()
133 explicit RefCountedPicker(std::unique_ptr<SubchannelPicker> picker) in RefCountedPicker()
138 std::unique_ptr<SubchannelPicker> picker_;
142 class RefCountedPickerWrapper : public SubchannelPicker {
163 std::unique_ptr<SubchannelPicker> picker) override;
178 std::unique_ptr<SubchannelPicker> picker);
609 std::unique_ptr<SubchannelPicker> picker) { in OnConnectivityStateUpdateLocked()
759 std::unique_ptr<SubchannelPicker> picker) { in UpdateState()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | xds_cluster_manager.cc | 85 std::unique_ptr<SubchannelPicker> picker) in ChildPickerWrapper()
93 std::unique_ptr<SubchannelPicker> picker_;
98 class ClusterPicker : public SubchannelPicker {
152 std::unique_ptr<SubchannelPicker> picker) override;
340 std::unique_ptr<SubchannelPicker> picker; in UpdateStateLocked()
551 std::unique_ptr<SubchannelPicker> picker) { in UpdateState()
|
| D | xds_cluster_impl.cc | 195 explicit RefCountedPicker(std::unique_ptr<SubchannelPicker> picker) in RefCountedPicker()
200 std::unique_ptr<SubchannelPicker> picker_;
204 class Picker : public SubchannelPicker {
232 std::unique_ptr<SubchannelPicker> picker) override;
575 std::unique_ptr<SubchannelPicker> picker) { in UpdateState()
|
| D | cds.cc | 109 std::unique_ptr<SubchannelPicker> picker) override;
213 std::unique_ptr<SubchannelPicker> picker) { in UpdateState()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 60 import io.grpc.LoadBalancer.SubchannelPicker;
143 private SubchannelPicker currentPicker;
163 private ArgumentCaptor<SubchannelPicker> pickerCaptor;
243 currentPicker = (SubchannelPicker) invocation.getArguments()[1]; in setUp()
247 any(ConnectivityState.class), any(SubchannelPicker.class)); in setUp()
578 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in loadReporting()
864 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in grpclbWorking()
1140 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in subtestGrpclbFallbackInitialTimeout()
1171 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in subtestGrpclbFallbackInitialTimeout()
1367 .updateBalancingState(eq(CONNECTING), any(SubchannelPicker.class)); in fallbackTestVerifyUseOfBackendLists()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 331 class Picker : public SubchannelPicker {
334 std::unique_ptr<SubchannelPicker> child_picker, in Picker()
346 std::unique_ptr<SubchannelPicker> child_picker_;
358 std::unique_ptr<SubchannelPicker> picker) override;
688 std::unique_ptr<SubchannelPicker> picker) { in UpdateState()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | child_policy_handler.cc | 50 std::unique_ptr<SubchannelPicker> picker) override { in UpdateState()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 153 class Picker : public SubchannelPicker {
|