net.i2p.data.i2np
Class DatabaseLookupMessage

java.lang.Object
  extended by net.i2p.data.DataStructureImpl
      extended by net.i2p.data.i2np.I2NPMessageImpl
          extended by net.i2p.data.i2np.FastI2NPMessageImpl
              extended by net.i2p.data.i2np.DatabaseLookupMessage
All Implemented Interfaces:
DataStructure, I2NPMessage

public class DatabaseLookupMessage
extends FastI2NPMessageImpl

Defines the message a router sends to another router to search for a key in the network database.

Author:
jrandom

Nested Class Summary
 
Nested classes/interfaces inherited from class net.i2p.data.i2np.I2NPMessageImpl
I2NPMessageImpl.Builder
 
Field Summary
static int MESSAGE_TYPE
           
 
Fields inherited from class net.i2p.data.i2np.FastI2NPMessageImpl
_checksum, _hasChecksum
 
Fields inherited from class net.i2p.data.i2np.I2NPMessageImpl
_context, _expiration, _log, _uniqueId, CHECKSUM_LENGTH, DEFAULT_EXPIRATION_MS, HEADER_LENGTH
 
Fields inherited from interface net.i2p.data.i2np.I2NPMessage
MAX_ID_VALUE, MAX_SIZE
 
Constructor Summary
DatabaseLookupMessage(I2PAppContext context)
           
DatabaseLookupMessage(I2PAppContext context, boolean locallyCreated)
           
 
Method Summary
 void addDontIncludePeer(Hash peer)
          Add to the set.
 void addDontIncludePeers(Collection<Hash> peers)
          Add to the set.
protected  int calculateWrittenLength()
          calculate the message body's length (not including the header and footer
 boolean equals(Object object)
           
 Set<Hash> getDontIncludePeers()
          Set of peers that a lookup reply should NOT include.
 Hash getFrom()
          Contains the router who requested this lookup
 TunnelId getReplyTunnel()
          Contains the tunnel ID a reply should be sent to
 Hash getSearchKey()
          Defines the key being searched for
 int getType()
          Return the unique identifier for this type of I2NP message, as defined in the I2NP spec
 int hashCode()
           
 void readMessage(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 specification
 void setDontIncludePeers(Collection<Hash> peers)
          Replace the dontInclude set with this set.
 void setFrom(Hash from)
           
 void setReplyTunnel(TunnelId replyTunnel)
           
 void setSearchKey(Hash key)
           
 String toString()
           
protected  int writeMessageBody(byte[] out, int curIndex)
          write the message body to the output array, starting at the given index.
 
Methods inherited from class net.i2p.data.i2np.FastI2NPMessageImpl
readBytes, readBytes, readBytes, toByteArray, toByteArrayWithSavedChecksum, writeBytes
 
Methods inherited from class net.i2p.data.i2np.I2NPMessageImpl
createMessage, fromRawByteArray, getMessageExpiration, getMessageSize, getRawMessageSize, getUniqueId, readBytes, readMessage, registerBuilder, setMessageExpiration, setUniqueId, toByteArray, toRawByteArray
 
Methods inherited from class net.i2p.data.DataStructureImpl
calculateHash, fromBase64, fromByteArray, read, toBase64
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface net.i2p.data.DataStructure
calculateHash, fromBase64, fromByteArray, toBase64
 

Field Detail

MESSAGE_TYPE

public static final int MESSAGE_TYPE
See Also:
Constant Field Values
Constructor Detail

DatabaseLookupMessage

public DatabaseLookupMessage(I2PAppContext context)

DatabaseLookupMessage

public DatabaseLookupMessage(I2PAppContext context,
                             boolean locallyCreated)
Parameters:
locallyCreated - ignored
Method Detail

getSearchKey

public Hash getSearchKey()
Defines the key being searched for


setSearchKey

public void setSearchKey(Hash key)
Throws:
IllegalStateException - if key previously set, to protect saved checksum

getFrom

public Hash getFrom()
Contains the router who requested this lookup


setFrom

public void setFrom(Hash from)
Throws:
IllegalStateException - if from previously set, to protect saved checksum

getReplyTunnel

public TunnelId getReplyTunnel()
Contains the tunnel ID a reply should be sent to


setReplyTunnel

public void setReplyTunnel(TunnelId replyTunnel)
Throws:
IllegalStateException - if tunnel previously set, to protect saved checksum

getDontIncludePeers

public Set<Hash> getDontIncludePeers()
Set of peers that a lookup reply should NOT include. WARNING - returns a copy.

Returns:
Set of Hash objects, each of which is the H(routerIdentity) to skip, or null

setDontIncludePeers

public void setDontIncludePeers(Collection<Hash> peers)
Replace the dontInclude set with this set. WARNING - makes a copy. Invalidates the checksum.

Parameters:
peers - may be null

addDontIncludePeer

public void addDontIncludePeer(Hash peer)
Add to the set. Invalidates the checksum.

Parameters:
peer - non-null
Since:
0.8.12

addDontIncludePeers

public void addDontIncludePeers(Collection<Hash> peers)
Add to the set. Invalidates the checksum.

Parameters:
peers - non-null
Since:
0.8.12

readMessage

public void readMessage(byte[] data,
                        int offset,
                        int dataSize,
                        int type)
                 throws I2NPMessageException
Description copied from interface: I2NPMessage
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 specification

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()
Description copied from class: I2NPMessageImpl
calculate the message body's length (not including the header and footer

Specified by:
calculateWrittenLength in class I2NPMessageImpl

writeMessageBody

protected int writeMessageBody(byte[] out,
                               int curIndex)
                        throws I2NPMessageException
Description copied from class: I2NPMessageImpl
write the message body to the output array, starting at the given index.

Specified by:
writeMessageBody in class I2NPMessageImpl
Returns:
the index into the array after the last byte written
Throws:
I2NPMessageException

getType

public int getType()
Description copied from interface: I2NPMessage
Return the unique identifier for this type of I2NP message, as defined in the I2NP spec


hashCode

public int hashCode()
Overrides:
hashCode in class Object

equals

public boolean equals(Object object)
Overrides:
equals in class Object

toString

public String toString()
Overrides:
toString in class Object