Package | Description |
---|---|
net.i2p.router.tunnel |
All the work of managing locally created and participating tunnels,
creating and handling tunnel messages, and their encryption.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
OutboundGatewayMessage
Stores all the state for an unsent or partially-sent message
|
Modifier and Type | Field and Description |
---|---|
protected List<PendingGatewayMessage> |
TunnelGateway._queue |
Modifier and Type | Method and Description |
---|---|
protected void |
PumpedTunnelGateway.add(PendingGatewayMessage cur) |
protected static int |
TrivialPreprocessor.getInstructionAugmentationSize(PendingGatewayMessage msg,
int offset,
int instructionsSize) |
protected static int |
TrivialPreprocessor.getInstructionsSize(PendingGatewayMessage msg) |
protected int |
TrivialPreprocessor.writeFirstFragment(PendingGatewayMessage msg,
byte[] target,
int offset) |
protected int |
TrivialPreprocessor.writeSubsequentFragment(PendingGatewayMessage msg,
byte[] target,
int offset) |
Modifier and Type | Method and Description |
---|---|
boolean |
BatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec) |
boolean |
TunnelGateway.QueuePreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver)
Caller must synchronize on the list!
|
boolean |
TrivialPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec)
Return true if there were messages remaining, and we should queue up
a delayed flush to clear them
NOTE: Unused here, see BatchedPreprocessor override, super is not called.
|
boolean |
PumpedTunnelGateway.pump(List<PendingGatewayMessage> queueBuf)
run in one of the TunnelGatewayPumper's threads, this pulls pending messages
off the prequeue, adds them to the queue and then tries to preprocess the queue,
scheduling a later delayed flush as necessary.
|
protected void |
BatchedPreprocessor.send(List<PendingGatewayMessage> pending,
int startAt,
int sendThrough,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec)
Preprocess the messages from the pending list, grouping items startAt
through sendThrough (though only part of the last one may be fully
sent), delivering them through the sender/receiver.
|