パッケージ | 説明 |
---|---|
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.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
OutNetMessagePool.add(OutNetMessage msg) |
Add a new message to the pool
|
abstract void |
CommSystemFacade.processMessage(OutNetMessage msg) |
|
void |
MessageHistory.replyTimedOut(OutNetMessage sentMessage) |
The message wanted a reply but no reply came in the time expected
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
VMCommSystem.processMessage(OutNetMessage msg) |
The router wants us to send the given message to the peer.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
protected OutNetMessage |
TransportImpl.getNextMessage() |
Nonblocking call to pull the next outbound message
off the queue.
|
OutNetMessage |
OutboundMessageRegistry.registerPending(MessageSelector replySelector,
ReplyJob onReply,
Job onTimeout) |
Registers a new, empty OutNetMessage, with the reply and timeout jobs specified.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
java.util.List<OutNetMessage> |
OutboundMessageRegistry.getOriginalMessages(I2NPMessage message) |
Retrieve all messages that are waiting for the specified message.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
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,
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) java.util.List<TransportBid> |
TransportManager.getBids(OutNetMessage msg) |
|
(package private) TransportBid |
TransportManager.getNextBid(OutNetMessage msg) |
|
void |
CommSystemFacadeImpl.processMessage(OutNetMessage msg) |
Send the message out
|
void |
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) |
コンストラクタ | 説明 |
---|---|
GetBidsJob(RouterContext ctx,
TransportManager tmgr,
OutNetMessage msg) |
推奨されていません。
unused, see static getBids()
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
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
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
OutNetMessage |
OutboundMessageState.getMessage() |
|
OutNetMessage |
MessageQueue.getNext(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 |
InboundEstablishState.getNextQueuedMessage() |
Pull from the message queue
|
OutNetMessage |
OutboundEstablishState.getNextQueuedMessage() |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
MessageQueue.add(OutNetMessage message) |
Add on a new message to the queue
|
void |
OutboundMessageFragments.add(OutNetMessage msg) |
Add a new message to the active pool
|
void |
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,
java.lang.String reason) |
|
void |
UDPTransport.failed(OutNetMessage msg,
java.lang.String reason) |
|
void |
UDPTransport.send(OutNetMessage msg) |
|
(package private) void |
UDPTransport.sendIfEstablished(OutNetMessage msg) |
Send only if established, otherwise fail immediately.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
(package private) void |
UDPTransport.send(I2NPMessage msg,
java.util.List<OutNetMessage> msgs,
PeerState peer) |
"injected" message from the EstablishmentManager,
plus pending messages to send,
so the messages may be bundled efficiently.
|
コンストラクタ | 説明 |
---|---|
OutboundMessageState(I2PAppContext context,
OutNetMessage m,
PeerState peer) |
Normal constructor.
|