Packages that use TunnelGateway.Receiver
Package
Description
Tunnel messages and the tunnel layer: the
TunnelManagerFacade, tunnel build request and reply processing, and the inbound and outbound tunnel structures.Uses of TunnelGateway.Receiver in net.i2p.router.tunnel
Classes in net.i2p.router.tunnel that implement TunnelGateway.ReceiverModifier and TypeClassDescription(package private) classHandle messages at the IBGW.(package private) classWe are the outbound gateway - we created this outbound tunnel.private static classNo-op receiver for poison pill to avoid null pointer issues.Fields in net.i2p.router.tunnel declared as TunnelGateway.ReceiverModifier and TypeFieldDescriptionprotected final TunnelGateway.ReceiverTunnelGateway._receiverThe message receiver, consuming encrypted messages for forwarding.Methods in net.i2p.router.tunnel with parameters of type TunnelGateway.ReceiverModifier and TypeMethodDescriptionprivate booleanBatchedPreprocessor.preprocessAndSend(List<PendingGatewayMessage> pending, TunnelGateway.Sender sender, TunnelGateway.Receiver rec) Body ofBatchedPreprocessor.preprocessQueue(List, TunnelGateway.Sender, TunnelGateway.Receiver), split out so the per-flush stat batches are flushed on every return path.booleanBatchedPreprocessor.preprocessQueue(List<PendingGatewayMessage> pending, TunnelGateway.Sender sender, TunnelGateway.Receiver rec) booleanTrivialPreprocessor.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 thembooleanTunnelGateway.QueuePreprocessor.preprocessQueue(List<PendingGatewayMessage> pending, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver) Caller must synchronize on the list!protected voidBatchedPreprocessor.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.longInboundSender.sendPreprocessed(byte[] preprocessed, TunnelGateway.Receiver receiver) Encrypt the preprocessed data and forward it to the receiver for delivery.longOutboundSender.sendPreprocessed(byte[] preprocessed, TunnelGateway.Receiver receiver) longTunnelGateway.Sender.sendPreprocessed(byte[] preprocessed, TunnelGateway.Receiver receiver) Encrypt and forward preprocessed data to the receiver.Constructors in net.i2p.router.tunnel with parameters of type TunnelGateway.ReceiverModifierConstructorDescriptionPumpedTunnelGateway(RouterContext context, TunnelGateway.QueuePreprocessor preprocessor, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver, TunnelGatewayPumper pumper) A gateway for a single tunnel hop.ThrottledPumpedTunnelGateway(RouterContext context, TunnelGateway.QueuePreprocessor preprocessor, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver, TunnelGatewayPumper pumper, HopConfig config) A pump-driven gateway that drops excess messages based on estimated bandwidth.protectedTunnelGateway(RouterContext context, TunnelGateway.QueuePreprocessor preprocessor, TunnelGateway.Sender sender, TunnelGateway.Receiver receiver) Creates a new TunnelGateway.