Package net.i2p.router.tunnel
Class TunnelGateway
java.lang.Object
net.i2p.router.tunnel.TunnelGateway
- Direct Known Subclasses:
PumpedTunnelGateway,TunnelGatewayZeroHop
abstract class TunnelGateway extends Object
Serve as the gatekeeper for a tunnel, accepting messages, coalescing and/or
fragmenting them before wrapping them up for tunnel delivery. The flow here
is:
- add an I2NPMessage (and a target tunnel/router, if necessary)
- that message is queued up into a TunnelGateway.Pending and offered to the assigned QueuePreprocessor.
- that QueuePreprocessor may then take off any of the TunnelGateway.Pending messages or instruct the TunnelGateway to offer it the messages again in a short while (in an attempt to coalesce them).
- when the QueueProcessor accepts a TunnelGateway.Pending, it preprocesses it into fragments, forwarding each preprocessed fragment group through the Sender.
- the Sender then encrypts the preprocessed data and delivers it to the Receiver.
- the Receiver now has the encrypted message and may do with it as it pleases (e.g. wrap it as necessary and enqueue it onto the OutNetMessagePool, or if debugging, verify that it can be decrypted properly)
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected classTunnelGateway.DelayedFlushstatic interfaceTunnelGateway.QueuePreprocessorstatic interfaceTunnelGateway.Receiverstatic interfaceTunnelGateway.Sender -
Field Summary
Fields Modifier and Type Field Description protected RouterContext_contextprotected TunnelGateway.DelayedFlush_delayedFlushprotected long_lastFlushprotected Log_logprotected int_messagesSentprotected TunnelGateway.QueuePreprocessor_preprocessorprotected List<PendingGatewayMessage>_queueprotected TunnelGateway.Receiver_receiverprotected TunnelGateway.Sender_sender -
Constructor Summary
Constructors Modifier Constructor Description protectedTunnelGateway(RouterContext context, TunnelGateway.QueuePreprocessor preprocessor, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver) -
Method Summary
Modifier and Type Method Description voidadd(I2NPMessage msg, Hash toRouter, TunnelId toTunnel)Add a message to be sent down the tunnel, either sending it now (perhaps coalesced with other pending messages) or after a brief pause (_flushFrequency).voidadd(TunnelGatewayMessage msg)Add a message to be sent down the tunnel, where we are the inbound gateway.intgetMessagesSent()
-
Field Details
-
_context
-
_log
-
_queue
-
_preprocessor
-
_sender
-
_receiver
-
_lastFlush
protected long _lastFlush -
_delayedFlush
-
_messagesSent
protected int _messagesSent
-
-
Constructor Details
-
TunnelGateway
protected TunnelGateway(RouterContext context, TunnelGateway.QueuePreprocessor preprocessor, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver)- Parameters:
preprocessor- this pulls Pending messages off a list, builds some full preprocessed messages, and pumps those into the sendersender- this takes a preprocessed message, encrypts it, and sends it to the receiverreceiver- this receives the encrypted message and forwards it off to the first hop
-
-
Method Details
-
add
Add a message to be sent down the tunnel, where we are the inbound gateway.- Parameters:
msg- message received to be sent through the tunnel
-
add
Add a message to be sent down the tunnel, either sending it now (perhaps coalesced with other pending messages) or after a brief pause (_flushFrequency). If it is queued up past its expiration, it is silently dropped UNUSED - see overrides- Parameters:
msg- message to be sent through the tunneltoRouter- router to send to after the endpoint (or null for endpoint processing)toTunnel- tunnel to send to after the endpoint (or null for endpoint or router processing)
-
getMessagesSent
public int getMessagesSent()
-