Home
last modified time | relevance | path

Searched refs:createSubchannel (Results 1 – 13 of 13) sorted by relevance

/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java88 }).when(helper).createSubchannel(any(EquivalentAddressGroup.class), any(Attributes.class)); in setUp()
112 verify(helper).createSubchannel(same(EAG1), same(ATTRS1)); in subchannelExpireAfterReturned()
117 verify(helper).createSubchannel(same(EAG2), same(ATTRS2)); in subchannelExpireAfterReturned()
143 verify(helper).createSubchannel(same(EAG1), same(ATTRS1)); in subchannelReused()
148 verify(helper).createSubchannel(same(EAG2), same(ATTRS2)); in subchannelReused()
170 verify(helper, times(2)).createSubchannel(same(EAG2), same(ATTRS2)); in subchannelReused()
DGrpclbLoadBalancerTest.java288 .createSubchannel(any(EquivalentAddressGroup.class), any(Attributes.class)); in tearDown()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java88 when(mockHelper.createSubchannel( in setUp()
105 verify(mockHelper).createSubchannel(eq(servers), attrsCaptor.capture()); in pickAfterResolved()
122 verify(mockHelper).createSubchannel(anyListOf(EquivalentAddressGroup.class), in pickAfterResolvedAndUnchanged()
142 inOrder.verify(mockHelper).createSubchannel(eq(servers), any(Attributes.class)); in pickAfterResolvedAndChanged()
209 inOrder.verify(mockHelper).createSubchannel(eq(servers), eq(Attributes.EMPTY)); in nameResolutionSuccessAfterError()
DLoadBalancerTest.java129 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrsIn, Attributes attrsIn) { in helper_createSubchannel_delegates() method in LoadBalancerTest.OverrideCreateSubchannel
139 assertThat(helper.createSubchannel(eag, attrs)).isSameAs(subchannel); in helper_createSubchannel_delegates()
145 new NoopHelper().createSubchannel(Arrays.asList(eag), attrs); in helper_createSubchannelList_throws()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DLoadBalancer.java464 public Subchannel createSubchannel(EquivalentAddressGroup addrs, Attributes attrs) { in createSubchannel() method in LoadBalancer.Helper
466 return createSubchannel(Collections.singletonList(addrs), attrs); in createSubchannel()
481 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel() method in LoadBalancer.Helper
DPickFirstBalancerFactory.java69 subchannel = helper.createSubchannel(servers, Attributes.EMPTY); in handleResolvedAddressGroups()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java116 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_keepOldBalancer()
150 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_shutsDownOldBalancer()
307 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
308 return delegate().createSubchannel(addrs, attrs); in createSubchannel()
DManagedChannelImplTest.java346 (AbstractSubchannel) helper.createSubchannel(addressGroup, Attributes.EMPTY); in channelzMembership_subchannel()
438 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown()
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()
853 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in firstResolvedServerFailedToConnect()
998 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in allServersFailedToConnect()
1054 Subchannel sub1 = helper.createSubchannel(addressGroup, attrs1); in subchannels()
1055 Subchannel sub2 = helper.createSubchannel(addressGroup, attrs2); in subchannels()
1110 Subchannel sub1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subchannelsWhenChannelShutdownNow()
[all …]
DManagedChannelImplIdlenessTest.java265 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in realTransportsHoldsOffIdleness()
304 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_newAddressConnects()
324 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_existingAddressDoesNotConnect()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java123 when(mockHelper.createSubchannel(any(EquivalentAddressGroup.class), any(Attributes.class))) in setUp()
149 verify(mockHelper, times(3)).createSubchannel(eagCaptor.capture(), in pickAfterResolved()
200 }).when(mockHelper).createSubchannel(any(EquivalentAddressGroup.class), any(Attributes.class)); in pickAfterResolvedUpdatedHosts()
236 verify(mockHelper, times(3)).createSubchannel(any(EquivalentAddressGroup.class), in pickAfterResolvedUpdatedHosts()
285 verify(mockHelper, times(3)).createSubchannel(any(EquivalentAddressGroup.class), in pickAfterStateChange()
339 verify(mockHelper, times(3)).createSubchannel(any(EquivalentAddressGroup.class), in nameResolutionErrorWithActiveChannels()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DCachedSubchannelPool.java58 subchannel = helper.createSubchannel(eag, defaultAttributes); in takeOrCreateSubchannel()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java172 helper.createSubchannel(addressGroup, subchannelAttrs.build()), "subchannel"); in handleResolvedAddressGroups()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java1025 public AbstractSubchannel createSubchannel( in createSubchannel() method in ManagedChannelImpl.LbHelperImpl