| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | CachedSubchannelPool.java | 68 CacheEntry prev = cache.get(subchannel.getAddresses()); in returnSubchannel()
85 cache.put(subchannel.getAddresses(), entry); in returnSubchannel()
126 CacheEntry entry = cache.remove(subchannel.getAddresses()); in run()
|
| D | GrpclbState.java | 269 lbAddressGroup.getAddresses(), lbAddressGroup.getAuthority()); in startLbComm()
271 helper.updateOobChannelAddresses(lbCommChannel, lbAddressGroup.getAddresses()); in startLbComm()
276 lbAddressGroup.getAddresses(), lbAddressGroup.getAuthority()); in startLbComm()
354 EquivalentAddressGroup eag = backendAddr.getAddresses(); in useRoundRobinLists()
742 eags.add(group.getAddresses()); in flattenLbAddressGroups()
763 addrs.addAll(group.getAddresses()); in flattenEquivalentAddressGroup()
|
| D | LbAddressGroup.java | 35 EquivalentAddressGroup getAddresses() { in getAddresses() method in LbAddressGroup
|
| D | BackendAddressGroup.java | 34 EquivalentAddressGroup getAddresses() { in getAddresses() method in BackendAddressGroup
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | LoadBalancerTest.java | 185 assertThat(subchannel.getAddresses()).isEqualTo(eag); in subchannel_getAddresses_delegates()
199 }.getAddresses(); in subchannel_getAddresses_throwsOnTwoAddrs()
|
| D | PickFirstLoadBalancerTest.java | 87 when(mockSubchannel.getAddresses()).thenThrow(new UnsupportedOperationException()); in setUp()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | EquivalentAddressGroup.java | 79 public List<SocketAddress> getAddresses() { in getAddresses() method in EquivalentAddressGroup
|
| D | LoadBalancer.java | 629 public EquivalentAddressGroup getAddresses() { in getAddresses() method in LoadBalancer.Subchannel
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | InternalSubchannel.java | 747 if (addressIndex >= group.getAddresses().size()) {
759 return addressGroups.get(groupIndex).getAddresses().get(addressIndex);
780 int j = group.getAddresses().indexOf(needle);
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 225 when(subchannel.getAddresses()).thenReturn(eag); in setUp()
808 grpclbResolutionList2.get(0).getAddresses().get(0), in grpclbUpdatedAddresses_avoidsReconnect()
809 grpclbResolutionList2.get(2).getAddresses().get(0)), in grpclbUpdatedAddresses_avoidsReconnect()
882 subchannel1.getAddresses()); in grpclbWorking()
885 subchannel2.getAddresses()); in grpclbWorking()
967 subchannel3.getAddresses()); in grpclbWorking()
1128 resolutionList.get(0).getAddresses().get(0), in subtestGrpclbFallbackInitialTimeout()
1129 resolutionList.get(1).getAddresses().get(0)), in subtestGrpclbFallbackInitialTimeout()
|
| D | CachedSubchannelPoolTest.java | 83 when(subchannel.getAddresses()).thenReturn(eag); in setUp()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 198 if (subchannels.get(subchannel.getAddresses()) != subchannel) { in handleSubchannelState()
292 addrs.add(new EquivalentAddressGroup(group.getAddresses())); in stripAttrs()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplIdlenessTest.java | 330 List<SocketAddress> changedList = new ArrayList<>(servers.get(0).getAddresses()); in updateSubchannelAddresses_existingAddressDoesNotConnect()
420 List<SocketAddress> changedList = new ArrayList<>(servers.get(0).getAddresses()); in updateOobChannelAddresses_existingAddressDoesNotConnect()
|
| D | DnsNameResolverTest.java | 517 assertThat(eag.getAddresses()).hasSize(1); in doNotResolveWhenProxyDetected()
519 ProxySocketAddress socketAddress = (ProxySocketAddress) eag.getAddresses().get(0); in doNotResolveWhenProxyDetected()
789 (InetSocketAddress) Iterables.getOnlyElement(addrGroup.getAddresses()); in assertAnswerMatches()
|
| D | ManagedChannelImplTest.java | 1060 assertSame(addressGroup, sub1.getAddresses()); in subchannels()
1061 assertSame(addressGroup, sub2.getAddresses()); in subchannels()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 119 when(sc.getAddresses()).thenReturn(eag); in setUp()
679 newServers.remove(sc2.getAddresses()); in stickiness_oneSubchannelShutdown()
|