Package | Description |
---|---|
net.i2p.router.transport |
The transport system allows the usage of communication layers that are below I2P in the stack, on which I2P messages are sent.
|
net.i2p.router.transport.ntcp |
The NTCP transport allows passing I2P messages on top of TCP.
|
Modifier and Type | Method and Description |
---|---|
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.createRequest() |
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.requestInbound(int bytesIn,
String purpose)
Request some bytes.
|
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.requestInbound(int bytesIn,
String purpose,
FIFOBandwidthLimiter.CompleteListener lsnr,
Object attachment) |
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.requestOutbound(int bytesOut,
String purpose)
Request some bytes.
|
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.requestOutbound(int bytesOut,
String purpose,
FIFOBandwidthLimiter.CompleteListener lsnr,
Object attachment) |
Modifier and Type | Method and Description |
---|---|
void |
FIFOBandwidthLimiter.CompleteListener.complete(FIFOBandwidthLimiter.Request req) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
FIFOBandwidthLimiter.refillBandwidthQueues(List<FIFOBandwidthLimiter.Request> buf,
long bytesInbound,
long bytesOutbound,
long maxBurstIn,
long maxBurstOut)
More bytes are available - add them to the queue and satisfy any requests
we can
|
Modifier and Type | Method and Description |
---|---|
void |
NTCPConnection.complete(FIFOBandwidthLimiter.Request req) |
void |
NTCPConnection.queuedRecv(ByteBuffer buf,
FIFOBandwidthLimiter.Request req)
We have read the data in the buffer, but we can't process it locally yet,
because we're choked by the bandwidth limiter.
|
void |
NTCPConnection.queuedWrite(ByteBuffer buf,
FIFOBandwidthLimiter.Request req)
ditto for writes
|