Searched refs:ReadyPicker (Results 1 – 2 of 2) sorted by relevance
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
D | RoundRobinLoadBalancerFactory.java | 193 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/ |
D | RoundRobinLoadBalancerTest.java | 64 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()
|