Runnablepublic class I2PTunnelOutproxyRunner extends I2PAppThread
I2PThread.OOMEventListenerThread.State, Thread.UncaughtExceptionHandler| Modifier and Type | Field | Description |
|---|---|---|
protected Log |
_log |
|
(package private) boolean |
finished |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY| Constructor | Description |
|---|---|
I2PTunnelOutproxyRunner(Socket s,
Socket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
I2PTunnelRunner.FailCallback onTimeout) |
Does NOT start itself.
|
| Modifier and Type | Method | 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, removeOOMEventThreadListeneraddOOMEventListener, removeOOMEventListener, startequals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitactiveCount, 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, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yieldprotected 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
IOExceptionprotected OutputStream getSocketOut() throws IOException
IOExceptionprotected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, Socket s, Socket i2ps, Thread t1, Thread t2) throws InterruptedException
InterruptedExceptionpublic void errorOccurred()