Searched refs:loadBalancer (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 92 private RoundRobinLoadBalancer loadBalancer; field in RoundRobinLoadBalancerTest
134 loadBalancer = (RoundRobinLoadBalancer) RoundRobinLoadBalancerFactory.getInstance() in setUp()
146 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolved()
147 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY)); in pickAfterResolved()
202 loadBalancer.handleResolvedAddressGroups(currentServers, affinity); in pickAfterResolvedUpdatedHosts()
213 assertThat(loadBalancer.getSubchannels()).containsExactly(removedSubchannel, in pickAfterResolvedUpdatedHosts()
225 loadBalancer.handleResolvedAddressGroups(latestServers, affinity); in pickAfterResolvedUpdatedHosts()
230 loadBalancer.handleSubchannelState(removedSubchannel, in pickAfterResolvedUpdatedHosts()
233 assertThat(loadBalancer.getSubchannels()).containsExactly(oldSubchannel, in pickAfterResolvedUpdatedHosts()
244 loadBalancer.handleResolvedAddressGroups(Collections.<EquivalentAddressGroup>emptyList(), in pickAfterResolvedUpdatedHosts()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 60 private PickFirstBalancer loadBalancer; field in PickFirstLoadBalancerTest
92 loadBalancer = (PickFirstBalancer) PickFirstBalancerFactory.getInstance().newLoadBalancer( in setUp()
103 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolved()
117 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolvedAndUnchanged()
119 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolvedAndUnchanged()
141 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolvedAndChanged()
147 loadBalancer.handleResolvedAddressGroups(newServers, affinity); in pickAfterResolvedAndChanged()
156 loadBalancer.handleSubchannelState(mockSubchannel, ConnectivityStateInfo.forNonError(READY)); in stateChangeBeforeResolution()
163 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterStateChangeAfterResolution()
171 loadBalancer.handleSubchannelState(subchannel, in pickAfterStateChangeAfterResolution()
[all …]
|