Home
last modified time | relevance | path

Searched refs:reconnectTask (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DInternalSubchannel.java117 private ScheduledFuture<?> reconnectTask; field in InternalSubchannel
220 Preconditions.checkState(reconnectTask == null, "Should have no reconnectTask scheduled"); in startNewTransport()
267 reconnectTask = null; in scheduleBackoff()
293 Preconditions.checkState(reconnectTask == null, "previous reconnectTask is not done"); in scheduleBackoff()
295 reconnectTask = scheduledExecutor.schedule( in scheduleBackoff()
482 if (reconnectTask != null) { in cancelReconnectTask()
483 reconnectTask.cancel(false); in cancelReconnectTask()
485 reconnectTask = null; in cancelReconnectTask()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DInternalSubchannelTest.java719 FakeClock.ScheduledTask reconnectTask = null; in shutdownBeforeTransportCreated() local
722 assertNull("There shouldn't be more than one reconnectTask", reconnectTask); in shutdownBeforeTransportCreated()
724 reconnectTask = task; in shutdownBeforeTransportCreated()
727 assertNotNull("There should be at least one reconnectTask", reconnectTask); in shutdownBeforeTransportCreated()
731 assertTrue(reconnectTask.isCancelled()); in shutdownBeforeTransportCreated()
737 reconnectTask.command.run(); in shutdownBeforeTransportCreated()
930 FakeClock.ScheduledTask reconnectTask = null; in resetConnectBackoff() local
933 assertNull("There shouldn't be more than one reconnectTask", reconnectTask); in resetConnectBackoff()
935 reconnectTask = task; in resetConnectBackoff()
938 assertNotNull("There should be at least one reconnectTask", reconnectTask); in resetConnectBackoff()
[all …]