| /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/core/src/main/java/io/grpc/util/ |
| D | ForwardingLoadBalancerHelper.java | 61 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in createOobChannel() argument
62 return delegate().createOobChannel(eag, authority); in createOobChannel()
66 public void updateOobChannelAddresses(ManagedChannel channel, EquivalentAddressGroup eag) { in updateOobChannelAddresses() argument
67 delegate().updateOobChannelAddresses(channel, eag); in updateOobChannelAddresses()
|
| /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 | 240 for (EquivalentAddressGroup eag : fallbackBackendList) { in useFallbackBackends()
242 newBackendAddrList.add(new BackendAddressGroup(eag, null)); in useFallbackBackends()
351 EquivalentAddressGroup eag = backendAddr.getAddresses(); in useRoundRobinLists() local
352 Subchannel subchannel = newSubchannelMap.get(eag); in useRoundRobinLists()
354 subchannel = subchannels.get(eag); in useRoundRobinLists()
361 subchannel = subchannelPool.takeOrCreateSubchannel(eag, subchannelAttrs); in useRoundRobinLists()
364 newSubchannelMap.put(eag, subchannel); in useRoundRobinLists()
378 EquivalentAddressGroup eag = entry.getKey(); in useRoundRobinLists() local
379 if (!newSubchannelMap.containsKey(eag)) { in useRoundRobinLists()
591 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 | 535 public abstract ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority); in createOobChannel() argument
546 public void updateOobChannelAddresses(ManagedChannel channel, EquivalentAddressGroup eag) { in updateOobChannelAddresses() argument
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 288 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in channelTracing_lbPolicyChanged()
390 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in createOobChannel() argument
391 return delegate().createOobChannel(eag, authority); in createOobChannel()
|
| D | DnsNameResolverTest.java | 361 EquivalentAddressGroup eag = result.get(0); in doNotResolveWhenProxyDetected() local
362 assertThat(eag.getAddresses()).hasSize(1); in doNotResolveWhenProxyDetected()
364 ProxySocketAddress socketAddress = (ProxySocketAddress) eag.getAddresses().get(0); in doNotResolveWhenProxyDetected()
|
| /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 | 1223 public void updateOobChannelAddresses(ManagedChannel channel, EquivalentAddressGroup eag) { in updateOobChannelAddresses() argument
1226 ((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 | 222 EquivalentAddressGroup eag = (EquivalentAddressGroup) invocation.getArguments()[0]; in setUp()
224 when(subchannel.getAddresses()).thenReturn(eag); in setUp()
743 EquivalentAddressGroup eag = resolvedServers.get(0); in nameResolutionFailsThenRecoverToGrpclb() local
748 verify(helper).createOobChannel(eq(eag), eq(lbAuthority(0))); in nameResolutionFailsThenRecoverToGrpclb()
1558 EquivalentAddressGroup eag = in createResolvedServerAddresses() local
1562 list.add(eag); in createResolvedServerAddresses()
|
| /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()
|
| /external/one-true-awk/testdir/ |
| D | test.data | 47 1933 eag
|