DatabaseSearchReplyMessage

net.i2p.data.i2np.DatabaseSearchReplyMessage

All Implemented Interfaces:: I2NPMessage

public class DatabaseSearchReplyMessageextends FastI2NPMessageImpl

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.

Nested Class Summary
Nested classes/interfaces inherited from class I2NPMessageImpl
I2NPMessageImpl.Builder
Modifier and Type
Class
Description
static interface
I2NPMessageImpl.Builder
Interface for extending the types of messages handled - unused.
Field Summary
Modifier and Type
Field
Description
private Hash
_from
The router sending the reply.
private Hash
_key
The hash that was looked up.
private final List<Hash>
_peerHashes
The peers found, closest first.
static final int
MESSAGE_TYPE
I2NP message type ID written to the wire header.
Fields inherited from class FastI2NPMessageImpl
_checksum, _hasChecksum
Modifier and Type
Field
Description
protected byte
_checksum
One-byte checksum.
protected boolean
_hasChecksum
Whether the message includes a checksum.
Fields inherited from class I2NPMessageImpl
_context, _expiration, _log, CHECKSUM_LENGTH, DEFAULT_EXPIRATION_MS, HEADER_LENGTH
Modifier and Type
Field
Description
protected final I2PAppContext
_context
Application context this message belongs to.
protected long
_expiration
Expiration time in milliseconds since the epoch, as an I2P Date.
protected final Log
_log
Log for the message class, taken from the context's log manager.
static final int
CHECKSUM_LENGTH
Number of checksum bytes the message header carries.
static final long
DEFAULT_EXPIRATION_MS
Default lifetime of an unsent message, one minute in milliseconds.
static final int
HEADER_LENGTH
I2NP message header size in bytes.
Fields inherited from interface I2NPMessage
MAX_ID_VALUE, MAX_SIZE
Modifier and Type
Field
Description
static final long
MAX_ID_VALUE
4 bytes unsigned.
static final int
MAX_SIZE
Nominal limit, actual max is much less.
Constructor Summary
Constructors
Constructor
Description
DatabaseSearchReplyMessage(I2PAppContext context)
Builds a reply carrying no peers yet, with the list ready to fill.
Method Summary
Public Methods
Modifier and Type
Method
Description
void
addReply(Hash peer)
Adds a peer hash to the reply.
protected int
calculateWrittenLength()
Calculate the message body's length (not including the header and footer).
boolean
equals(Object object)
Compares this message to another for equality of all fields.
Hash
getFromHash()
The router that sent this reply.
int
getNumReplies()
The number of peer hashes included in the reply.
Hash
getReply(int index)
The peer hash at the given index.
Hash
getSearchKey()
Defines the key being searched for.
int
getType()
The message type.
int
hashCode()
Hash code calculated from the message fields.
void
readMessage(byte[] data, int offset, int dataSize, int type)
Reads the message fields from the byte array.
void
setFromHash(Hash from)
Assigns the router that sent this reply.
void
setSearchKey(Hash key)
Assigns the key being searched for.
String
toString()
String form of the message, suitable for debugging.
protected int
writeMessageBody(byte[] out, int curIndex)
Write the message body to the output array, starting at the given index.
Methods inherited from class FastI2NPMessageImpl
readBytes, toByteArray, toByteArrayWithSavedChecksum
Modifier and Type
Method
Description
int
readBytes(byte[] data, int type, int offset, int maxLen)
Ignore, but save, the checksum, to be used later if necessary.
int
toByteArray(byte[] buffer)
If available, use the previously-computed or previously-read checksum for speed.
protected int
toByteArrayWithSavedChecksum(byte[] buffer)
Use a previously-computed checksum for speed.
Methods inherited from class I2NPMessageImpl
createMessage, fromRawByteArray, fromRawByteArrayNTCP2, getMessageExpiration, getMessageSize, getRawMessageSize, getUniqueId, getUniqueId, readBytes, readMessage, setMessageExpiration, setUniqueId, toByteArray, toByteArray, toRawByteArray, toRawByteArrayNTCP2
Modifier and Type
Method
Description
static I2NPMessage
createMessage(I2PAppContext context, int type)
Yes, this is fairly ugly, but its the only place it ever happens.
static I2NPMessage
fromRawByteArray(I2PAppContext ctx, byte[] buffer, int offset, int len, I2NPMessageHandler handler)
Read the message with a short 5-byte header.
static I2NPMessage
fromRawByteArrayNTCP2(I2PAppContext ctx, byte[] buffer, int offset, int len, I2NPMessageHandler handler)
Read the message with a short 9-byte header.
long
getMessageExpiration()
Date after which the message should be dropped (and the associated uniqueId forgotten).
int
getMessageSize()
Serialized message size, including the 16-byte header.
int
getRawMessageSize()
The raw header consists of a one-byte type and a 4-byte expiration in seconds only.
long
getUniqueId()
Unique id for this message, lazily initialized when negative.
long
getUniqueId(long msgIDBloomXor)
Replay resistant message Id.
int
readBytes(byte[] data, int type, int offset)
Read the header, then read the rest into buffer, then call readMessage in the implemented message type.
void
readMessage(byte[] data, int offset, int dataSize, int type, I2NPMessageHandler handler)
Read the message fields from the byte array, ignoring the handler.
void
setMessageExpiration(long exp)
The expiration is set to one minute from now in the constructor but it can be overridden here.
void
setUniqueId(long id)
The ID is set to a random value when written but it can be overridden here.
byte[]
toByteArray()
The message serialized into a new byte array.
int
toByteArray(byte[] buffer, int off)
Write the message to the buffer, returning the new offset (NOT the length).
int
toRawByteArray(byte[] buffer)
Write the message with a short 5-byte header.
int
toRawByteArrayNTCP2(byte[] buffer, int off)
Write the message to the buffer, returning the new offset (NOT the length).
Methods inherited from class Object
clone, getClass, notify, notifyAll, wait, wait, wait

Field Details
- MESSAGE_TYPE
  public static final int MESSAGE_TYPE
  I2NP message type ID written to the wire header.
  See Also:
  Constant Field Values
- _key
  private Hash _key
  The hash that was looked up.
- _peerHashes
  private final List<Hash> _peerHashes
  The peers found, closest first.
- _from
  private Hash _from
  The router sending the reply.
Constructor Details
- DatabaseSearchReplyMessage
  public DatabaseSearchReplyMessage(I2PAppContext context)
  Builds a reply carrying no peers yet, with the list ready to fill.
  Parameters:
  context - the context to use for the message
Method Details
- getSearchKey
  public Hash getSearchKey()
  Defines the key being searched for.
  Returns:
  the search key
- setSearchKey
  public void setSearchKey(Hash key)
  Assigns the key being searched for.
  Parameters:
  key - the hash being searched for; it may only be assigned once
  Throws:
  IllegalStateException - if key previously set, to protect saved checksum
- getNumReplies
  public int getNumReplies()
  The number of peer hashes included in the reply.
  Returns:
  the num replies
- getReply
  public Hash getReply(int index)
  The peer hash at the given index.
  Parameters:
  index - the position of the wanted peer hash in the reply list
  Returns:
  the router hash found at that index in the reply list
- addReply
  public void addReply(Hash peer)
  Adds a peer hash to the reply.
  Parameters:
  peer - the hash of the router answering the search, appended to the reply list
- getFromHash
  public Hash getFromHash()
  The router that sent this reply.
  Returns:
  the from hash
- setFromHash
  public void setFromHash(Hash from)
  Assigns the router that sent this reply.
  Parameters:
  from - the hash of the router whose database was searched
- readMessage
  public void readMessage(byte[] data, int offset, int dataSize, int type) throws I2NPMessageException
  Reads the message fields from the byte array.
  Parameters:
  data - data to read from
  offset - where to start in the data array
  dataSize - how long into the data to read
  type - 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:
  calculateWrittenLength in class I2NPMessageImpl
  Returns:
  the number of bytes the body will occupy once serialized
- writeMessageBody
  protected int writeMessageBody(byte[] out, int curIndex) throws I2NPMessageException
  Write the message body to the output array, starting at the given index.
  Specified by:
  writeMessageBody in class I2NPMessageImpl
  Parameters:
  out - the buffer to serialize the body into
  curIndex - 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:
  I2NPMessageException - if the body cannot be serialized into out, because it is too small or a field is unserializable
- getType
  public int getType()
  The message type.
  Returns:
  the I2NP message type ID, always MESSAGE_TYPE
- equals
  public boolean equals(Object object)
  Compares this message to another for equality of all fields.
  Overrides:
  equals in class Object
- hashCode
  public int hashCode()
  Hash code calculated from the message fields.
  Overrides:
  hashCode in class Object
  Returns:
  the hash code
- toString
  public String toString()
  String form of the message, suitable for debugging.
  Overrides:
  toString in class Object

Nested Class Summary

Nested classes/interfaces inherited from class I2NPMessageImpl

Field Summary

Fields inherited from class FastI2NPMessageImpl

Fields inherited from class I2NPMessageImpl

Fields inherited from interface I2NPMessage

Constructor Summary

Method Summary

Methods inherited from class FastI2NPMessageImpl

Methods inherited from class I2NPMessageImpl

Methods inherited from class Object

Field Details

MESSAGE_TYPE

_key

_peerHashes

_from

Constructor Details

Method Details

getSearchKey

setSearchKey

getNumReplies

getReply

addReply

getFromHash

setFromHash

readMessage

calculateWrittenLength

writeMessageBody

getType

equals

hashCode

toString