Uses of Interface
net.i2p.data.i2np.I2NPMessage
Package
Description
This package defines the low-level messages sent between routers,
called the Invisible Internet Network Protocol (I2NP).
The I2P router application handles the I2P network communication.
Creates and parses garlic messages.
A couple of classes, but most things are in kademlia.
The network database, including implementation of floodfills.
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.
All the work of managing locally created and participating tunnels,
creating and handling tunnel messages, and their encryption.
-
Uses of I2NPMessage in net.i2p.data.i2np
Modifier and TypeClassDescriptionclass
Defines the message a router sends to another router to search for a key in the network database.class
Defines the message a router sends to another router in response to a search (DatabaseFindNearest or DatabaseLookup) when it doesn't have the value, specifying what routers it would search.class
Defines the message a router sends to another router to test the network database reachability, as well as the reply message sent back.class
Defines a message containing arbitrary bytes of data This is what goes in a GarlicClove.class
Defines the message sent back in reply to a message when requested, containing the private ack id.class
Ignore, but save, the SHA-256 checksum in the full 16-byte header when read in.class
Defines the wrapped garlic messageclass
Defines the base message implementation.class
Sent from the OBEP to the tunnel creator via an inbound tunnel.class
Variable size, small records.class
Internal use only, to convert an inbound STBM to a reply.class
The basic build message with 8 records.class
Base for TBM, TBRM, VTBM, VTBRM Retrofitted over them.class
The basic build reply message with 8 records.class
Defines the message sent between routers as part of the tunnel delivery The tunnel ID is changed in-place by TunnelParticipant.send(), so we can't reuse the checksum on output, but we still subclass FastI2NPMessageImpl so we don't verify the checksum on input...class
Defines the message sent between one tunnel's endpoint and another's gateway.class
This is similar to DataMessage or GarlicMessage but with a variable message type.class
Variable number of records.class
Transmitted from the new outbound endpoint to the creator through a reply tunnel.Modifier and TypeMethodDescriptionI2NPMessageImpl.Builder.build
(I2PAppContext ctx) instantiate a new I2NPMessage to be populated shortlyUnknownI2NPMessage.convert()
Attempt to convert this message to a known message class.static I2NPMessage
I2NPMessageImpl.createMessage
(I2PAppContext context, int type) Yes, this is fairly ugly, but its the only place it ever happens.static I2NPMessage
I2NPMessageImpl.fromRawByteArray
(I2PAppContext ctx, byte[] buffer, int offset, int len, I2NPMessageHandler handler) Read the message with a short 5-byte header.static I2NPMessage
I2NPMessageImpl.fromRawByteArrayNTCP2
(I2PAppContext ctx, byte[] buffer, int offset, int len, I2NPMessageHandler handler) Read the message with a short 9-byte header.GarlicClove.getData()
TunnelGatewayMessage.getMessage()
Warning, at the IBGW, where the message was read in, this will be an UnknownI2NPMessage.I2NPMessageHandler.lastRead()
clear the last message read from a byte array with an offsetI2NPMessageHandler.readMessage
(byte[] data) Read an I2NPMessage from the byte array and return the fully populated object.Modifier and TypeMethodDescriptionvoid
GarlicClove.setData
(I2NPMessage msg) void
TunnelGatewayMessage.setMessage
(I2NPMessage msg) -
Uses of I2NPMessage in net.i2p.router
Modifier and TypeMethodDescriptionint
InNetMessagePool.add
(I2NPMessage messageBody, RouterIdentity fromRouter, Hash fromRouterHash) Add a new message to the pool.HandlerJobBuilder.createJob
(I2NPMessage receivedMessage, RouterIdentity from, Hash fromHash) Create a new job to handle the received message.void
MessageHistory.droppedOtherMessage
(I2NPMessage message, Hash from) We received another message we weren't waiting for and don't know how to handleint
InNetMessagePool.handleReplies
(I2NPMessage messageBody) boolean
MessageSelector.isMatch
(I2NPMessage message) Returns true if the received message matches the selector.void
ReplyJob.setMessage
(I2NPMessage message) Called by InNetMessagePool when an I2NPMessage matching a MessageSelector registered with the OutboundMessageRegistry is receivedModifierConstructorDescriptionOutNetMessage
(RouterContext context, I2NPMessage msg, long expiration, int priority, RouterInfo target) Standard constructor -
Uses of I2NPMessage in net.i2p.router.message
Modifier and TypeMethodDescriptionPayloadGarlicConfig.getPayload()
Specify the I2NP message to be sent - if this is set, no other cloves can be included in this blockModifier and TypeMethodDescriptionGarlicMessageHandler.createJob
(I2NPMessage receivedMessage, RouterIdentity from, Hash fromHash) void
GarlicMessageReceiver.CloveReceiver.handleClove
(DeliveryInstructions instructions, I2NPMessage data) void
HandleGarlicMessageJob.handleClove
(DeliveryInstructions instructions, I2NPMessage data) ModifierConstructorDescriptionPayloadGarlicConfig
(Certificate cert, long id, long expiration, DeliveryInstructions di, I2NPMessage message) SendMessageDirectJob
(RouterContext ctx, I2NPMessage message, Hash toPeer, int timeoutMs, int priority) SendMessageDirectJob
(RouterContext ctx, I2NPMessage message, Hash toPeer, Job onSend, ReplyJob onSuccess, Job onFail, MessageSelector selector, int timeoutMs, int priority) SendMessageDirectJob
(RouterContext ctx, I2NPMessage message, Hash toPeer, ReplyJob onSuccess, Job onFail, MessageSelector selector, int timeoutMs, int priority) -
Uses of I2NPMessage in net.i2p.router.networkdb
Modifier and TypeMethodDescriptionprotected void
HandleDatabaseLookupMessageJob.sendMessage
(I2NPMessage message, Hash toPeer, TunnelId replyTunnel) -
Uses of I2NPMessage in net.i2p.router.networkdb.kademlia
Modifier and TypeMethodDescriptionprotected I2NPMessage
ExploreJob.buildMessage
(TunnelId replyTunnelId, Hash replyGateway, long expiration, RouterInfo peer) Build the database search message, but unlike the normal searches, we're more explicit in what we /dont/ want.protected I2NPMessage
SearchJob.buildMessage
(TunnelId replyTunnelId, Hash replyGateway, long expiration, RouterInfo peer) Build the database search messageModifier and TypeMethodDescriptionFloodfillDatabaseLookupMessageHandler.createJob
(I2NPMessage receivedMessage, RouterIdentity from, Hash fromHash) FloodfillDatabaseStoreMessageHandler.createJob
(I2NPMessage receivedMessage, RouterIdentity from, Hash fromHash) boolean
FloodOnlyLookupSelector.isMatch
(I2NPMessage message) boolean
IterativeLookupSelector.isMatch
(I2NPMessage message) This only returns true for DSMs, not for DSRMs.boolean
SearchMessageSelector.isMatch
(I2NPMessage message) boolean
StoreMessageSelector.isMatch
(I2NPMessage message) void
DirectLookupMatchJob.setMessage
(I2NPMessage message) Override to not call failed() in setMessage(), as it will be called from runJob()void
FloodOnlyLookupMatchJob.setMessage
(I2NPMessage message) void
SearchUpdateReplyFoundJob.setMessage
(I2NPMessage message) (package private) static MessageWrapper.WrappedMessage
MessageWrapper.wrap
(RouterContext ctx, I2NPMessage m, Hash from, RouterInfo to) Garlic wrap a message from a client or this router, destined for a router, to hide the contents from the OBEP.static GarlicMessage
MessageWrapper.wrap
(RouterContext ctx, I2NPMessage m, RouterInfo to) Garlic wrap a message from nobody, destined for a router, to hide the contents from the OBEP.static GarlicMessage
MessageWrapper.wrap
(RouterContext ctx, I2NPMessage m, SessionKey encryptKey, SessionTag encryptTag) Garlic wrap a message from nobody, destined for an unknown router, to hide the contents from the IBGW.static GarlicMessage
MessageWrapper.wrap
(RouterContext ctx, I2NPMessage m, SessionKey encryptKey, RatchetSessionTag encryptTag) Garlic wrap a message from nobody, destined for an unknown router, to hide the contents from the IBGW.static GarlicMessage
MessageWrapper.wrap
(RouterContext ctx, I2NPMessage m, MessageWrapper.OneTimeSession session) Garlic wrap a message from nobody, destined for an unknown router, to hide the contents from the IBGW. -
Uses of I2NPMessage in net.i2p.router.transport
Modifier and TypeMethodDescriptionOutboundMessageRegistry.getOriginalMessages
(I2NPMessage message) Retrieve all messages that are waiting for the specified message.void
TransportEventListener.messageReceived
(I2NPMessage message, RouterIdentity fromRouter, Hash fromRouterHash) Message receivedvoid
TransportImpl.messageReceived
(I2NPMessage inMsg, RouterIdentity remoteIdent, Hash remoteIdentHash, long msToReceive, int bytesReceived) Message received from the I2NPMessageReader - send it to the listenervoid
TransportManager.messageReceived
(I2NPMessage message, RouterIdentity fromRouter, Hash fromRouterHash) Message received -
Uses of I2NPMessage in net.i2p.router.transport.ntcp
Modifier and TypeMethodDescriptionvoid
InboundEstablishState.gotI2NP
(I2NPMessage msg) void
NTCP2Payload.PayloadCallback.gotI2NP
(I2NPMessage msg) -
Uses of I2NPMessage in net.i2p.router.transport.udp
Modifier and TypeMethodDescriptionvoid
InboundEstablishState2.gotI2NP
(I2NPMessage msg) void
OutboundEstablishState2.gotI2NP
(I2NPMessage msg) void
PeerState2.gotI2NP
(I2NPMessage msg) void
SSU2Payload.PayloadCallback.gotI2NP
(I2NPMessage msg) void
UDPTransport.messageReceived
(I2NPMessage inMsg, RouterIdentity remoteIdent, Hash remoteIdentHash, long msToReceive, int bytesReceived) infinite loop public RouterAddress getCurrentAddress() { if (needsRebuild()) rebuildExternalAddress(false); return super.getCurrentAddress(); }(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.(package private) void
UDPTransport.send
(I2NPMessage msg, PeerState peer) "injected" message from the EstablishmentManager.Modifier and TypeMethodDescription(package private) void
UDPTransport.send
(List<I2NPMessage> msgs, PeerState peer) "injected" messages from the EstablishmentManager.ModifierConstructorDescriptionOutboundMessageState
(I2PAppContext context, I2NPMessage msg, PeerState peer) "injected" message from the establisher. -
Uses of I2NPMessage in net.i2p.router.tunnel
Modifier and TypeMethodDescriptionvoid
PumpedTunnelGateway.add
(I2NPMessage msg, Hash toRouter, TunnelId toTunnel) Add a message to be sent down the tunnel, either sending it now (perhaps coallesced with other pending messages) or after a brief pause (_flushFrequency).void
ThrottledPumpedTunnelGateway.add
(I2NPMessage msg, Hash toRouter, TunnelId toTunnel) Possibly drop a message due to bandwidth before adding it to the preprocessor queue.void
TunnelGateway.add
(I2NPMessage msg, Hash toRouter, TunnelId toTunnel) Add a message to be sent down the tunnel, either sending it now (perhaps coallesced with other pending messages) or after a brief pause (_flushFrequency).void
TunnelGatewayZeroHop.add
(I2NPMessage msg, Hash toRouter, TunnelId toTunnel) Add a message to be sent down the tunnel (immediately forwarding it to theInboundMessageDistributor
orOutboundMessageDistributor
, as necessary).void
TunnelDispatcher.dispatchOutbound
(I2NPMessage msg, TunnelId outboundTunnel, Hash targetPeer) We are the outbound tunnel gateway (we created it), so wrap up this message with instructions to be forwarded to the targetPeer when it reaches the endpoint.void
TunnelDispatcher.dispatchOutbound
(I2NPMessage msg, TunnelId outboundTunnel, TunnelId targetTunnel, Hash targetPeer) We are the outbound tunnel gateway (we created it), so wrap up this message with instructions to be forwarded to the targetTunnel on the targetPeer when it reaches the endpoint.void
InboundMessageDistributor.distribute
(I2NPMessage msg, Hash target) void
InboundMessageDistributor.distribute
(I2NPMessage msg, Hash target, TunnelId tunnel) void
OutboundMessageDistributor.distribute
(I2NPMessage msg, Hash target) void
OutboundMessageDistributor.distribute
(I2NPMessage msg, Hash target, TunnelId tunnel) void
InboundMessageDistributor.handleClove
(DeliveryInstructions instructions, I2NPMessage data) Handle a clove removed from the garlic messagevoid
FragmentHandler.DefragmentedReceiver.receiveComplete
(I2NPMessage msg, Hash toRouter, TunnelId toTunnel) Receive a fully formed I2NPMessage out of the tunnelModifierConstructorDescriptionOutboundGatewayMessage
(I2NPMessage message, Hash toRouter, TunnelId toTunnel) PendingGatewayMessage
(I2NPMessage message, Hash toRouter, TunnelId toTunnel)