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
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 net.i2p.util.I2PThread
I2PThread.OOMEventListener
Nested classes/interfaces inherited from class java.lang.Thread
Thread.BuilderPREVIEW, Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
ConstructorDescriptionI2PTunnelOutproxyRunner
(Socket s, Socket i2ps, Object slock, byte[] initialI2PData, byte[] initialSocketData, I2PTunnelRunner.FailCallback onTimeout) Does NOT start itself. -
Method Summary
Modifier and TypeMethodDescriptionprotected void
close
(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, Socket s, Socket i2ps, Thread t1, Thread t2) void
long
Deprecated.unusedprotected InputStream
protected OutputStream
long
When this runner started up transferring databoolean
Deprecated.unusedvoid
run()
Methods inherited from class net.i2p.util.I2PAppThread
addOOMEventThreadListener, fireOOM, removeOOMEventThreadListener
Methods inherited from class net.i2p.util.I2PThread
addOOMEventListener, removeOOMEventListener, start
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, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, startVirtualThread, stop, suspend, threadId, toString, yield
-
Field Details
-
_log
-
finished
volatile boolean finished
-
-
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()
-