Searched refs:addressGroup (Results 1 – 4 of 4) sorted by relevance
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | ManagedChannelImplTest.java | 157 private final EquivalentAddressGroup addressGroup = new EquivalentAddressGroup(socketAddress); field in ManagedChannelImplTest 345 (AbstractSubchannel) helper.createSubchannel(addressGroup, Attributes.EMPTY); in channelzMembership_subchannel() 376 OobChannel oob = (OobChannel) helper.createOobChannel(addressGroup, AUTHORITY); in channelzMembership_oob() 437 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown() 568 eq(Arrays.asList(addressGroup)), eq(Attributes.EMPTY)); in noMoreCallbackAfterLoadBalancerShutdown() 570 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown() 571 Subchannel subchannel2 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown() 636 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in callOptionsExecutor() 849 EquivalentAddressGroup addressGroup = new EquivalentAddressGroup(resolvedAddrs); in firstResolvedServerFailedToConnect() local 851 eq(Arrays.asList(addressGroup)), eq(Attributes.EMPTY)); in firstResolvedServerFailedToConnect() [all …]
|
D | ManagedChannelImplIdlenessTest.java | 252 final EquivalentAddressGroup addressGroup = servers.get(1); in realTransportsHoldsOffIdleness() local 265 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in realTransportsHoldsOffIdleness()
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
D | RoundRobinLoadBalancerFactory.java | 155 for (EquivalentAddressGroup addressGroup : addedAddrs) { in handleResolvedAddressGroups() 172 helper.createSubchannel(addressGroup, subchannelAttrs.build()), "subchannel"); in handleResolvedAddressGroups() 176 subchannels.put(addressGroup, subchannel); in handleResolvedAddressGroups() 181 for (EquivalentAddressGroup addressGroup : removedAddrs) { in handleResolvedAddressGroups() 182 Subchannel subchannel = subchannels.remove(addressGroup); in handleResolvedAddressGroups()
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
D | ManagedChannelImpl.java | 1146 public ManagedChannel createOobChannel(EquivalentAddressGroup addressGroup, String authority) { in createOobChannel() argument 1184 Collections.singletonList(addressGroup), in createOobChannel()
|