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.
|
net.i2p.router.transport.udp |
The UDP transport (also known as 'SSU transport') allows passing I2P messages on top of UDP.
|
Modifier and Type | Method and Description |
---|---|
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.requestInbound(int bytesIn,
String purpose)
Request some bytes.
|
FIFOBandwidthLimiter.Request |
FIFOBandwidthLimiter.requestOutbound(int bytesOut,
int priority,
String purpose)
Request some bytes.
|
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.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
|
Modifier and Type | Method and Description |
---|---|
FIFOBandwidthLimiter.Request |
UDPPacket.getBandwidthRequest()
So that we can compete with NTCP, we want to request bandwidth
in parallel, on the way into the queue, not on the way out.
|