Searched refs:pingFuture (Results 1 – 3 of 3) sorted by relevance
44 private ScheduledFuture<?> pingFuture; field in KeepAliveManager65 pingFuture = null;76 pingFuture = scheduler.schedule(175 checkState(pingFuture == null, "There should be no outstanding pingFuture"); in onDataReceived()176 pingFuture = scheduler.schedule(sendPing, keepAliveTimeInNanos, TimeUnit.NANOSECONDS); in onDataReceived()188 if (pingFuture == null) { in onTransportActive()189 pingFuture = scheduler.schedule( in onTransportActive()223 if (pingFuture != null) { in onTransportTermination()224 pingFuture.cancel(false); in onTransportTermination()225 pingFuture = null; in onTransportTermination()
225 ScheduledFuture<?> pingFuture = mock(ScheduledFuture.class); in transportGoesIdle() local226 doReturn(pingFuture) in transportGoesIdle()312 ScheduledFuture<?> pingFuture = mock(ScheduledFuture.class); in transportGoesIdleBeforePingSent() local313 doReturn(pingFuture) in transportGoesIdleBeforePingSent()331 ScheduledFuture<?> pingFuture = mock(ScheduledFuture.class); in transportShutsdownAfterPingScheduled() local332 doReturn(pingFuture) in transportShutsdownAfterPingScheduled()341 verify(pingFuture).cancel(isA(Boolean.class)); in transportShutsdownAfterPingScheduled()
803 ChannelFuture pingFuture = encoder().writePing( in ping() local807 pingFuture.addListener(new ChannelFutureListener() { in ping()852 Future<?> pingFuture; field in NettyServerHandler.GracefulShutdown871 pingFuture = ctx.executor().schedule( in start()890 checkNotNull(pingFuture, "pingFuture"); in secondGoAwayAndClose()891 pingFuture.cancel(false); in secondGoAwayAndClose()