Uses of Class
net.i2p.router.OutNetMessage
Package
Description
The I2P router application handles the I2P network communication.
Dummy versions of things for testing.
The transport system allows the usage of communication layers that are below I2P in the stack, on which I2P messages are sent.
The NTCP transport allows passing I2P messages on top of TCP.
The UDP transport (also known as 'SSU transport') allows passing I2P messages on top of UDP.
-
Uses of OutNetMessage in net.i2p.router
Modifier and TypeMethodDescriptionvoid
OutNetMessagePool.add
(OutNetMessage msg) Add a new message to the poolabstract void
CommSystemFacade.processMessage
(OutNetMessage msg) void
MessageHistory.replyTimedOut
(OutNetMessage sentMessage) The message wanted a reply but no reply came in the time expected -
Uses of OutNetMessage in net.i2p.router.dummy
Modifier and TypeMethodDescriptionvoid
VMCommSystem.processMessage
(OutNetMessage msg) The router wants us to send the given message to the peer. -
Uses of OutNetMessage in net.i2p.router.transport
Modifier and TypeMethodDescriptionprotected OutNetMessage
TransportImpl.getNextMessage()
Nonblocking call to pull the next outbound message off the queue.OutboundMessageRegistry.registerPending
(MessageSelector replySelector, ReplyJob onReply, Job onTimeout) Registers a new, empty OutNetMessage, with the reply and timeout jobs specified.Modifier and TypeMethodDescriptionOutboundMessageRegistry.getOriginalMessages
(I2NPMessage message) Retrieve all messages that are waiting for the specified message.Modifier and TypeMethodDescriptionprotected void
TransportImpl.afterSend
(OutNetMessage msg, boolean sendSuccessful) The transport is done sending this messageprotected void
TransportImpl.afterSend
(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue) The transport is done sending this messageprotected void
TransportImpl.afterSend
(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend) The transport is done sending this message.protected void
TransportImpl.afterSend
(OutNetMessage msg, boolean sendSuccessful, long msToSend) The transport is done sending this message(package private) static void
GetBidsJob.fail
(RouterContext context, OutNetMessage msg) (package private) TransportBid
TransportManager.getBid
(OutNetMessage msg) (package private) static void
GetBidsJob.getBids
(RouterContext context, TransportManager tmgr, OutNetMessage msg) (package private) List<TransportBid>
TransportManager.getBids
(OutNetMessage msg) (package private) TransportBid
TransportManager.getNextBid
(OutNetMessage msg) void
CommSystemFacadeImpl.processMessage
(OutNetMessage msg) Send the message outvoid
OutboundMessageRegistry.registerPending
(OutNetMessage msg) Register the message.void
Transport.send
(OutNetMessage msg) Asynchronously send the message as requested in the message and, if the send is successful, queue up any msg.getOnSendJob job, and register it with the OutboundMessageRegistry (if it has a reply selector).void
TransportImpl.send
(OutNetMessage msg) Asynchronously send the message as requested in the message and, if the send is successful, queue up any msg.getOnSendJob job, and register it with the OutboundMessageRegistry (if it has a reply selector).void
OutboundMessageRegistry.unregisterPending
(OutNetMessage msg) ModifierConstructorDescriptionGetBidsJob
(RouterContext ctx, TransportManager tmgr, OutNetMessage msg) Deprecated.unused, see static getBids() -
Uses of OutNetMessage in net.i2p.router.transport.ntcp
Modifier and TypeMethodDescriptionvoid
NTCPSendFinisher.add
(OutNetMessage msg) void
NTCPTransport.afterSend
(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend) void
NTCPConnection.send
(OutNetMessage msg) toss the message onto the connection's send queue(package private) void
NTCPTransport.sendComplete
(OutNetMessage msg) queue up afterSend call, which can take some time w/ jobs, etc -
Uses of OutNetMessage in net.i2p.router.transport.udp
Modifier and TypeMethodDescriptionOutboundMessageState.getMessage()
MessageQueue.getNext
(long blockUntil) Get the next message, blocking until one is found or the expiration reached.TimedWeightedPriorityMessageQueue.getNext
(long blockUntil) Grab the next message out of the next queue.InboundEstablishState.getNextQueuedMessage()
Pull from the message queueOutboundEstablishState.getNextQueuedMessage()
Modifier and TypeMethodDescriptionvoid
MessageQueue.add
(OutNetMessage message) Add on a new message to the queuevoid
OutboundMessageFragments.add
(OutNetMessage msg) Add a new message to the active poolvoid
TimedWeightedPriorityMessageQueue.add
(OutNetMessage message) void
InboundEstablishState.addMessage
(OutNetMessage msg) Queue a message to be sent after the session is established.void
OutboundEstablishState.addMessage
(OutNetMessage msg) Queue a message to be sent after the session is established.void
EstablishmentManager.establish
(OutNetMessage msg) Send the message to its specified recipient by establishing a connection with them and sending it off.void
TimedWeightedPriorityMessageQueue.FailedListener.failed
(OutNetMessage msg, String reason) void
UDPTransport.failed
(OutNetMessage msg, String reason) void
UDPTransport.send
(OutNetMessage msg) (package private) void
UDPTransport.sendIfEstablished
(OutNetMessage msg) Send only if established, otherwise fail immediately.Modifier and TypeMethodDescription(package private) void
UDPTransport.send
(I2NPMessage msg, List<OutNetMessage> msgs, PeerState peer) "injected" message from the EstablishmentManager, plus pending messages to send, so the messages may be bundled efficiently.ModifierConstructorDescriptionOutboundMessageState
(I2PAppContext context, OutNetMessage m, PeerState peer) Normal constructor.