Package | Description |
---|---|
net.i2p.router.tunnel |
All the work of managing locally created and participating tunnels,
creating and handling tunnel messages, and their encryption.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
InboundSender
Receive the preprocessed data for an inbound gateway, encrypt it, and forward
it on to the first hop.
|
(package private) class |
OutboundSender
Receive the preprocessed data for an outbound gateway, encrypt all of the
layers, and forward it on to the first hop.
|
Modifier and Type | Field and Description |
---|---|
protected TunnelGateway.Sender |
TunnelGateway._sender |
Modifier and Type | Method and Description |
---|---|
boolean |
BatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec) |
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.
|
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.
|
Constructor and Description |
---|
PumpedTunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver,
TunnelGatewayPumper pumper) |
ThrottledPumpedTunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver,
TunnelGatewayPumper pumper,
HopConfig config) |
TunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver) |