class ThrottledPumpedTunnelGateway extends PumpedTunnelGateway
TunnelGateway.DelayedFlush, TunnelGateway.QueuePreprocessor, TunnelGateway.Receiver, TunnelGateway.Sender_isInbound, PROP_INITIAL_OB_QUEUE, PROP_MAX_IB_MSGS_PER_PUMP, PROP_MAX_IB_QUEUE, PROP_MAX_OB_MSGS_PER_PUMP_context, _delayedFlush, _lastFlush, _log, _messagesSent, _preprocessor, _queue, _receiver, _sender| Constructor and Description |
|---|
ThrottledPumpedTunnelGateway(RouterContext context,
TunnelGateway.QueuePreprocessor preprocessor,
TunnelGateway.Sender sender,
TunnelGateway.Receiver receiver,
TunnelGatewayPumper pumper,
HopConfig config)Constructs a ThrottledPumpedTunnelGateway with bandwidth throttling. |
| Modifier and Type | Method and Description |
|---|---|
boolean | add(I2NPMessage msg,
Hash toRouter,
TunnelId toTunnel)Adds a message to the inbound gateway after a bandwidth-based drop check. |
String | toString()Human-readable description differentiating inbound gateway and including tunnel ID. |
add, getMaxIbMsgsPerPump, getMaxObMsgsPerPump, pump, setMaxIbMsgsPerPump, setMaxObMsgsPerPumpadd, getMessagesSentpublic ThrottledPumpedTunnelGateway(RouterContext context, TunnelGateway.QueuePreprocessor preprocessor, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver, TunnelGatewayPumper pumper, HopConfig config)
context - RouterContextpreprocessor - QueuePreprocessor for the gatewaysender - Encrypting Sender for fragmentsreceiver - Receiving entity consuming encrypted messagespumper - TunnelGatewayPumper managing pumping threadsconfig - HopConfig containing bandwidth and message statisticspublic boolean add(I2NPMessage msg, Hash toRouter, TunnelId toTunnel)
add in class PumpedTunnelGatewaymsg - the I2NP message to addtoRouter - optional target router after the endpointtoTunnel - optional target tunnel after the endpoint