Uses of Class
net.i2p.router.tunnel.PendingGatewayMessage

Packages that use PendingGatewayMessage
net.i2p.router.tunnel   
 

Uses of PendingGatewayMessage in net.i2p.router.tunnel
 

Subclasses of PendingGatewayMessage in net.i2p.router.tunnel
(package private)  class OutboundGatewayMessage
          Stores all the state for an unsent or partially-sent message
 

Fields in net.i2p.router.tunnel with type parameters of type PendingGatewayMessage
protected  List<PendingGatewayMessage> TunnelGateway._queue
           
 

Methods in net.i2p.router.tunnel with parameters of type PendingGatewayMessage
protected  void PumpedTunnelGateway.add(PendingGatewayMessage cur)
           
protected  int TrivialPreprocessor.getInstructionAugmentationSize(PendingGatewayMessage msg, int offset, int instructionsSize)
           
protected  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)
           
 

Method parameters in net.i2p.router.tunnel with type arguments of type PendingGatewayMessage
 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 BatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending, TunnelGateway.Sender sender, TunnelGateway.Receiver rec)
           
 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.