Searched refs:shutdownFuture (Results 1 – 3 of 3) sorted by relevance
42 private ScheduledFuture<?> shutdownFuture; field in MaxConnectionIdleManager75 shutdownFuture = scheduler.schedule( in start()82 shutdownFuture = null; in start()87 shutdownFuture = in start()106 if (shutdownFuture == null) { in onTransportIdle()109 if (shutdownFuture.isDone()) { in onTransportIdle()111 shutdownFuture = scheduler in onTransportIdle()120 if (shutdownFuture != null) { in onTransportTermination()121 shutdownFuture.cancel(false); in onTransportTermination()122 shutdownFuture = null; in onTransportTermination()
81 ScheduledFuture<?> shutdownFuture = mock(ScheduledFuture.class); in sendKeepAlivePings() local82 doReturn(shutdownFuture) in sendKeepAlivePings()100 verify(shutdownFuture).cancel(isA(Boolean.class)); in sendKeepAlivePings()176 ScheduledFuture<?> shutdownFuture = mock(ScheduledFuture.class); in onTransportTerminationCancelsShutdownFuture() local177 doReturn(shutdownFuture) in onTransportTerminationCancelsShutdownFuture()186 verify(shutdownFuture).cancel(isA(Boolean.class)); in onTransportTerminationCancelsShutdownFuture()198 ScheduledFuture<?> shutdownFuture = mock(ScheduledFuture.class); in keepAlivePingTimesOut() local199 doReturn(shutdownFuture) in keepAlivePingTimesOut()286 ScheduledFuture<?> shutdownFuture = mock(ScheduledFuture.class); in transportGoesIdleAfterPingSent() local287 doReturn(shutdownFuture) in transportGoesIdleAfterPingSent()[all …]
43 private ScheduledFuture<?> shutdownFuture; field in KeepAliveManager72 shutdownFuture = scheduler.schedule(shutdown, keepAliveTimeoutInNanos,165 if (shutdownFuture != null) { in onDataReceived()166 shutdownFuture.cancel(false); in onDataReceived()220 if (shutdownFuture != null) { in onTransportTermination()221 shutdownFuture.cancel(false); in onTransportTermination()