Home
last modified time | relevance | path

Searched refs:ReadyPicker (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java193 currentPicker instanceof ReadyPicker ? currentPicker : new EmptyPicker(error)); in handleNameResolutionError()
259 updateBalancingState(READY, new ReadyPicker(activeList, startIndex, stickinessState)); in updateBalancingState()
409 static final class ReadyPicker extends RoundRobinPicker { class in RoundRobinLoadBalancerFactory
410 private static final AtomicIntegerFieldUpdater<ReadyPicker> indexUpdater =
411 AtomicIntegerFieldUpdater.newUpdater(ReadyPicker.class, "index");
419 ReadyPicker(List<Subchannel> list, int startIndex, in ReadyPicker() method in RoundRobinLoadBalancerFactory.ReadyPicker
461 if (!(picker instanceof ReadyPicker)) { in isEquivalentTo()
464 ReadyPicker other = (ReadyPicker) picker; in isEquivalentTo()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java64 import io.grpc.util.RoundRobinLoadBalancerFactory.ReadyPicker;
267 assertThat(pickerCaptor.getValue()).isInstanceOf(ReadyPicker.class); in pickAfterStateChange()
300 ReadyPicker picker = new ReadyPicker(Collections.unmodifiableList( in pickerRoundRobin()
732 new ReadyPicker(Collections.<Subchannel>emptyList(), 0, null); in readyPicker_emptyList()
745 ReadyPicker ready1 = new ReadyPicker(Arrays.asList(sc1, sc2), 0, null); in internalPickerComparisons()
746 ReadyPicker ready2 = new ReadyPicker(Arrays.asList(sc1), 0, null); in internalPickerComparisons()
747 ReadyPicker ready3 = new ReadyPicker(Arrays.asList(sc2, sc1), 1, null); in internalPickerComparisons()
748 ReadyPicker ready4 = new ReadyPicker(Arrays.asList(sc1, sc2), 1, stickinessState); in internalPickerComparisons()
749 ReadyPicker ready5 = new ReadyPicker(Arrays.asList(sc2, sc1), 0, stickinessState); in internalPickerComparisons()
763 return picker instanceof ReadyPicker ? ((ReadyPicker) picker).getList() : in getList()