Home
last modified time | relevance | path

Searched refs:timerService (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbLoadBalancer.java52 private ScheduledExecutorService timerService; field in GrpclbLoadBalancer
65 this.timerService = checkNotNull(timerServicePool.getObject(), "timerService"); in GrpclbLoadBalancer()
69 this.subchannelPool.init(helper, timerService); in GrpclbLoadBalancer()
71 new GrpclbState(helper, subchannelPool, time, timerService, backoffPolicyProvider, logId); in GrpclbLoadBalancer()
116 timerService = timerServicePool.returnObject(timerService); in shutdown()
DCachedSubchannelPool.java41 private ScheduledExecutorService timerService; field in CachedSubchannelPool
47 public void init(Helper helper, ScheduledExecutorService timerService) { in init() argument
49 this.timerService = checkNotNull(timerService, "timerService"); in init()
80 timerService.schedule( in returnSubchannel()
DGrpclbState.java113 private final ScheduledExecutorService timerService; field in GrpclbState
153 ScheduledExecutorService timerService, in GrpclbState() argument
159 this.timerService = checkNotNull(timerService, "timerService"); in GrpclbState()
417 scheduledFuture = timerService.schedule(this, FALLBACK_TIMEOUT_MS, TimeUnit.MILLISECONDS); in schedule()
443 scheduledFuture = timerService.schedule(this, delayNanos, TimeUnit.NANOSECONDS); in schedule()
536 loadReportFuture = timerService.schedule( in scheduleNextLoadReport()
DSubchannelPool.java36 void init(Helper helper, ScheduledExecutorService timerService); in init() argument
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessChannelBuilder.java159 private final ScheduledExecutorService timerService; field in InProcessChannelBuilder.InProcessClientTransportFactory
167 timerService = useSharedTimer in InProcessClientTransportFactory()
182 return timerService; in getScheduledExecutorService()
192 SharedResourceHolder.release(GrpcUtil.TIMER_SERVICE, timerService); in close()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java250 ScheduledExecutorService timerService = fakeClock.getScheduledExecutorService(); in setUp() local
251 when(timerServicePool.getObject()).thenReturn(timerService); in setUp()
261 verify(subchannelPool).init(same(helper), same(timerService)); in setUp()