Packages that use OutNetMessage
Package
Description
The I2P router application handles I2P network communication.
Simplified fake implementations of router interfaces (comm system and friends) for testing and embedded builds.
Transport framework: the transport lifecycle and pool management, connection handling and bandwidth throttling for the transports (NTCP2 over TCP, SSU over UDP) that carry I2P messages between routers, plus NAT traversal via UPnP and GeoIP country lookups.
NTCP2, the TCP transport: framed, ratchet-encrypted and mutually authenticated connections between routers.
SSU2, the UDP transport: datagram sessions with Holepunch peer discovery, plus the older SSU compatibility code.
Uses of OutNetMessage in net.i2p.router
Methods in net.i2p.router with parameters of type OutNetMessageModifier and TypeMethodDescriptionvoidOutNetMessagePool.add(OutNetMessage msg) Add a new outbound network message to the pool for delivery.abstract voidCommSystemFacade.processMessage(OutNetMessage msg) Queue an outbound message for delivery through the appropriate transport.voidMessageHistory.replyTimedOut(OutNetMessage sentMessage) The message wanted a reply but no reply came in the time expected.Uses of OutNetMessage in net.i2p.router.dummy
Methods in net.i2p.router.dummy with parameters of type OutNetMessageModifier and TypeMethodDescriptionvoidVMCommSystem.processMessage(OutNetMessage msg) The router wants us to send the given message to the peer.Uses of OutNetMessage in net.i2p.router.transport
Methods in net.i2p.router.transport that return OutNetMessageModifier and TypeMethodDescriptionprotected OutNetMessageTransportImpl.getNextMessage()Nonblocking call to pull the next outbound message off the queue.PrioritySendPool.poll()Return the highest-priority message, or null if empty.OutboundMessageRegistry.registerPending(MessageSelector replySelector, ReplyJob onReply, Job onTimeout) Registers a new, empty OutNetMessage, with the reply and timeout jobs specified.Methods in net.i2p.router.transport that return types with arguments of type OutNetMessageModifier and TypeMethodDescriptionOutboundMessageRegistry.getOriginalMessages(I2NPMessage message) Retrieve all messages that are waiting for the specified message.Methods in net.i2p.router.transport with parameters of type OutNetMessageModifier and TypeMethodDescriptionprotected voidTransportImpl.afterSend(OutNetMessage msg, boolean sendSuccessful) The transport is done sending this message.protected voidTransportImpl.afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue) The transport is done sending this message.protected voidTransportImpl.afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend) The transport is done sending this message.protected voidTransportImpl.afterSend(OutNetMessage msg, boolean sendSuccessful, long msToSend) The transport is done sending this message.(package private) static voidGetBidsJob.fail(RouterContext context, OutNetMessage msg) Fail a message and trigger failure callbacks.(package private) TransportBidTransportManager.getBid(OutNetMessage msg) The best bid for a message across all transports.(package private) static voidGetBidsJob.getBids(RouterContext context, TransportManager tmgr, OutNetMessage msg) Transport bids for a message and send it if a suitable bid is found.(package private) List<TransportBid> TransportManager.getBids(OutNetMessage msg) All bids for a message across all transports.(package private) TransportBidTransportManager.getNextBid(OutNetMessage msg) The best bid, skipping failed transports and unreachable peers.booleanPrioritySendPool.offer(OutNetMessage msg) Non-blocking offer with priority eviction.voidCommSystemFacadeImpl.processMessage(OutNetMessage msg) Process and route an outbound message through the transport system.voidOutboundMessageRegistry.registerPending(OutNetMessage msg) Register the message.voidTransport.send(OutNetMessage msg) Asynchronously send a message to the specified peer.voidTransportImpl.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).voidOutboundMessageRegistry.unregisterPending(OutNetMessage msg) Removes a message that is no longer waiting for a reply, so a later reply that still arrives is not handed to a cancelled request.Method parameters in net.i2p.router.transport with type arguments of type OutNetMessageModifier and TypeMethodDescriptionvoidPrioritySendPool.drainTo(ArrayList<OutNetMessage> target) Drain all messages into the target list (for resize).Uses of OutNetMessage in net.i2p.router.transport.ntcp
Methods in net.i2p.router.transport.ntcp with parameters of type OutNetMessageModifier and TypeMethodDescriptionvoidNTCPSendFinisher.add(OutNetMessage msg) Adds a message to the finishing queue to call afterSend asynchronously.voidNTCPTransport.afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend) Notify after the message send attempt completes.voidNTCPConnection.send(OutNetMessage msg) Queue the message onto the connection's send queue.(package private) voidNTCPTransport.sendComplete(OutNetMessage msg) Queue up the afterSend call, which can take some time with jobs, etc.Uses of OutNetMessage in net.i2p.router.transport.udp
Methods in net.i2p.router.transport.udp that return OutNetMessageModifier and TypeMethodDescriptionOutboundMessageState.getMessage()The message.InboundEstablishState.getNextQueuedMessage()Pull from the message queue.OutboundEstablishState.getNextQueuedMessage()Next queued message.Methods in net.i2p.router.transport.udp with parameters of type OutNetMessageModifier and TypeMethodDescriptionvoidOutboundMessageFragments.add(OutNetMessage msg) Add a new message to the active pool.voidInboundEstablishState.addMessage(OutNetMessage msg) Queue a message to be sent after the session is established.voidOutboundEstablishState.addMessage(OutNetMessage msg) Queue a message to be sent after the session is established.voidEstablishmentManager.establish(OutNetMessage msg) Send the message to its specified recipient by establishing a connection with them and sending it off.voidUDPTransport.failed(OutNetMessage msg, String reason) Handle a failed outbound network message.(package private) static booleanPeerState.isTotalFail(OutNetMessage msg, boolean isInbound, long seqNum) Whether a failed outbound message counts as a total-first-message failure.voidUDPTransport.send(OutNetMessage msg) (package private) voidUDPTransport.sendIfEstablished(OutNetMessage msg) Send only if established, otherwise fail immediately.Method parameters in net.i2p.router.transport.udp with type arguments of type OutNetMessageModifier and TypeMethodDescription(package private) voidUDPTransport.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.Constructors in net.i2p.router.transport.udp with parameters of type OutNetMessageModifierConstructorDescriptionOutboundMessageState(I2PAppContext context, OutNetMessage m, PeerState peer) Normal constructor.