public class I2PTunnelOutproxyRunner extends I2PAppThread
I2PThread.OOMEventListener
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected Log |
_log |
(package private) boolean |
finished |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
I2PTunnelOutproxyRunner(Socket s,
Socket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
I2PTunnelRunner.FailCallback onTimeout)
Does NOT start itself.
|
Modifier and Type | Method and Description |
---|---|
protected void |
close(OutputStream out,
InputStream in,
OutputStream i2pout,
InputStream i2pin,
Socket s,
Socket i2ps,
Thread t1,
Thread t2) |
void |
errorOccurred() |
long |
getLastActivityOn()
Deprecated.
unused
|
protected InputStream |
getSocketIn() |
protected OutputStream |
getSocketOut() |
long |
getStartedOn()
When this runner started up transferring data
|
boolean |
isFinished()
Deprecated.
unused
|
void |
run() |
addOOMEventThreadListener, fireOOM, removeOOMEventThreadListener
addOOMEventListener, removeOOMEventListener, start
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield
protected final Log _log
volatile boolean finished
public I2PTunnelOutproxyRunner(Socket s, Socket i2ps, Object slock, byte[] initialI2PData, byte[] initialSocketData, I2PTunnelRunner.FailCallback onTimeout)
slock
- the socket lock, non-nullinitialI2PData
- may be nullonTimeout
- May be null. If non-null and no data (except initial data) was received,
it will be run before closing s.@Deprecated public boolean isFinished()
@Deprecated public long getLastActivityOn()
public long getStartedOn()
protected InputStream getSocketIn() throws IOException
IOException
protected OutputStream getSocketOut() throws IOException
IOException
protected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, Socket s, Socket i2ps, Thread t1, Thread t2) throws InterruptedException
InterruptedException
public void errorOccurred()