HandleFloodfillDatabaseLookupMessageJob

net.i2p.router.networkdb.kademlia.HandleFloodfillDatabaseLookupMessageJob

All Implemented Interfaces:: Job

public class HandleFloodfillDatabaseLookupMessageJobextends HandleDatabaseLookupMessageJob

Processes database lookup messages received by floodfill routers.

Handles incoming DatabaseLookupMessage requests from remote peers, performing database searches and sending appropriate replies. Extends the base lookup handling with floodfill-specific logic including query acceptance criteria and capability-based response behavior.

Determines whether to answer all queries based on floodfill status and capability flags. When not operating as floodfill, includes the local RouterInfo in responses to inform peers of the capability change and reduce misdirected queries.

Field Summary
Fields inherited from class HandleDatabaseLookupMessageJob
EXPIRE_DELAY
Modifier and Type
Field
Description
static final long
EXPIRE_DELAY
If a routerInfo structure isn't this recent, don't send it out.
Fields inherited from class JobImpl
_id
Modifier and Type
Field
Description
final long
_id
Unique job identifier.
Constructor Summary
Constructors
Constructor
Description
HandleFloodfillDatabaseLookupMessageJob(RouterContext ctx, DatabaseLookupMessage receivedMessage, RouterIdentity from, Hash fromHash, long msgIDBloomXor)
Creates a new job to handle a floodfill database lookup message.
Method Summary
All Methods
Modifier and Type
Method
Description
protected void
sendClosest(Hash key, Set<Hash> routerInfoSet, Hash toPeer, TunnelId replyTunnel)
We extend this here to send our routerInfo back as well, if we are not floodfill.
Methods inherited from class HandleDatabaseLookupMessageJob
dropped, getName, runJob, sendMessage
Modifier and Type
Method
Description
void
dropped()
Default implementation does nothing.
String
getName()
Descriptive name of the task.
void
runJob()
Actually perform the task.
protected void
sendMessage(I2NPMessage message, Hash toPeer, TunnelId replyTunnel)
Send an I2NP message to the specified peer.
Methods inherited from class JobImpl
getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
Modifier and Type
Method
Description
final RouterContext
getContext()
The router context that this job belongs to.
long
getJobId()
The unique job ID for this job.
long
getMadeReadyOn()
The timestamp when this job was last made ready for execution.
JobTiming
getTiming()
The timing object for this job.
void
madeReady(long now)
For JobQueue only, not for external use.
protected void
requeue(long delayMs)
Requeue this job to run after the specified delay.
String
toString()

Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- HandleFloodfillDatabaseLookupMessageJob
  public HandleFloodfillDatabaseLookupMessageJob(RouterContext ctx, DatabaseLookupMessage receivedMessage, RouterIdentity from, Hash fromHash, long msgIDBloomXor)
  Creates a new job to handle a floodfill database lookup message.
  Parameters:
  ctx - the router context
  receivedMessage - the lookup message received
  from - the router identity of the sender
  fromHash - the hash of the sender
  msgIDBloomXor - the message ID bloom XOR
Method Details
- sendClosest
  protected void sendClosest(Hash key, Set<Hash> routerInfoSet, Hash toPeer, TunnelId replyTunnel)
  We extend this here to send our routerInfo back as well, if we are not floodfill. This gets the word out to routers that we are no longer floodfill, so they will stop bugging us.
  Overrides:
  sendClosest in class HandleDatabaseLookupMessageJob
  Parameters:
  key - the search key
  routerInfoSet - the set of router hashes to send
  toPeer - the destination peer
  replyTunnel - the reply tunnel

Field Summary

Fields inherited from class HandleDatabaseLookupMessageJob

Fields inherited from class JobImpl

Constructor Summary

Method Summary

Methods inherited from class HandleDatabaseLookupMessageJob

Methods inherited from class JobImpl

Methods inherited from class Object

Constructor Details

HandleFloodfillDatabaseLookupMessageJob

Method Details

sendClosest