net.i2p.router.transport.ntcp
Class EventPumper
java.lang.Object
net.i2p.router.transport.ntcp.EventPumper
- All Implemented Interfaces:
- java.lang.Runnable
public class EventPumper
- extends java.lang.Object
- implements java.lang.Runnable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EventPumper
public EventPumper(RouterContext ctx,
NTCPTransport transport)
startPumping
public void startPumping()
stopPumping
public void stopPumping()
register
public void register(java.nio.channels.ServerSocketChannel chan)
registerConnect
public void registerConnect(NTCPConnection con)
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
wantsWrite
public void wantsWrite(NTCPConnection con,
byte[] data)
wantsWrite
public void wantsWrite(NTCPConnection con)
- called by the connection when it has data ready to write (after bw allocation)
wantsRead
public void wantsRead(NTCPConnection con)
acquireBuf
java.nio.ByteBuffer acquireBuf()
releaseBuf
void releaseBuf(java.nio.ByteBuffer buf)