| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | LoadBalancerTest.java | 41 private final EquivalentAddressGroup eag = new EquivalentAddressGroup(new SocketAddress() {}); field in LoadBalancerTest
131 assertThat(addrsIn.get(0)).isSameAs(eag); in helper_createSubchannel_delegates()
139 assertThat(helper.createSubchannel(eag, attrs)).isSameAs(subchannel); in helper_createSubchannel_delegates()
145 new NoopHelper().createSubchannel(Arrays.asList(eag), attrs); in helper_createSubchannelList_throws()
158 assertThat(addrsIn.get(0)).isSameAs(eag); in helper_updateSubchannelAddresses_delegates()
164 helper.updateSubchannelAddresses(emptySubchannel, eag); in helper_updateSubchannelAddresses_delegates()
170 new NoopHelper().updateSubchannelAddresses(null, Arrays.asList(eag)); in helper_updateSubchannelAddressesList_throws()
180 return Arrays.asList(eag); in subchannel_getAddresses_delegates()
185 assertThat(subchannel.getAddresses()).isEqualTo(eag); in subchannel_getAddresses_delegates()
197 return Arrays.asList(eag, eag); in subchannel_getAddresses_throwsOnTwoAddrs()
[all …]
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | CachedSubchannelPool.java | 54 EquivalentAddressGroup eag, Attributes defaultAttributes) { in takeOrCreateSubchannel() argument
55 CacheEntry entry = cache.remove(eag); in takeOrCreateSubchannel()
58 subchannel = helper.createSubchannel(eag, defaultAttributes); in takeOrCreateSubchannel()
|
| D | GrpclbState.java | 243 for (EquivalentAddressGroup eag : fallbackBackendList) { in useFallbackBackends()
245 newBackendAddrList.add(new BackendAddressGroup(eag, null)); in useFallbackBackends()
354 EquivalentAddressGroup eag = backendAddr.getAddresses(); in useRoundRobinLists() local
355 Subchannel subchannel = newSubchannelMap.get(eag); in useRoundRobinLists()
357 subchannel = subchannels.get(eag); in useRoundRobinLists()
364 subchannel = subchannelPool.takeOrCreateSubchannel(eag, subchannelAttrs); in useRoundRobinLists()
367 newSubchannelMap.put(eag, subchannel); in useRoundRobinLists()
381 EquivalentAddressGroup eag = entry.getKey(); in useRoundRobinLists() local
382 if (!newSubchannelMap.containsKey(eag)) { in useRoundRobinLists()
597 EquivalentAddressGroup eag = in handleResponse() local
[all …]
|
| D | SubchannelPool.java | 43 Subchannel takeOrCreateSubchannel(EquivalentAddressGroup eag, Attributes defaultAttributes); in takeOrCreateSubchannel() argument
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 529 public abstract ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority); in createOobChannel() argument
540 public void updateOobChannelAddresses(ManagedChannel channel, EquivalentAddressGroup eag) { in updateOobChannelAddresses() argument
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | OobChannel.java | 188 void updateAddresses(EquivalentAddressGroup eag) { in updateAddresses() argument
189 subchannel.updateAddresses(Collections.singletonList(eag)); in updateAddresses()
|
| D | ManagedChannelImpl.java | 1224 public void updateOobChannelAddresses(ManagedChannel channel, EquivalentAddressGroup eag) { in updateOobChannelAddresses() argument
1227 ((OobChannel) channel).updateAddresses(eag); in updateOobChannelAddresses()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | CachedSubchannelPoolTest.java | 81 EquivalentAddressGroup eag = (EquivalentAddressGroup) invocation.getArguments()[0]; in setUp()
83 when(subchannel.getAddresses()).thenReturn(eag); in setUp()
|
| D | GrpclbLoadBalancerTest.java | 223 EquivalentAddressGroup eag = (EquivalentAddressGroup) invocation.getArguments()[0]; in setUp()
225 when(subchannel.getAddresses()).thenReturn(eag); in setUp()
744 EquivalentAddressGroup eag = resolvedServers.get(0); in nameResolutionFailsThenRecoverToGrpclb() local
749 verify(helper).createOobChannel(eq(eag), eq(lbAuthority(0))); in nameResolutionFailsThenRecoverToGrpclb()
1527 EquivalentAddressGroup eag = in createResolvedServerAddresses() local
1531 list.add(eag); in createResolvedServerAddresses()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 312 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in createOobChannel() argument
313 return delegate().createOobChannel(eag, authority); in createOobChannel()
|
| D | DnsNameResolverTest.java | 516 EquivalentAddressGroup eag = result.get(0); in doNotResolveWhenProxyDetected() local
517 assertThat(eag.getAddresses()).hasSize(1); in doNotResolveWhenProxyDetected()
519 ProxySocketAddress socketAddress = (ProxySocketAddress) eag.getAddresses().get(0); in doNotResolveWhenProxyDetected()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 116 EquivalentAddressGroup eag = new EquivalentAddressGroup(addr); in setUp() local
117 servers.add(eag); in setUp()
119 when(sc.getAddresses()).thenReturn(eag); in setUp()
120 subchannels.put(eag, sc); in setUp()
|