Searched refs:RoundRobinPicker (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 68 import io.grpc.grpclb.GrpclbState.RoundRobinPicker;
306 RoundRobinPicker picker = new RoundRobinPicker(Collections.<DropEntry>emptyList(), pickList); in roundRobinPickerNoDrop()
347 RoundRobinPicker picker = new RoundRobinPicker(dropList, pickList); in roundRobinPickerWithDrop()
444 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in loadReporting()
599 picker = (RoundRobinPicker) pickerCaptor.getValue(); in loadReporting()
722 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in nameResolutionFailsThenRecoverToDelegate()
738 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in nameResolutionFailsThenRecoverToGrpclb()
772 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in grpclbThenNameResolutionFails()
890 RoundRobinPicker picker0 = (RoundRobinPicker) pickerCaptor.getValue(); in grpclbWorking()
898 RoundRobinPicker picker1 = (RoundRobinPicker) pickerCaptor.getValue(); in grpclbWorking()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 118 private RoundRobinPicker currentPicker = new EmptyPicker(EMPTY_OK);
263 private void updateBalancingState(ConnectivityState state, RoundRobinPicker picker) { in updateBalancingState()
404 private abstract static class RoundRobinPicker extends SubchannelPicker { class in RoundRobinLoadBalancerFactory
405 abstract boolean isEquivalentTo(RoundRobinPicker picker); in isEquivalentTo()
409 static final class ReadyPicker extends RoundRobinPicker {
460 boolean isEquivalentTo(RoundRobinPicker picker) { in isEquivalentTo()
473 static final class EmptyPicker extends RoundRobinPicker {
487 boolean isEquivalentTo(RoundRobinPicker picker) { in isEquivalentTo()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 146 private RoundRobinPicker currentPicker =
147 new RoundRobinPicker(Collections.<DropEntry>emptyList(), Arrays.asList(BUFFER_ENTRY));
328 TRANSIENT_FAILURE, new RoundRobinPicker(dropList, Arrays.asList(new ErrorEntry(status)))); in propagateError()
709 maybeUpdatePicker(state, new RoundRobinPicker(dropList, pickList)); in maybeUpdatePicker()
715 private void maybeUpdatePicker(ConnectivityState state, RoundRobinPicker picker) { in maybeUpdatePicker()
906 static final class RoundRobinPicker extends SubchannelPicker { class in GrpclbState
917 RoundRobinPicker(List<DropEntry> dropList, List<? extends RoundRobinEntry> pickList) { in RoundRobinPicker() method in GrpclbState.RoundRobinPicker
|