|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use TunnelGateway.Pending | |
---|---|
net.i2p.router.tunnel |
Uses of TunnelGateway.Pending in net.i2p.router.tunnel |
---|
Subclasses of TunnelGateway.Pending in net.i2p.router.tunnel | |
---|---|
(package private) class |
TunnelGateway.PendingImpl
Extend for debugging |
Fields in net.i2p.router.tunnel with type parameters of type TunnelGateway.Pending | |
---|---|
protected List<TunnelGateway.Pending> |
TunnelGateway._queue
|
Methods in net.i2p.router.tunnel with parameters of type TunnelGateway.Pending | |
---|---|
protected int |
TrivialPreprocessor.getInstructionAugmentationSize(TunnelGateway.Pending msg,
int offset,
int instructionsSize)
|
protected int |
TrivialPreprocessor.getInstructionsSize(TunnelGateway.Pending msg)
|
protected int |
TrivialPreprocessor.writeFirstFragment(TunnelGateway.Pending msg,
byte[] target,
int offset)
|
protected int |
TrivialPreprocessor.writeSubsequentFragment(TunnelGateway.Pending msg,
byte[] target,
int offset)
|
Method parameters in net.i2p.router.tunnel with type arguments of type TunnelGateway.Pending | |
---|---|
boolean |
TrivialPreprocessor.preprocessQueue(List<TunnelGateway.Pending> 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<TunnelGateway.Pending> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver)
Caller must synchronize on the list! |
boolean |
BatchedPreprocessor.preprocessQueue(List<TunnelGateway.Pending> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec)
|
(package private) void |
PumpedTunnelGateway.pump(List<TunnelGateway.Pending> 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<TunnelGateway.Pending> 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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |