Home
last modified time | relevance | path

Searched refs:handleResolvedAddressGroups (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java103 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()
163 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterStateChangeAfterResolution()
208 loadBalancer.handleResolvedAddressGroups(servers, affinity); in nameResolutionSuccessAfterError()
250 loadBalancer.handleResolvedAddressGroups(servers, affinity); in requestConnection()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java146 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolved()
202 loadBalancer.handleResolvedAddressGroups(currentServers, affinity); in pickAfterResolvedUpdatedHosts()
225 loadBalancer.handleResolvedAddressGroups(latestServers, affinity); in pickAfterResolvedUpdatedHosts()
244 loadBalancer.handleResolvedAddressGroups(Collections.<EquivalentAddressGroup>emptyList(), in pickAfterResolvedUpdatedHosts()
256 loadBalancer.handleResolvedAddressGroups(servers, Attributes.EMPTY); in pickAfterStateChange()
335 loadBalancer.handleResolvedAddressGroups(servers, affinity); in nameResolutionErrorWithActiveChannels()
365 loadBalancer.handleResolvedAddressGroups(servers, Attributes.EMPTY); in subchannelStateIsolation()
404 loadBalancer.handleResolvedAddressGroups(servers, Attributes.EMPTY); in noStickinessEnabled_withStickyHeader()
437 loadBalancer.handleResolvedAddressGroups(servers, attributes); in stickinessEnabled_withoutStickyHeader()
469 loadBalancer.handleResolvedAddressGroups(servers, attributes); in stickinessEnabled_withStickyHeader()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java134 lb.handleResolvedAddressGroups(servers, Attributes.EMPTY); in handleResolvedAddressGroups_keepOldBalancer()
186 lb.handleResolvedAddressGroups(servers, serviceConfigAttrs); in handleResolvedAddressGroups_shutsDownOldBalancer()
306 lb.handleResolvedAddressGroups(servers, Attributes.EMPTY); in channelTracing_lbPolicyChanged()
312 lb.handleResolvedAddressGroups(servers, in channelTracing_lbPolicyChanged()
322 lb.handleResolvedAddressGroups(servers, in channelTracing_lbPolicyChanged()
331 lb.handleResolvedAddressGroups(servers, Attributes.EMPTY); in channelTracing_lbPolicyChanged()
351 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancer
353 delegate().handleResolvedAddressGroups(servers, attributes); in handleResolvedAddressGroups()
DManagedChannelImplIdlenessTest.java187 verify(mockLoadBalancer).handleResolvedAddressGroups(servers, Attributes.EMPTY); in newCallExitsIdleness()
DManagedChannelImplTest.java567 verify(mockLoadBalancer).handleResolvedAddressGroups( in noMoreCallbackAfterLoadBalancerShutdown()
787 doThrow(ex).when(mockLoadBalancer).handleResolvedAddressGroups( in loadBalancerThrowsInHandleResolvedAddresses()
850 inOrder.verify(mockLoadBalancer).handleResolvedAddressGroups( in firstResolvedServerFailedToConnect()
995 inOrder.verify(mockLoadBalancer).handleResolvedAddressGroups( in allServersFailedToConnect()
2644 .handleResolvedAddressGroups(nameResolverFactory.servers, attributesWithRetryPolicy); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactory.java69 public void handleResolvedAddressGroups(List<EquivalentAddressGroup> s, Attributes a) {} in handleResolvedAddressGroups() method in AutoConfiguredLoadBalancerFactory.NoopLoadBalancer
106 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in AutoConfiguredLoadBalancerFactory.AutoConfiguredLoadBalancer
137 getDelegate().handleResolvedAddressGroups(servers, attributes); in handleResolvedAddressGroups()
DManagedChannelImpl.java1307 helper.lb.handleResolvedAddressGroups(servers, config); in onAddresses()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java66 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in PickFirstBalancerFactory.PickFirstBalancer
DLoadBalancer.java113 public abstract void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in LoadBalancer
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbLoadBalancer.java87 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in GrpclbLoadBalancer
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java129 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java1545 balancer.handleResolvedAddressGroups(addrs, attrs); in deliverResolvedAddresses()