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 | Description |
---|---|---|
(package private) class |
OutboundGatewayMessage |
Stores all the state for an unsent or partially-sent message
|
Modifier and Type | Field | Description |
---|---|---|
protected List<PendingGatewayMessage> |
TunnelGateway._queue |
Modifier and Type | Method | 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 | Description |
---|---|---|
boolean |
BatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec) |
|
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 |
TunnelGateway.QueuePreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver) |
Caller must synchronize on the list!
|
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.
|