java.lang.Object
net.i2p.data.i2np.I2NPMessageImpl
net.i2p.data.i2np.TunnelBuildMessageBase
net.i2p.data.i2np.TunnelBuildReplyMessage
net.i2p.data.i2np.ShortTunnelBuildReplyMessage
- All Implemented Interfaces:
I2NPMessage
Internal use only, to convert an inbound STBM to a reply. Never serialized/deserialized/sent/received. See BuildHandler and BuildReplyHandler.
Nested Class Summary
Nested classes/interfaces inherited from class I2NPMessageImpl
I2NPMessageImpl.BuilderModifier and TypeClassDescriptionstatic interfaceInterface for extending the types of messages handled - unused.Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intImpossible value, more than 1 byte.static final intByte length every short build record in this reply must have.Fields inherited from class TunnelBuildMessageBase
_records, MAX_RECORD_COUNT, RECORD_COUNT, RECORD_SIZEModifier and TypeFieldDescriptionprotected EncryptedBuildRecord[]The encrypted records, one per hop, or null untilTunnelBuildMessageBase.readMessage(byte[], int, int, int).static final intMaximum number of records in any tunnel build message (8 hops).protected intNumber of records in _records, zero if not yet set.static final intSize in bytes of one encrypted record: 16 byte IV + 512 byte payload.Fields inherited from class I2NPMessageImpl
_context, _expiration, _log, CHECKSUM_LENGTH, DEFAULT_EXPIRATION_MS, HEADER_LENGTHModifier and TypeFieldDescriptionprotected final I2PAppContextApplication context this message belongs to.protected longExpiration time in milliseconds since the epoch, as an I2P Date.protected final LogLog for the message class, taken from the context's log manager.static final intNumber of checksum bytes the message header carries.static final longDefault lifetime of an unsent message, one minute in milliseconds.static final intI2NP message header size in bytes.Fields inherited from interface I2NPMessage
MAX_ID_VALUE, MAX_SIZEModifier and TypeFieldDescriptionstatic final long4 bytes unsigned.static final intNominal limit, actual max is much less.Constructor Summary
ConstructorsConstructorDescriptionShortTunnelBuildReplyMessage(I2PAppContext context, int records) Creates a reply with preallocated slots for the given number of records.Method Summary
Public MethodsModifier and TypeMethodDescriptionprotected intWritten length of the message body, zero since never serialized.intgetType()I2NP message type of a short tunnel build reply, never sent.voidreadMessage(byte[] data, int offset, int dataSize, int type) Unsupported; the reply is never deserialized.voidsetRecord(int index, EncryptedBuildRecord record) Store a build record, checking its length.toString()String form for debugging, showing the id and record count.protected intwriteMessageBody(byte[] out, int curIndex) Unsupported; the reply is never serialized.Methods inherited from class TunnelBuildMessageBase
getRecord, getRecordCountModifier and TypeMethodDescriptiongetRecord(int index) Build record at the given index, may be null.intHow many encrypted build records this message carries, which sets both the length of every hop record array and the tunnel's depth.Methods inherited from class I2NPMessageImpl
createMessage, fromRawByteArray, fromRawByteArrayNTCP2, getMessageExpiration, getMessageSize, getRawMessageSize, getUniqueId, getUniqueId, readBytes, readBytes, readMessage, setMessageExpiration, setUniqueId, toByteArray, toByteArray, toByteArray, toRawByteArray, toRawByteArrayNTCP2Modifier and TypeMethodDescriptionstatic I2NPMessagecreateMessage(I2PAppContext context, int type) Yes, this is fairly ugly, but its the only place it ever happens.static I2NPMessagefromRawByteArray(I2PAppContext ctx, byte[] buffer, int offset, int len, I2NPMessageHandler handler) Read the message with a short 5-byte header.static I2NPMessagefromRawByteArrayNTCP2(I2PAppContext ctx, byte[] buffer, int offset, int len, I2NPMessageHandler handler) Read the message with a short 9-byte header.longDate after which the message should be dropped (and the associated uniqueId forgotten).intSerialized message size, including the 16-byte header.intThe raw header consists of a one-byte type and a 4-byte expiration in seconds only.longUnique id for this message, lazily initialized when negative.longgetUniqueId(long msgIDBloomXor) Replay resistant message Id.intreadBytes(byte[] data, int type, int offset) Read the header, then read the rest into buffer, then call readMessage in the implemented message type.intreadBytes(byte[] data, int type, int offset, int maxLen) Limit the max to read from the data buffer, so that we can use a large buffer but prevent the reader from reading off the end.voidreadMessage(byte[] data, int offset, int dataSize, int type, I2NPMessageHandler handler) Read the message fields from the byte array, ignoring the handler.voidsetMessageExpiration(long exp) The expiration is set to one minute from now in the constructor but it can be overridden here.voidsetUniqueId(long id) The ID is set to a random value when written but it can be overridden here.byte[]The message serialized into a new byte array.inttoByteArray(byte[] buffer) Write the message to the buffer, returning the number of bytes written.inttoByteArray(byte[] buffer, int off) Write the message to the buffer, returning the new offset (NOT the length).inttoRawByteArray(byte[] buffer) Write the message with a short 5-byte header.inttoRawByteArrayNTCP2(byte[] buffer, int off) Write the message to the buffer, returning the new offset (NOT the length).
Field Details
MESSAGE_TYPE
public static final int MESSAGE_TYPEImpossible value, more than 1 byte.- See Also:
SHORT_RECORD_SIZE
public static final int SHORT_RECORD_SIZEByte length every short build record in this reply must have.- See Also:
Constructor Details
ShortTunnelBuildReplyMessage
Creates a reply with preallocated slots for the given number of records.- Parameters:
context- the context owning the reply's random source and clockrecords- number of short build records to preallocate slots for
Method Details
setRecord
Store a build record, checking its length.- Overrides:
setRecordin classTunnelBuildMessageBase- Parameters:
index- the zero-based position of the record in the record arrayrecord- must be ShortEncryptedBuildRecord or null
calculateWrittenLength
protected int calculateWrittenLength()Written length of the message body, zero since never serialized.- Overrides:
calculateWrittenLengthin classTunnelBuildMessageBase- Returns:
- the number of bytes the body will occupy once serialized
getType
public int getType()I2NP message type of a short tunnel build reply, never sent.- Specified by:
getTypein interfaceI2NPMessage- Overrides:
getTypein classTunnelBuildReplyMessage- Returns:
MESSAGE_TYPE, 999
readMessage
public void readMessage(byte[] data, int offset, int dataSize, int type) throws I2NPMessageException Unsupported; the reply is never deserialized.- Specified by:
readMessagein interfaceI2NPMessage- Overrides:
readMessagein classTunnelBuildMessageBase- Parameters:
data- data to read fromoffset- where to start in the data arraydataSize- how long into the data to readtype- I2NP message type- Throws:
UnsupportedOperationException- always, nothing constructs this from wire dataI2NPMessageException- if the stream doesn't contain a valid message that this class can read.
writeMessageBody
Unsupported; the reply is never serialized.- Overrides:
writeMessageBodyin classTunnelBuildMessageBase- Parameters:
out- the buffer to serialize the body intocurIndex- the offset into out at which to begin writing; leave room for the signature where the header format calls for one- Returns:
- the index into the array after the last byte written (NOT the length)
- Throws:
UnsupportedOperationException- always, nothing puts this type on the wireI2NPMessageException- if the body cannot be serialized into out, because it is too small or a field is unserializable
toString
String form for debugging, showing the id and record count.- Overrides:
toStringin classTunnelBuildReplyMessage