| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| LoadBalancerTest.java | 41 private final EquivalentAddressGroup eag = new EquivalentAddressGroup(new SocketAddress() {}); field in class:LoadBalancerTest
131 assertThat(addrsIn.get(0)).isSameAs(eag);
139 assertThat(helper.createSubchannel(eag, attrs)).isSameAs(subchannel);
145 new NoopHelper().createSubchannel(Arrays.asList(eag), attrs);
158 assertThat(addrsIn.get(0)).isSameAs(eag);
164 helper.updateSubchannelAddresses(emptySubchannel, eag);
170 new NoopHelper().updateSubchannelAddresses(null, Arrays.asList(eag));
180 return Arrays.asList(eag);
185 assertThat(subchannel.getAddresses()).isEqualTo(eag);
196 // Doubling up eag is technically a bad idea, but nothing here care
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| DnsNameResolverTest.java | 516 EquivalentAddressGroup eag = result.get(0); local
517 assertThat(eag.getAddresses()).hasSize(1);
519 ProxySocketAddress socketAddress = (ProxySocketAddress) eag.getAddresses().get(0);
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| RoundRobinLoadBalancerTest.java | 116 EquivalentAddressGroup eag = new EquivalentAddressGroup(addr); local
117 servers.add(eag);
119 when(sc.getAddresses()).thenReturn(eag);
120 subchannels.put(eag, sc);
[all...] |
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| GrpclbState.java | 243 for (EquivalentAddressGroup eag : fallbackBackendList) {
245 newBackendAddrList.add(new BackendAddressGroup(eag, null));
354 EquivalentAddressGroup eag = backendAddr.getAddresses(); local
355 Subchannel subchannel = newSubchannelMap.get(eag);
357 subchannel = subchannels.get(eag);
364 subchannel = subchannelPool.takeOrCreateSubchannel(eag, subchannelAttrs);
367 newSubchannelMap.put(eag, subchannel);
381 EquivalentAddressGroup eag = entry.getKey(); local
382 if (!newSubchannelMap.containsKey(eag)) {
597 EquivalentAddressGroup eag local
[all...] |
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| GrpclbLoadBalancerTest.java | 223 EquivalentAddressGroup eag = (EquivalentAddressGroup) invocation.getArguments()[0];
225 when(subchannel.getAddresses()).thenReturn(eag);
744 EquivalentAddressGroup eag = resolvedServers.get(0); local
749 verify(helper).createOobChannel(eq(eag), eq(lbAuthority(0)));
1527 EquivalentAddressGroup eag = local
[all...] |
| /external/grpc-grpc-java/core/ |
| grpc-core-1.14.0.jar | |
