Searched refs:subchannelPool (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancer.java | 48 private final SubchannelPool subchannelPool; field in GrpclbLoadBalancer
59 SubchannelPool subchannelPool, in GrpclbLoadBalancer() argument
68 this.subchannelPool = checkNotNull(subchannelPool, "subchannelPool"); in GrpclbLoadBalancer()
69 this.subchannelPool.init(helper, timerService); in GrpclbLoadBalancer()
71 new GrpclbState(helper, subchannelPool, time, timerService, backoffPolicyProvider, logId); in GrpclbLoadBalancer()
|
| D | GrpclbState.java | 111 private final SubchannelPool subchannelPool; field in GrpclbState
151 SubchannelPool subchannelPool, in GrpclbState() argument
157 this.subchannelPool = checkNotNull(subchannelPool, "subchannelPool"); in GrpclbState()
315 subchannelPool.returnSubchannel(subchannel); in shutdown()
318 subchannelPool.clear(); in shutdown()
364 subchannel = subchannelPool.takeOrCreateSubchannel(eag, subchannelAttrs); in useRoundRobinLists()
383 subchannelPool.returnSubchannel(entry.getValue()); in useRoundRobinLists()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 143 private SubchannelPool subchannelPool; field in GrpclbLoadBalancerTest
231 }).when(subchannelPool).takeOrCreateSubchannel( in setUp()
257 subchannelPool, in setUp()
261 verify(subchannelPool).init(same(helper), same(timerService)); in setUp()
282 verify(subchannelPool).returnSubchannel(same(subchannel)); in tearDown()
411 InOrder helperInOrder = inOrder(helper, subchannelPool); in loadReporting()
594 helperInOrder.verify(subchannelPool, never()).takeOrCreateSubchannel( in loadReporting()
755 InOrder inOrder = inOrder(helper, subchannelPool); in grpclbThenNameResolutionFails()
786 inOrder.verify(subchannelPool).takeOrCreateSubchannel( in grpclbThenNameResolutionFails()
789 inOrder.verify(subchannelPool).takeOrCreateSubchannel( in grpclbThenNameResolutionFails()
[all …]
|