| Package | Description |
|---|---|
| net.i2p.router.tunnel | Core tunnel management, message processing, and encryption for I2P's anonymous routing system. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class | InboundGatewayReceiverHandle messages at the IBGW. |
(package private) class | OutboundReceiverWe are the outbound gateway - we created this outbound tunnel. |
| Modifier and Type | Field and Description |
|---|---|
protected TunnelGateway.Receiver | TunnelGateway._receiverreceiver |
| Modifier and Type | Method and Description |
|---|---|
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! |
boolean | BatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending,
TunnelGateway.Sender sender,
TunnelGateway.Receiver rec) |
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 | TunnelGateway.Sender.sendPreprocessed(byte[] preprocessed,
TunnelGateway.Receiver receiver)Encrypt and forward preprocessed data to the receiver. |
long | OutboundSender.sendPreprocessed(byte[] preprocessed,
TunnelGateway.Receiver receiver) |
long | InboundSender.sendPreprocessed(byte[] preprocessed,
TunnelGateway.Receiver receiver)sendPreprocessed. |
| Constructor and Description |
|---|
PumpedTunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver,
TunnelGatewayPumper pumper)Constructs a PumpedTunnelGateway instance. |
ThrottledPumpedTunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver,
TunnelGatewayPumper pumper,
HopConfig config)Constructs a ThrottledPumpedTunnelGateway with bandwidth throttling. |
TunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver)Creates a new TunnelGateway. |