Package net.i2p.data.i2np
Class DatabaseStoreMessage
java.lang.Object
net.i2p.data.i2np.I2NPMessageImpl
net.i2p.data.i2np.FastI2NPMessageImpl
net.i2p.data.i2np.DatabaseStoreMessage
- All Implemented Interfaces:
I2NPMessage
public class DatabaseStoreMessage extends FastI2NPMessageImpl
Defines the message a router sends to another router to test the network
database reachability, as well as the reply message sent back.
TODO: Don't decompress and recompress RouterInfos at the OBEP and IBGW.
Could this even change the message length or corrupt things?
- Author:
- jrandom
-
Nested Class Summary
Nested classes/interfaces inherited from class net.i2p.data.i2np.I2NPMessageImpl
I2NPMessageImpl.Builder -
Field Summary
Fields Modifier and Type Field Description static intMESSAGE_TYPEFields inherited from class net.i2p.data.i2np.I2NPMessageImpl
_context, _expiration, _log, CHECKSUM_LENGTH, DEFAULT_EXPIRATION_MS, HEADER_LENGTH -
Constructor Summary
Constructors Constructor Description DatabaseStoreMessage(I2PAppContext context) -
Method Summary
Modifier and Type Method Description protected intcalculateWrittenLength()calculate the message body's length (not including the header and footer)booleanequals(Object object)DatabaseEntrygetEntry()Defines the entry in the network database being storedHashgetKey()Defines the key in the network database being storedHashgetReplyGateway()longgetReplyToken()If a reply is desired, this token specifies the message ID that should be used for a DeliveryStatusMessage to be sent to the reply tunnel on the reply gateway.TunnelIdgetReplyTunnel()intgetType()Return the unique identifier for this type of I2NP message, as defined in the I2NP specinthashCode()voidreadMessage(byte[] data, int offset, int dataSize, int type)Read the body into the data structures, after the initial type byte and the uniqueId / expiration, using the current class's format as defined by the I2NP specificationvoidsetEntry(DatabaseEntry entry)This also sets the keyvoidsetReplyGateway(Hash peer)voidsetReplyToken(long token)Update the reply token.voidsetReplyTunnel(TunnelId id)StringtoString()protected intwriteMessageBody(byte[] out, int curIndex)write the message body to the output array, starting at the given indexMethods inherited from class net.i2p.data.i2np.FastI2NPMessageImpl
readBytes, toByteArray, toByteArrayWithSavedChecksumMethods inherited from class net.i2p.data.i2np.I2NPMessageImpl
createMessage, fromRawByteArray, fromRawByteArrayNTCP2, getMessageExpiration, getMessageSize, getRawMessageSize, getUniqueId, readBytes, readBytes, readMessage, registerBuilder, setMessageExpiration, setUniqueId, toByteArray, toByteArray, toRawByteArray, toRawByteArrayNTCP2, writeBytes
-
Field Details
-
MESSAGE_TYPE
public static final int MESSAGE_TYPE- See Also:
- Constant Field Values
-
-
Constructor Details
-
Method Details
-
getKey
Defines the key in the network database being stored -
getEntry
Defines the entry in the network database being stored -
setEntry
This also sets the key- Throws:
IllegalStateException- if data previously set, to protect saved checksum
-
getReplyToken
public long getReplyToken()If a reply is desired, this token specifies the message ID that should be used for a DeliveryStatusMessage to be sent to the reply tunnel on the reply gateway.- Returns:
- positive reply token ID, or 0 if no reply is necessary.
-
setReplyToken
Update the reply token.- Throws:
IllegalArgumentException- if the token is out of range (min=0, max=I2NPMessage.MAX_ID_VALUE)
-
getReplyTunnel
-
setReplyTunnel
-
getReplyGateway
-
setReplyGateway
-
readMessage
public void readMessage(byte[] data, int offset, int dataSize, int type) throws I2NPMessageExceptionDescription copied from interface:I2NPMessageRead the body into the data structures, after the initial type byte and the uniqueId / expiration, using the current class's format as defined by the I2NP specification- Parameters:
data- data to read fromoffset- where to start in the data arraydataSize- how long into the data to readtype- I2NP message type- Throws:
I2NPMessageException- if the stream doesn't contain a valid message that this class can read.
-
calculateWrittenLength
protected int calculateWrittenLength()calculate the message body's length (not including the header and footer)- Specified by:
calculateWrittenLengthin classI2NPMessageImpl- Throws:
IllegalStateException
-
writeMessageBody
write the message body to the output array, starting at the given index- Specified by:
writeMessageBodyin classI2NPMessageImpl- Returns:
- the index into the array after the last byte written (NOT the length)
- Throws:
I2NPMessageException
-
getType
public int getType()Description copied from interface:I2NPMessageReturn the unique identifier for this type of I2NP message, as defined in the I2NP spec -
hashCode
public int hashCode() -
equals
-
toString
-