| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | ForwardingLoadBalancerHelper.java | 39 public Subchannel createSubchannel(EquivalentAddressGroup addrs, Attributes attrs) { in createSubchannel() method in ForwardingLoadBalancerHelper
40 return delegate().createSubchannel(addrs, attrs); in createSubchannel()
44 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel() method in ForwardingLoadBalancerHelper
45 return delegate().createSubchannel(addrs, attrs); in createSubchannel()
|
| D | RoundRobinLoadBalancerFactory.java | 172 helper.createSubchannel(addressGroup, subchannelAttrs.build()), "subchannel"); in handleResolvedAddressGroups()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | CachedSubchannelPoolTest.java | 88 }).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()
|
| D | GrpclbLoadBalancerTest.java | 287 .createSubchannel(any(EquivalentAddressGroup.class), any(Attributes.class)); in tearDown()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 88 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()
|
| D | LoadBalancerTest.java | 129 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/ |
| D | LoadBalancer.java | 470 public Subchannel createSubchannel(EquivalentAddressGroup addrs, Attributes attrs) { in createSubchannel() method in LoadBalancer.Helper
472 return createSubchannel(Collections.singletonList(addrs), attrs); in createSubchannel()
487 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel() method in LoadBalancer.Helper
|
| D | PickFirstBalancerFactory.java | 69 subchannel = helper.createSubchannel(servers, Attributes.EMPTY); in handleResolvedAddressGroups()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 120 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_keepOldBalancer()
154 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_shutsDownOldBalancer()
283 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in channelTracing_lbPolicyChanged()
385 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
386 return delegate().createSubchannel(addrs, attrs); in createSubchannel()
|
| D | ManagedChannelImplTest.java | 345 (AbstractSubchannel) helper.createSubchannel(addressGroup, Attributes.EMPTY); in channelzMembership_subchannel()
437 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown()
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()
852 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in firstResolvedServerFailedToConnect()
997 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in allServersFailedToConnect()
1053 Subchannel sub1 = helper.createSubchannel(addressGroup, attrs1); in subchannels()
1054 Subchannel sub2 = helper.createSubchannel(addressGroup, attrs2); in subchannels()
1109 Subchannel sub1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subchannelsWhenChannelShutdownNow()
[all …]
|
| D | ManagedChannelImplIdlenessTest.java | 265 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/ |
| D | RoundRobinLoadBalancerTest.java | 123 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/ |
| D | CachedSubchannelPool.java | 58 subchannel = helper.createSubchannel(eag, defaultAttributes); in takeOrCreateSubchannel()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelImpl.java | 1014 public AbstractSubchannel createSubchannel( in createSubchannel() method in ManagedChannelImpl.LbHelperImpl
|