I2PSocket.SocketErrorListener
I2PTunnelHTTPClientRunner
public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErrorListener
修飾子とタイプ | クラス | 説明 |
---|---|---|
static interface |
I2PTunnelRunner.FailCallback |
For use in new constructor
|
I2PThread.OOMEventListener
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected Log |
_log |
|
(package private) static int |
MAX_PACKET_SIZE |
max bytes streamed in a packet - smaller ones might be filled
up to this size.
|
(package private) static int |
NETWORK_BUFFER_SIZE |
コンストラクタ | 説明 |
---|---|
I2PTunnelRunner(java.net.Socket s,
I2PSocket i2ps,
java.lang.Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
java.util.List<I2PSocket> sockList) |
推奨されていません。
use FailCallback constructor
|
I2PTunnelRunner(java.net.Socket s,
I2PSocket i2ps,
java.lang.Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
java.util.List<I2PSocket> sockList,
java.lang.Runnable onTimeout) |
推奨されていません。
use FailCallback constructor
|
I2PTunnelRunner(java.net.Socket s,
I2PSocket i2ps,
java.lang.Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
java.util.List<I2PSocket> sockList,
I2PTunnelRunner.FailCallback onFail) |
Recommended new constructor.
|
I2PTunnelRunner(java.net.Socket s,
I2PSocket i2ps,
java.lang.Object slock,
byte[] initialI2PData,
java.util.List<I2PSocket> sockList) |
推奨されていません。
use FailCallback constructor
|
I2PTunnelRunner(java.net.Socket s,
I2PSocket i2ps,
java.lang.Object slock,
byte[] initialI2PData,
java.util.List<I2PSocket> sockList,
java.lang.Runnable onTimeout) |
推奨されていません。
use FailCallback constructor
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
protected void |
close(java.io.OutputStream out,
java.io.InputStream in,
java.io.OutputStream i2pout,
java.io.InputStream i2pin,
java.net.Socket s,
I2PSocket i2ps,
java.lang.Thread t1,
java.lang.Thread t2) |
|
void |
errorOccurred() |
Deprecated, unimplemented in streaming, never called.
|
long |
getLastActivityOn() |
推奨されていません。
unused
|
protected java.io.InputStream |
getSocketIn() |
|
protected java.io.OutputStream |
getSocketOut() |
|
long |
getStartedOn() |
When this runner started up transferring data
|
boolean |
isFinished() |
推奨されていません。
unused
|
void |
run() |
addOOMEventThreadListener, fireOOM, removeOOMEventThreadListener
addOOMEventListener, removeOOMEventListener, start
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield
protected final Log _log
static int MAX_PACKET_SIZE
static final int NETWORK_BUFFER_SIZE
@Deprecated public I2PTunnelRunner(java.net.Socket s, I2PSocket i2ps, java.lang.Object slock, byte[] initialI2PData, java.util.List<I2PSocket> sockList)
slock
- the socket lock, non-nullinitialI2PData
- may be nullsockList
- may be null. Caller must add i2ps to the list! It will be removed here on completion.
Will synchronize on slock when removing.@Deprecated public I2PTunnelRunner(java.net.Socket s, I2PSocket i2ps, java.lang.Object slock, byte[] initialI2PData, byte[] initialSocketData, java.util.List<I2PSocket> sockList)
slock
- the socket lock, non-nullinitialI2PData
- may be nullinitialSocketData
- may be nullsockList
- may be null. Caller must add i2ps to the list! It will be removed here on completion.
Will synchronize on slock when removing.@Deprecated public I2PTunnelRunner(java.net.Socket s, I2PSocket i2ps, java.lang.Object slock, byte[] initialI2PData, java.util.List<I2PSocket> sockList, java.lang.Runnable onTimeout)
slock
- the socket lock, non-nullinitialI2PData
- may be nullsockList
- may be null. Caller must add i2ps to the list! It will be removed here on completion.
Will synchronize on slock when removing.onTimeout
- May be null. If non-null and no data (except initial data) was received,
it will be run before closing s.@Deprecated public I2PTunnelRunner(java.net.Socket s, I2PSocket i2ps, java.lang.Object slock, byte[] initialI2PData, byte[] initialSocketData, java.util.List<I2PSocket> sockList, java.lang.Runnable onTimeout)
slock
- the socket lock, non-nullinitialI2PData
- may be nullinitialSocketData
- may be nullsockList
- may be null. Caller must add i2ps to the list! It will be removed here on completion.
Will synchronize on slock when removing.onTimeout
- May be null. If non-null and no data (except initial data) was received,
it will be run before closing s.public I2PTunnelRunner(java.net.Socket s, I2PSocket i2ps, java.lang.Object slock, byte[] initialI2PData, byte[] initialSocketData, java.util.List<I2PSocket> sockList, I2PTunnelRunner.FailCallback onFail)
slock
- the socket lock, non-nullinitialI2PData
- may be nullinitialSocketData
- may be nullsockList
- may be null. Caller must add i2ps to the list! It will be removed here on completion.
Will synchronize on slock when removing.onFail
- 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 java.io.InputStream getSocketIn() throws java.io.IOException
java.io.IOException
protected java.io.OutputStream getSocketOut() throws java.io.IOException
java.io.IOException
protected void close(java.io.OutputStream out, java.io.InputStream in, java.io.OutputStream i2pout, java.io.InputStream i2pin, java.net.Socket s, I2PSocket i2ps, java.lang.Thread t1, java.lang.Thread t2) throws java.lang.InterruptedException
out
- may be nullin
- may be nulli2pout
- may be nulli2pin
- may be nullt1
- may be nullt2
- may be nulljava.lang.InterruptedException
public void errorOccurred()
errorOccurred
インタフェース内 I2PSocket.SocketErrorListener