Uses of Class
net.i2p.router.tunnel.PendingGatewayMessage
| Package | Description |
|---|---|
| net.i2p.router.tunnel |
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
Subclasses of PendingGatewayMessage in net.i2p.router.tunnel Modifier and Type Class Description (package private) classOutboundGatewayMessageStores all the state for an unsent or partially-sent messageFields in net.i2p.router.tunnel with type parameters of type PendingGatewayMessage Modifier and Type Field Description protected List<PendingGatewayMessage>TunnelGateway. _queueMethods in net.i2p.router.tunnel with parameters of type PendingGatewayMessage Modifier and Type Method Description protected voidPumpedTunnelGateway. add(PendingGatewayMessage cur)protected static intTrivialPreprocessor. getInstructionAugmentationSize(PendingGatewayMessage msg, int offset, int instructionsSize)protected static intTrivialPreprocessor. getInstructionsSize(PendingGatewayMessage msg)protected intTrivialPreprocessor. writeFirstFragment(PendingGatewayMessage msg, byte[] target, int offset)protected intTrivialPreprocessor. writeSubsequentFragment(PendingGatewayMessage msg, byte[] target, int offset)Method parameters in net.i2p.router.tunnel with type arguments of type PendingGatewayMessage Modifier and Type Method Description booleanBatchedPreprocessor. preprocessQueue(List<PendingGatewayMessage> pending, TunnelGateway.Sender sender, TunnelGateway.Receiver rec)booleanTrivialPreprocessor. 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.booleanTunnelGateway.QueuePreprocessor. preprocessQueue(List<PendingGatewayMessage> pending, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver)Caller must synchronize on the list!booleanPumpedTunnelGateway. 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 voidBatchedPreprocessor. 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.