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 | 158 private final EquivalentAddressGroup addressGroup = new EquivalentAddressGroup(socketAddress); field in ManagedChannelImplTest 346 (AbstractSubchannel) helper.createSubchannel(addressGroup, Attributes.EMPTY); in channelzMembership_subchannel() 377 OobChannel oob = (OobChannel) helper.createOobChannel(addressGroup, AUTHORITY); in channelzMembership_oob() 438 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown() 569 eq(Arrays.asList(addressGroup)), eq(Attributes.EMPTY)); in noMoreCallbackAfterLoadBalancerShutdown() 571 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown() 572 Subchannel subchannel2 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown() 637 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in callOptionsExecutor() 850 EquivalentAddressGroup addressGroup = new EquivalentAddressGroup(resolvedAddrs); in firstResolvedServerFailedToConnect() local 852 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 | 1151 public ManagedChannel createOobChannel(EquivalentAddressGroup addressGroup, String authority) { in createOobChannel() argument 1173 Collections.singletonList(addressGroup), in createOobChannel()
|