Sink
, Source
, EventDispatcher
StreamrProducer
public class I2PTunnelUDPServerBase extends I2PTunnelTask implements Source, Sink
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected Logging |
l |
|
protected long |
readTimeout |
default timeout to 3 minutes - override if desired
|
protected java.lang.Object |
slock |
open
コンストラクタ | 説明 |
---|---|
I2PTunnelUDPServerBase(boolean verify,
java.io.File privkey,
java.lang.String privkeyname,
Logging l,
EventDispatcher notifyThis,
I2PTunnel tunnel) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
boolean |
close(boolean forced) |
I2PTunnelTask Methods
Classes should override to close UDP side as well
|
long |
getReadTimeout() |
Get the read idle timeout for newly-created connections (in
milliseconds).
|
void |
send(Destination to,
byte[] data) |
Sink Methods
|
void |
setReadTimeout(long ms) |
Set the read idle timeout for newly-created connections (in
milliseconds).
|
void |
setSink(Sink s) |
Source Methods
Sets the receiver of the UDP datagrams from I2P
Subclass must call this after constructor
and before start()
|
void |
start() |
start the source
|
void |
startRunning() |
Classes should override to start UDP side as well.
|
attachEventDispatcher, detachEventDispatcher, getEventDispatcher, getEvents, getEventValue, ignoreEvents, notifyEvent, unIgnoreEvents, waitEventValue
connected, destroy, disconnected, errorOccurred, getId, getTunnel, isOpen, optionsUpdated, reportAbuse, routerDisconnected, setId, setName, setTunnel, toString
protected java.lang.Object slock
protected Logging l
protected long readTimeout
public I2PTunnelUDPServerBase(boolean verify, java.io.File privkey, java.lang.String privkeyname, Logging l, EventDispatcher notifyThis, I2PTunnel tunnel)
java.lang.IllegalArgumentException
- if the I2CP configuration is b0rked so
badly that we cant create a socketManagerpublic void startRunning()
public void setReadTimeout(long ms)
public long getReadTimeout()
public boolean close(boolean forced)
close
クラス内 I2PTunnelTask
public void setSink(Sink s)
public void send(Destination to, byte[] data)