Uses of Class
net.i2p.router.tunnel.PendingGatewayMessage
Package
Description
All the work of managing locally created and participating tunnels,
creating and handling tunnel messages, and their encryption.
-
Uses of PendingGatewayMessage in net.i2p.router.tunnel
Modifier and TypeClassDescription(package private) class
Stores all the state for an unsent or partially-sent messageModifier and TypeFieldDescriptionprotected final List<PendingGatewayMessage>
TunnelGateway._queue
Modifier and TypeMethodDescriptionprotected 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 TypeMethodDescriptionboolean
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.