net.i2p.router.transport.ntcp
Constructor and Description |
---|
EventPumper(RouterContext ctx,
NTCPTransport transport) |
Modifier and Type | Method and Description |
---|---|
(package private) ByteBuffer |
acquireBuf() |
long |
getIdleTimeout() |
boolean |
isAlive()
Selector can take quite a while to close after calling stopPumping()
|
void |
register(ServerSocketChannel chan) |
void |
registerConnect(NTCPConnection con) |
(package private) void |
releaseBuf(ByteBuffer buf) |
void |
run() |
void |
startPumping() |
void |
stopPumping() |
void |
wantsRead(NTCPConnection con) |
void |
wantsWrite(NTCPConnection con)
called by the connection when it has data ready to write (after bw allocation)
|
void |
wantsWrite(NTCPConnection con,
byte[] data) |
public EventPumper(RouterContext ctx, NTCPTransport transport)
public void startPumping()
public void stopPumping()
public boolean isAlive()
public void register(ServerSocketChannel chan)
public void registerConnect(NTCPConnection con)
public void wantsWrite(NTCPConnection con, byte[] data)
public void wantsWrite(NTCPConnection con)
public void wantsRead(NTCPConnection con)
ByteBuffer acquireBuf()
void releaseBuf(ByteBuffer buf)
public long getIdleTimeout()