| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 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()
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/ |
| D | RoundRobinLoadBalancerTest.java | 146 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/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 134 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()
|
| D | ManagedChannelImplIdlenessTest.java | 187 verify(mockLoadBalancer).handleResolvedAddressGroups(servers, Attributes.EMPTY); in newCallExitsIdleness()
|
| D | ManagedChannelImplTest.java | 567 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/ |
| D | AutoConfiguredLoadBalancerFactory.java | 69 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()
|
| D | ManagedChannelImpl.java | 1307 helper.lb.handleResolvedAddressGroups(servers, config); in onAddresses()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PickFirstBalancerFactory.java | 66 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in PickFirstBalancerFactory.PickFirstBalancer
|
| D | LoadBalancer.java | 113 public abstract void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in LoadBalancer
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancer.java | 87 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in GrpclbLoadBalancer
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 129 public void handleResolvedAddressGroups( in handleResolvedAddressGroups() method in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 1545 balancer.handleResolvedAddressGroups(addrs, attrs); in deliverResolvedAddresses()
|