SingleSearchJob

net.i2p.router.networkdb.kademlia.SingleSearchJob

All Implemented Interfaces:: Job

Direct Known Subclasses:: IterativeFollowupJob

class SingleSearchJobextends FloodOnlySearchJob

Performs a targeted lookup to a single peer for a specific key.

This specialized search job queries exactly one peer for a RouterInfo associated with the target key. Despite extending FloodOnlySearchJob, this is not a flood operation but rather a direct, point-to-point lookup designed for specific scenarios where the target peer is known.

Used primarily for followup operations and targeted peer validation where the response from a specific peer is required. The job handles tunnel selection, message construction, and timeout management for reliable single-peer communication.

Field Summary
Fields
Modifier and Type
Field
Description
private OutNetMessage
_onm
The lookup message awaiting a reply.
private final Hash
_to
The hash being looked up.
private static final int
TIMEOUT
How long to wait for the reply - 8 seconds.
Fields inherited from class FloodOnlySearchJob
_onReply, _onTimeout, _replySelector
Modifier and Type
Field
Description
protected final ReplyJob
_onReply
Job to run on reply.
protected final Job
_onTimeout
Job to run on timeout.
protected final MessageSelector
_replySelector
Reply message selector.
Fields inherited from class FloodSearchJob
_created, _dead, _expiration, _facade, _isLease, _key, _log, _lookupsRemaining, _onFailed, _onFind, _success, _timeoutMs, CONCURRENT_SEARCHES
Modifier and Type
Field
Description
protected final long
_created
System time when this search was created.
protected boolean
_dead
Whether this search has been marked as completed.
protected long
_expiration
Deadline after which the search expires.
protected final FloodfillNetworkDatabaseFacade
_facade
Floodfill network database facade.
protected final boolean
_isLease
Whether the target is a LeaseSet lookup.
protected final Hash
_key
Target database entry hash being searched.
protected final Log
_log
Class logger.
protected final AtomicInteger
_lookupsRemaining
Remaining flood lookups before fallback to iterative search.
protected final List<Job>
_onFailed
Callbacks for search failure.
protected final List<Job>
_onFind
Callbacks for successful search completion.
protected boolean
_success
Whether the search completed successfully.
protected int
_timeoutMs
Timeout for the search in milliseconds.
protected static final int
CONCURRENT_SEARCHES
Max simultaneous flood lookups before fallback.
Fields inherited from class JobImpl
_id
Modifier and Type
Field
Description
final long
_id
Unique job identifier.
Constructor Summary
Constructors
Constructor
Description
SingleSearchJob(RouterContext ctx, Hash key, Hash to)
Send one DatabaseLookupMessage straight to a chosen peer over exploratory tunnels, instead of flooding the networkDb with it.
Method Summary
Public Methods
Modifier and Type
Method
Description
(package private) void
failed()
Deprecated, unused, see FOSJ override.
String
getName()
Deprecated, unused, see FOSJ override.
void
runJob()
Deprecated, unused, see FOSJ override.
boolean
shouldProcessDSRM()
Whether a DSRM reply should be processed.
(package private) void
success()
Deprecated, unused, see FOSJ override.
Methods inherited from class FloodOnlySearchJob
decrementRemaining
Modifier and Type
Method
Description
(package private) int
decrementRemaining(Hash peer)
Note that we heard from the peer.
Methods inherited from class FloodSearchJob
addDeferred, decrementRemaining, getCreated, getExpiration, getKey, getLookupsRemaining
Modifier and Type
Method
Description
(package private) void
addDeferred(Job onFind, Job onFailed, long timeoutMs, boolean isLease)
Add jobs to an existing search.
protected int
decrementRemaining()
Number of lookups remaining after decrementing.
long
getCreated()
System time, NOT context time.
long
getExpiration()
Expiration time from the context clock.
Hash
getKey()
The database entry hash being searched.
protected int
getLookupsRemaining()
Number of flood lookups still pending.
Methods inherited from class JobImpl
dropped, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
Modifier and Type
Method
Description
void
dropped()
Default implementation does nothing.
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

Field Details
- _to
  private final Hash _to
  The hash being looked up.
- _onm
  private OutNetMessage _onm
  The lookup message awaiting a reply.
- TIMEOUT
  private static final int TIMEOUT
  How long to wait for the reply - 8 seconds.
  See Also:
  Constant Field Values
Constructor Details
- SingleSearchJob
  public SingleSearchJob(RouterContext ctx, Hash key, Hash to)
  Send one DatabaseLookupMessage straight to a chosen peer over exploratory tunnels, instead of flooding the networkDb with it.
  Parameters:
  ctx - the router context for the parent search job
  key - for Router Info ONLY
  to - the peer the lookup is sent to
Method Details
- getName
  public String getName()
  Description copied from class: FloodSearchJob
  Deprecated, unused, see FOSJ override.
  Specified by:
  getName in interface Job
  Overrides:
  getName in class FloodOnlySearchJob
  Returns:
  the fixed descriptive name "NetDb Search (phase 1)" of this job
- shouldProcessDSRM
  public boolean shouldProcessDSRM()
  Description copied from class: FloodOnlySearchJob
  Whether a DSRM reply should be processed.
  Overrides:
  shouldProcessDSRM in class FloodOnlySearchJob
  Returns:
  true if DSRM should be processed
- runJob
  public void runJob()
  Description copied from class: FloodSearchJob
  Deprecated, unused, see FOSJ override.
  Specified by:
  runJob in interface Job
  Overrides:
  runJob in class FloodOnlySearchJob
- failed
  void failed()
  Description copied from class: FloodSearchJob
  Deprecated, unused, see FOSJ override.
  Overrides:
  failed in class FloodOnlySearchJob
- success
  void success()
  Description copied from class: FloodSearchJob
  Deprecated, unused, see FOSJ override.
  Overrides:
  success in class FloodOnlySearchJob

Field Summary

Fields inherited from class FloodOnlySearchJob

Fields inherited from class FloodSearchJob

Fields inherited from class JobImpl

Constructor Summary

Method Summary

Methods inherited from class FloodOnlySearchJob

Methods inherited from class FloodSearchJob

Methods inherited from class JobImpl

Methods inherited from class Object

Field Details

_to

_onm

TIMEOUT

Constructor Details

Method Details

getName

shouldProcessDSRM

runJob

failed

success