| Package | Description |
|---|---|
| net.i2p.router.tunnel | Core tunnel management, message processing, and encryption for I2P's anonymous routing system. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class | OutboundGatewayMessageStores all the state for an unsent or partially-sent message. |
| Modifier and Type | Field and Description |
|---|---|
protected List<PendingGatewayMessage> | TunnelGateway._queuemessage queue |
| Modifier and Type | Method and Description |
|---|---|
protected boolean | PumpedTunnelGateway.add(PendingGatewayMessage cur)Adds a PendingGatewayMessage to the prequeue and notifies the pumper to process it. |
protected static int | TrivialPreprocessor.getInstructionAugmentationSize(PendingGatewayMessage msg,
int offset,
int instructionsSize)Get the augmentation size for instructions if fragmentation is needed. |
protected static int | TrivialPreprocessor.getInstructionsSize(PendingGatewayMessage msg)Calculate the size of the instructions for a pending message. |
protected int | TrivialPreprocessor.writeFirstFragment(PendingGatewayMessage msg,
byte[] target,
int offset)Write the first fragment of a tunnel message. |
protected int | TrivialPreprocessor.writeSubsequentFragment(PendingGatewayMessage msg,
byte[] target,
int offset)Write a subsequent fragment of a tunnel message. |
| Modifier and Type | Method and Description |
|---|---|
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 | BatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec) |
boolean | PumpedTunnelGateway.pump(List<PendingGatewayMessage> queueBuf)Pumps messages from the internal prequeue into the processing queue. |
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. |