Searched refs:nextSubchannel (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 290 private Subchannel nextSubchannel(Subchannel current, List<Subchannel> allSubChannels) { in nextSubchannel() method in RoundRobinLoadBalancerTest
423 assertEquals(nextSubchannel(sc1, allSubchannels), sc2); in noStickinessEnabled_withStickyHeader()
424 assertEquals(nextSubchannel(sc2, allSubchannels), sc3); in noStickinessEnabled_withStickyHeader()
425 assertEquals(nextSubchannel(sc3, allSubchannels), sc1); in noStickinessEnabled_withStickyHeader()
454 assertEquals(nextSubchannel(sc1, allSubchannels), sc2); in stickinessEnabled_withoutStickyHeader()
455 assertEquals(nextSubchannel(sc2, allSubchannels), sc3); in stickinessEnabled_withoutStickyHeader()
456 assertEquals(nextSubchannel(sc3, allSubchannels), sc1); in stickinessEnabled_withoutStickyHeader()
530 assertEquals(nextSubchannel(sc1a, allSubchannels), sc2a); in stickinessEnabled_withDifferentStickyHeaders()
531 assertEquals(nextSubchannel(sc1b, allSubchannels), sc2b); in stickinessEnabled_withDifferentStickyHeaders()
668 assertEquals(nextSubchannel(sc1, allSubchannels), in stickiness_oneSubchannelShutdown()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 435 subchannel = stickinessState.maybeRegister(stickinessValue, nextSubchannel()); in pickSubchannel()
440 return PickResult.withSubchannel(subchannel != null ? subchannel : nextSubchannel()); in pickSubchannel()
443 private Subchannel nextSubchannel() { in nextSubchannel() method in RoundRobinLoadBalancerFactory.ReadyPicker
|