Package net.schmizz.keepalive
Class KeepAliveRunner
- java.lang.Object
-
- java.lang.Thread
-
- net.schmizz.keepalive.KeepAlive
-
- net.schmizz.keepalive.KeepAliveRunner
-
- All Implemented Interfaces:
java.lang.Runnable
public class KeepAliveRunner extends KeepAlive
-
-
Field Summary
Fields Modifier and Type Field Description private int
maxAliveCount
The max number of keep-alives that should be unanswered before killing the connection.private java.util.Queue<Promise<SSHPacket,ConnectionException>>
queue
The queue of promises.-
Fields inherited from class net.schmizz.keepalive.KeepAlive
conn, keepAliveInterval, log
-
-
Constructor Summary
Constructors Constructor Description KeepAliveRunner(ConnectionImpl conn)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
checkMaxReached(java.util.Queue<Promise<SSHPacket,ConnectionException>> queue)
protected void
doKeepAlive()
private void
emptyQueue(java.util.Queue<Promise<SSHPacket,ConnectionException>> queue)
int
getMaxAliveCount()
void
setMaxAliveCount(int maxAliveCount)
-
Methods inherited from class net.schmizz.keepalive.KeepAlive
getKeepAliveInterval, isEnabled, run, setKeepAliveInterval
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
maxAliveCount
private int maxAliveCount
The max number of keep-alives that should be unanswered before killing the connection.
-
queue
private final java.util.Queue<Promise<SSHPacket,ConnectionException>> queue
The queue of promises.
-
-
Constructor Detail
-
KeepAliveRunner
KeepAliveRunner(ConnectionImpl conn)
-
-
Method Detail
-
getMaxAliveCount
public int getMaxAliveCount()
-
setMaxAliveCount
public void setMaxAliveCount(int maxAliveCount)
-
doKeepAlive
protected void doKeepAlive() throws TransportException, ConnectionException
- Specified by:
doKeepAlive
in classKeepAlive
- Throws:
TransportException
ConnectionException
-
checkMaxReached
private void checkMaxReached(java.util.Queue<Promise<SSHPacket,ConnectionException>> queue) throws ConnectionException
- Throws:
ConnectionException
-
emptyQueue
private void emptyQueue(java.util.Queue<Promise<SSHPacket,ConnectionException>> queue)
-
-