Package net.i2p.i2ptunnel
Class I2PTunnelOutproxyRunner
java.lang.Object
java.lang.Thread
net.i2p.util.I2PThread
net.i2p.util.I2PAppThread
net.i2p.i2ptunnel.I2PTunnelOutproxyRunner
- All Implemented Interfaces:
Runnable
public class I2PTunnelOutproxyRunner extends I2PAppThread
Like I2PTunnelRunner but socket-to-socket
Warning - not maintained as a stable API for external use.
- Since:
- 0.9.11
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler -
Field Summary
-
Constructor Summary
Constructors Constructor Description I2PTunnelOutproxyRunner(Socket s, Socket i2ps, Object slock, byte[] initialI2PData, byte[] initialSocketData, I2PTunnelRunner.FailCallback onTimeout)Does NOT start itself. -
Method Summary
Modifier and Type Method Description protected voidclose(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, Socket s, Socket i2ps, Thread t1, Thread t2)voiderrorOccurred()longgetLastActivityOn()Deprecated.unusedprotected InputStreamgetSocketIn()protected OutputStreamgetSocketOut()longgetStartedOn()When this runner started up transferring databooleanisFinished()Deprecated.unusedvoidrun()Methods inherited from class net.i2p.util.I2PAppThread
addOOMEventThreadListener, fireOOM, removeOOMEventThreadListenerMethods inherited from class net.i2p.util.I2PThread
addOOMEventListener, removeOOMEventListener, startMethods 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, stop, suspend, toString, yield
-
Field Details
-
Constructor Details
-
I2PTunnelOutproxyRunner
public I2PTunnelOutproxyRunner(Socket s, Socket i2ps, Object slock, byte[] initialI2PData, byte[] initialSocketData, I2PTunnelRunner.FailCallback onTimeout)Does NOT start itself. Caller must call start().- Parameters:
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.
-
-
Method Details
-
isFinished
Deprecated.unusedhave we closed at least one (if not both) of the streams [aka we're done running the streams]? -
getLastActivityOn
Deprecated.unusedWhen was the last data for this runner sent or received? As of 0.9.20, returns -1 always!- Returns:
- date (ms since the epoch), or -1 if no data has been transferred yet
-
getStartedOn
public long getStartedOn()When this runner started up transferring data -
getSocketIn
- Throws:
IOException
-
getSocketOut
- Throws:
IOException
-
run
public void run() -
close
protected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, Socket s, Socket i2ps, Thread t1, Thread t2) throws InterruptedException- Throws:
InterruptedException
-
errorOccurred
public void errorOccurred()
-