| /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 | 164 public abstract static class SubchannelPicker { class in LoadBalancer
562 @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 | 30 import io.grpc.LoadBalancer.SubchannelPicker;
122 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_keepOldBalancer()
156 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_shutsDownOldBalancer()
318 @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 | 81 import io.grpc.LoadBalancer.SubchannelPicker;
188 private SubchannelPicker mockPicker;
512 SubchannelPicker picker2 = mock(SubchannelPicker.class); in subtestCallsAndShutdown()
749 SubchannelPicker picker = mock(SubchannelPicker.class); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
930 SubchannelPicker picker = mock(SubchannelPicker.class); in subtestFailRpcFromBalancer()
1030 SubchannelPicker picker2 = mock(SubchannelPicker.class); in allServersFailedToConnect()
|
| /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/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 | AutoConfiguredLoadBalancerFactory.java | 28 import io.grpc.LoadBalancer.SubchannelPicker;
206 private static final class EmptyPicker extends SubchannelPicker {
214 private static final class FailingPicker extends SubchannelPicker {
|
| 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 | ManagedChannelImpl.java | 56 import io.grpc.LoadBalancer.SubchannelPicker;
172 private volatile SubchannelPicker subchannelPicker;
469 SubchannelPicker pickerCopy = subchannelPicker;
748 SubchannelPicker newPicker = new SubchannelPicker() { in panic()
770 private void updateSubchannelPicker(SubchannelPicker newPicker) { in updateSubchannelPicker()
1113 final ConnectivityState newState, final SubchannelPicker newPicker) { in updateBalancingState()
|
| /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/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 61 import io.grpc.LoadBalancer.SubchannelPicker;
144 private SubchannelPicker currentPicker;
164 private ArgumentCaptor<SubchannelPicker> pickerCaptor;
244 currentPicker = (SubchannelPicker) invocation.getArguments()[1]; in setUp()
248 any(ConnectivityState.class), any(SubchannelPicker.class)); in setUp()
579 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in loadReporting()
865 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in grpclbWorking()
1163 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in subtestGrpclbFallbackInitialTimeout()
1194 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in subtestGrpclbFallbackInitialTimeout()
1336 .updateBalancingState(eq(CONNECTING), any(SubchannelPicker.class)); in fallbackTestVerifyUseOfBackendLists()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 39 import io.grpc.LoadBalancer.SubchannelPicker;
404 private abstract static class RoundRobinPicker extends SubchannelPicker {
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 41 import io.grpc.LoadBalancer.SubchannelPicker;
906 static final class RoundRobinPicker extends SubchannelPicker {
|