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 |
InboundGatewayReceiver |
Handle messages at the IBGW.
|
(package private) class |
OutboundReceiver |
We are the outbound gateway - we created this outbound tunnel.
|
Modifier and Type | Field | Description |
---|---|---|
protected TunnelGateway.Receiver |
TunnelGateway._receiver |
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.
|
long |
InboundSender.sendPreprocessed(byte[] preprocessed,
TunnelGateway.Receiver receiver) |
|
long |
OutboundSender.sendPreprocessed(byte[] preprocessed,
TunnelGateway.Receiver receiver) |
|
long |
TunnelGateway.Sender.sendPreprocessed(byte[] preprocessed,
TunnelGateway.Receiver receiver) |
Take the preprocessed data containing zero or more fragments, encrypt
it, and pass it on to the 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) |