Uses of Class
net.i2p.router.OutNetMessage
| Package | Description |
|---|---|
| net.i2p.router |
The I2P router application handles the I2P network communication.
|
| net.i2p.router.dummy |
Dummy versions of things for testing.
|
| net.i2p.router.transport |
The transport system allows the usage of communication layers that are below I2P in the stack, on which I2P messages are sent.
|
| net.i2p.router.transport.ntcp |
The NTCP transport allows passing I2P messages on top of TCP.
|
| net.i2p.router.transport.udp |
The UDP transport (also known as 'SSU transport') allows passing I2P messages on top of UDP.
|
-
Uses of OutNetMessage in net.i2p.router
Methods in net.i2p.router with parameters of type OutNetMessage Modifier and Type Method Description voidOutNetMessagePool. add(OutNetMessage msg)Add a new message to the poolabstract voidCommSystemFacade. processMessage(OutNetMessage msg)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 OutNetMessage Modifier and Type Method Description voidVMCommSystem. 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 OutNetMessage Modifier and Type Method Description protected OutNetMessageTransportImpl. getNextMessage()Nonblocking call to pull the next outbound message off the queue.OutNetMessageOutboundMessageRegistry. 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 OutNetMessage Modifier and Type Method Description List<OutNetMessage>OutboundMessageRegistry. getOriginalMessages(I2NPMessage message)Retrieve all messages that are waiting for the specified message.Methods in net.i2p.router.transport with parameters of type OutNetMessage Modifier and Type Method Description protected voidTransportImpl. afterSend(OutNetMessage msg, boolean sendSuccessful)The transport is done sending this messageprotected voidTransportImpl. afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue)The transport is done sending this messageprotected 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)(package private) TransportBidTransportManager. getBid(OutNetMessage msg)(package private) static voidGetBidsJob. getBids(RouterContext context, TransportManager tmgr, OutNetMessage msg)(package private) List<TransportBid>TransportManager. getBids(OutNetMessage msg)(package private) TransportBidTransportManager. getNextBid(OutNetMessage msg)voidCommSystemFacadeImpl. processMessage(OutNetMessage msg)Send the message outvoidOutboundMessageRegistry. registerPending(OutNetMessage msg)Register the message.voidTransport. 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).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)Constructors in net.i2p.router.transport with parameters of type OutNetMessage Constructor Description GetBidsJob(RouterContext ctx, TransportManager tmgr, OutNetMessage msg)Deprecated.unused, see static getBids() -
Uses of OutNetMessage in net.i2p.router.transport.ntcp
Methods in net.i2p.router.transport.ntcp with parameters of type OutNetMessage Modifier and Type Method Description voidNTCPSendFinisher. add(OutNetMessage msg)voidNTCPTransport. afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend)voidNTCPConnection. send(OutNetMessage msg)toss the message onto the connection's send queue(package private) voidNTCPTransport. sendComplete(OutNetMessage msg)queue up afterSend call, which can take some time w/ jobs, etc -
Uses of OutNetMessage in net.i2p.router.transport.udp
Methods in net.i2p.router.transport.udp that return OutNetMessage Modifier and Type Method Description OutNetMessageOutboundMessageState. getMessage()OutNetMessageMessageQueue. getNext(long blockUntil)Get the next message, blocking until one is found or the expiration reached.OutNetMessageTimedWeightedPriorityMessageQueue. getNext(long blockUntil)Grab the next message out of the next queue.OutNetMessageInboundEstablishState. getNextQueuedMessage()Pull from the message queueOutNetMessageOutboundEstablishState. getNextQueuedMessage()Methods in net.i2p.router.transport.udp with parameters of type OutNetMessage Modifier and Type Method Description voidMessageQueue. add(OutNetMessage message)Add on a new message to the queuevoidOutboundMessageFragments. add(OutNetMessage msg)Add a new message to the active poolvoidTimedWeightedPriorityMessageQueue. add(OutNetMessage message)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.voidTimedWeightedPriorityMessageQueue.FailedListener. failed(OutNetMessage msg, String reason)voidUDPTransport. failed(OutNetMessage msg, String reason)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 OutNetMessage Modifier and Type Method Description (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 OutNetMessage Constructor Description OutboundMessageState(I2PAppContext context, OutNetMessage m, PeerState peer)Normal constructor.