|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use OutNetMessage | |
net.i2p.router | |
net.i2p.router.transport | |
net.i2p.router.transport.tcp | Implements the transport for communicating with other routers via TCP/IP. |
net.i2p.router.transport.udp |
Uses of OutNetMessage in net.i2p.router |
Methods in net.i2p.router that return OutNetMessage | |
OutNetMessage |
OutNetMessagePool.getNext()
Remove the highest priority message, or null if none are available. |
Methods in net.i2p.router with parameters of type OutNetMessage | |
void |
DummyCommSystemFacade.processMessage(OutNetMessage msg)
|
void |
OutNetMessagePool.add(OutNetMessage msg)
Add a new message to the pool |
void |
MessageHistory.replyTimedOut(OutNetMessage sentMessage)
The message wanted a reply but no reply came in the time expected |
abstract void |
CommSystemFacade.processMessage(OutNetMessage msg)
|
Uses of OutNetMessage in net.i2p.router.transport |
Methods in net.i2p.router.transport that return OutNetMessage | |
OutNetMessage |
TransportImpl.getNextMessage()
Nonblocking call to pull the next outbound message off the queue. |
OutNetMessage |
OutboundMessageRegistry.registerPending(MessageSelector replySelector,
ReplyJob onReply,
Job onTimeout,
int timeoutMs)
|
Methods in net.i2p.router.transport with parameters of type OutNetMessage | |
void |
VMCommSystem.processMessage(OutNetMessage msg)
The router wants us to send the given message to the peer. |
java.util.List |
TransportManager.getBids(OutNetMessage msg)
|
TransportBid |
TransportManager.getBid(OutNetMessage msg)
|
protected void |
TransportImpl.afterSend(OutNetMessage msg,
boolean sendSuccessful)
The transport is done sending this message |
protected void |
TransportImpl.afterSend(OutNetMessage msg,
boolean sendSuccessful,
boolean allowRequeue)
The transport is done sending this message |
protected void |
TransportImpl.afterSend(OutNetMessage msg,
boolean sendSuccessful,
long msToSend)
The transport is done sending this message |
protected void |
TransportImpl.afterSend(OutNetMessage msg,
boolean sendSuccessful,
boolean allowRequeue,
long msToSend)
The transport is done sending this message. |
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 |
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 |
OutboundMessageRegistry.registerPending(OutNetMessage msg)
|
void |
OutboundMessageRegistry.registerPending(OutNetMessage msg,
boolean allowEmpty)
|
void |
OutboundMessageRegistry.unregisterPending(OutNetMessage msg)
|
(package private) static void |
GetBidsJob.getBids(RouterContext context,
CommSystemFacadeImpl facade,
OutNetMessage msg)
|
java.util.List |
CommSystemFacadeImpl.getBids(OutNetMessage msg)
|
TransportBid |
CommSystemFacadeImpl.getBid(OutNetMessage msg)
|
void |
CommSystemFacadeImpl.processMessage(OutNetMessage msg)
|
Constructors in net.i2p.router.transport with parameters of type OutNetMessage | |
GetBidsJob(RouterContext ctx,
CommSystemFacadeImpl facade,
OutNetMessage msg)
|
Uses of OutNetMessage in net.i2p.router.transport.tcp |
Methods in net.i2p.router.transport.tcp that return OutNetMessage | |
(package private) OutNetMessage |
TCPConnection.getNextMessage()
Blocking call to retrieve the next pending message. |
Methods in net.i2p.router.transport.tcp with parameters of type OutNetMessage | |
void |
TCPTransport.afterSend(OutNetMessage msg,
boolean sendSuccessful,
boolean allowRequeue,
long msToSend)
The transport is done sending this message. |
void |
TCPConnection.addMessage(OutNetMessage msg)
Add the given message to the outbound queue, notifying our runners that we want to send it. |
(package private) void |
TCPConnection.sent(OutNetMessage msg,
boolean ok,
long time)
The message was sent. |
Uses of OutNetMessage in net.i2p.router.transport.udp |
Methods in net.i2p.router.transport.udp that return OutNetMessage | |
OutNetMessage |
UDPTransport.getNextMessage()
|
OutNetMessage |
UDPTransport.getNextMessage(long blockUntil)
Get the next message, blocking until one is found or the expiration reached. |
OutNetMessage |
TimedWeightedPriorityMessageQueue.getNext(long blockUntil)
Grab the next message out of the next queue. |
OutNetMessage |
OutboundMessageState.getMessage()
|
OutNetMessage |
OutboundEstablishState.getNextQueuedMessage()
|
OutNetMessage |
MessageQueue.getNext(long blockUntil)
Get the next message, blocking until one is found or the expiration reached. |
Methods in net.i2p.router.transport.udp with parameters of type OutNetMessage | |
void |
UDPTransport.send(OutNetMessage msg)
|
void |
UDPTransport.failed(OutNetMessage msg)
|
void |
UDPTransport.succeeded(OutNetMessage msg)
|
void |
TimedWeightedPriorityMessageQueue.add(OutNetMessage message)
|
void |
TimedWeightedPriorityMessageQueue.FailedListener.failed(OutNetMessage msg)
|
boolean |
OutboundMessageState.initialize(OutNetMessage msg)
|
void |
OutboundMessageFragments.add(OutNetMessage msg)
Add a new message to the active pool |
void |
OutboundEstablishState.addMessage(OutNetMessage msg)
|
void |
MessageQueue.add(OutNetMessage message)
Add on a new message to the queue |
void |
EstablishmentManager.establish(OutNetMessage msg)
Send the message to its specified recipient by establishing a connection with them and sending it off. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |