public class I2PTunnelOutproxyRunner extends I2PAppThread
I2PThread.OOMEventListenerThread.State, Thread.UncaughtExceptionHandler| Modifier and Type | Field and Description |
|---|---|
protected Log | _log |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY| Constructor and Description |
|---|
I2PTunnelOutproxyRunner(Socket s,
Socket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
I2PTunnelRunner.FailCallback onTimeout)Constructs the OutproxyRunner
Does not start itself. |
| Modifier and Type | Method and Description |
|---|---|
void | errorOccurred()Called to signal an error occurred and notify waiting threads. |
protected InputStream | getSocketIn()Get the input stream from the external socket. |
protected OutputStream | getSocketOut()Get the output stream from the external socket. |
long | getStartedOn()Get when this runner started transferring data |
void | run()Start forwarding data bidirectionally between the external socket
and the I2P socket. |
addOOMEventThreadListener, fireOOM, removeOOMEventThreadListeneraddOOMEventListener, removeOOMEventListener, startactiveCount, 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, yieldprotected final Log _log
public I2PTunnelOutproxyRunner(Socket s, Socket i2ps, Object slock, byte[] initialI2PData, byte[] initialSocketData, I2PTunnelRunner.FailCallback onTimeout)
s - external socket connectioni2ps - I2P socket connectionslock - socket lock object, non-nullinitialI2PData - initial data to send to I2P side, nullableinitialSocketData - initial data to send to socket side, nullableonTimeout - fail callback if no data received (except initial), nullablepublic void errorOccurred()
protected InputStream getSocketIn() throws IOException
IOException - if an I/O error occursprotected OutputStream getSocketOut() throws IOException
IOException - if an I/O error occurspublic long getStartedOn()
public void run()