java.lang.Runnable
class EventPumper
extends java.lang.Object
implements java.lang.Runnable
コンストラクタ | 説明 |
---|---|
EventPumper(RouterContext ctx,
NTCPTransport transport) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
long |
getIdleTimeout() |
|
boolean |
isAlive() |
Selector can take quite a while to close after calling stopPumping()
|
void |
register(java.nio.channels.ServerSocketChannel chan) |
Register the acceptor.
|
void |
registerConnect(NTCPConnection con) |
Outbound
|
static void |
releaseBuf(java.nio.ByteBuffer buf) |
Return a read buffer to the pool.
|
void |
run() |
The selector loop.
|
void |
startPumping() |
|
void |
stopPumping() |
|
void |
wantsRead(NTCPConnection con) |
This is only called from NTCPConnection.complete()
if there is more data, which is rare (never?)
so we don't need to check for dups or make _wantsRead a Set.
|
void |
wantsWrite(NTCPConnection con) |
Called by the connection when it has data ready to write (after bw allocation).
|
void |
wantsWrite(NTCPConnection con,
byte[] data) |
Called by the connection when it has data ready to write.
|
public EventPumper(RouterContext ctx, NTCPTransport transport)
public void startPumping()
public void stopPumping()
public boolean isAlive()
public void register(java.nio.channels.ServerSocketChannel chan)
public void registerConnect(NTCPConnection con)
public void run()
run
インタフェース内 java.lang.Runnable
public void wantsWrite(NTCPConnection con, byte[] data)
public void wantsWrite(NTCPConnection con)
public void wantsRead(NTCPConnection con)
public static void releaseBuf(java.nio.ByteBuffer buf)
public long getIdleTimeout()