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 | 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 | Description |
---|---|---|
protected TunnelGateway.Sender |
TunnelGateway._sender |
Modifier and Type | Method | Description |
---|---|---|
boolean |
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!
|
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 | 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) |