IterativeSearchJob (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.JobImpl
- - net.i2p.router.networkdb.kademlia.FloodSearchJob
  - - net.i2p.router.networkdb.kademlia.IterativeSearchJob

All Implemented Interfaces:
Job
```
public class IterativeSearchJob
extends FloodSearchJob
```
Traditional Kademlia iterative search with enhanced robustness.
Continues searching when initial lookup fails by iteratively querying closer-to-the-key peers returned in DatabaseSearchReplyMessages. Unlike traditional Kademlia, doesn't stop when no closer keys are available - keeps searching until timeout or maximum search limit is reached.
Key differences from FloodOnlySearchJob: - Chases peers in DSRM immediately rather than waiting - Searches one peer at a time with individual per-search timeouts - Uses total timeout rather than per-search timeouts - Longer overall timeout for better success rates - Reduces search traffic by half compared to parallel approaches
Advantages over flood-only approaches: - More robust in large networks with incomplete floodfill knowledge - Better success rates through sequential searching - Reduced network traffic through single-peer queries

Field Summary
Fields
Modifier and Type Field and Description
static boolean DEFAULT_ENCRYPT_RI
only on fast boxes, for now
static String PROP_ENCRYPT_RI
PROP_ENCRYPT_RI.
- Fields inherited from class net.i2p.router.networkdb.kademlia.FloodSearchJob
  _created, _dead, _expiration, _facade, _isLease, _key, _log, _lookupsRemaining, _onFailed, _onFind, _success, _timeoutMs, CONCURRENT_SEARCHES
- Fields inherited from class net.i2p.router.JobImpl
  _id

Fields
Modifier and Type	Field and Description
`static boolean`	`DEFAULT_ENCRYPT_RI` only on fast boxes, for now
`static String`	`PROP_ENCRYPT_RI` PROP_ENCRYPT_RI.

Constructor Summary

Constructors
Constructor and Description
`IterativeSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)` Lookup using exploratory tunnels
`IterativeSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease, Hash fromLocalDest)` Lookup using the client's tunnels.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`cancelJob()` Cancels the job without performing full failure handling.
`static void`	`clearRecentlyQueried(Hash peer)` Clear peer from grace period cache (received their response).
`void`	`dropped()` Dropped by the job queue
`(package private) void`	`failed()` Total failure
`(package private) void`	`failed(Hash peer, boolean timedOut)` Note that the peer did not respond with a DSM (either a DSRM, timeout, or failure).
`Hash`	`getFromHash()` Hash of the dest this query is from
`static int`	`getMaxConcurrentDefault()` Gets the maximum concurrent default value.
`static int`	`getMaxLeaseSetLookupTime()`
`static int`	`getMaxRouterInfoLookupTime()`
`String`	`getName()` Deprecated, unused, see FOSJ override
`(package private) void`	`newPeerToTry(Hash peer)` A new (floodfill) peer was discovered that may have the answer.
`static long`	`reloadGracePeriod(RouterContext ctx)` Reload grace period from properties (for dynamic tuning).
`void`	`runJob()` Execute the iterative search, selecting floodfill peers from the k-buckets and sending DatabaseLookupMessages to each.
`static void`	`setMaxConcurrentDefault(int val)` Sets the maximum concurrent default value.
`static void`	`setMaxLeaseSetLookupTime(int val)`
`static void`	`setMaxRouterInfoLookupTime(int val)`
`(package private) void`	`success()` Called when the search completes successfully.
`(package private) long`	`timeSent(Hash peer)` When did we send the query to the peer?
`boolean`	`wasQueried(Hash peer)` Did we send a request to this peer?
`static boolean`	`wasRecentlyQueried(Hash peer)` Was this peer recently queried (within grace period)? Used to avoid false positive bans for late but legitimate replies.

Methods inherited from class net.i2p.router.networkdb.kademlia.FloodSearchJob
addDeferred, decrementRemaining, getCreated, getExpiration, getKey, getLookupsRemaining

Methods inherited from class net.i2p.router.JobImpl
getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - DEFAULT_ENCRYPT_RI
```
public static final boolean DEFAULT_ENCRYPT_RI
```
    only on fast boxes, for now
  - PROP_ENCRYPT_RI
```
public static final String PROP_ENCRYPT_RI
```
    PROP_ENCRYPT_RI.
    See Also:
    Constant Field Values
- Constructor Detail
  - IterativeSearchJob
```
public IterativeSearchJob(RouterContext ctx,
                          FloodfillNetworkDatabaseFacade facade,
                          Hash key,
                          Job onFind,
                          Job onFailed,
                          int timeoutMs,
                          boolean isLease)
```
    Lookup using exploratory tunnels
  - IterativeSearchJob
```
public IterativeSearchJob(RouterContext ctx,
                          FloodfillNetworkDatabaseFacade facade,
                          Hash key,
                          Job onFind,
                          Job onFailed,
                          int timeoutMs,
                          boolean isLease,
                          Hash fromLocalDest)
```
    Lookup using the client's tunnels. Do not use for RI lookups down client tunnels, as the response will be dropped in InboundMessageDistributor.
    Parameters:
    fromLocalDest - use these tunnels for the lookup, or null for exploratory
- Method Detail
  - cancelJob
```
void cancelJob()
```
    Cancels the job without performing full failure handling.
  - clearRecentlyQueried
```
public static void clearRecentlyQueried(Hash peer)
```
    Clear peer from grace period cache (received their response).
    Parameters:
    peer - the peer
  - dropped
```
public void dropped()
```
    Dropped by the job queue
    Specified by:
    dropped in interface Job
    Overrides:
    dropped in class JobImpl
  - failed
```
void failed()
```
    Total failure
    Overrides:
    failed in class FloodSearchJob
  - failed
```
void failed(Hash peer,
            boolean timedOut)
```
    Note that the peer did not respond with a DSM (either a DSRM, timeout, or failure). This is not necessarily a total failure of the search.
    Parameters:
    peer - the peer that failed
    timedOut - if true, will blame the peer's profile
  - getFromHash
```
public Hash getFromHash()
```
    Hash of the dest this query is from
    Returns:
    null for router
  - getMaxConcurrentDefault
```
public static int getMaxConcurrentDefault()
```
    Gets the maximum concurrent default value.
    Returns:
    the max concurrent default
  - getMaxLeaseSetLookupTime
```
public static int getMaxLeaseSetLookupTime()
```
    Returns:
    the current LeaseSet lookup deadline cap in ms
  - getMaxRouterInfoLookupTime
```
public static int getMaxRouterInfoLookupTime()
```
    Returns:
    the current RouterInfo lookup deadline cap in ms
  - getName
```
public String getName()
```
    Description copied from class: FloodSearchJob
    Deprecated, unused, see FOSJ override
    Specified by:
    getName in interface Job
    Overrides:
    getName in class FloodSearchJob
    Returns:
    the name
  - newPeerToTry
```
void newPeerToTry(Hash peer)
```
    A new (floodfill) peer was discovered that may have the answer.
    Parameters:
    peer - may not actually be new
  - reloadGracePeriod
```
public static long reloadGracePeriod(RouterContext ctx)
```
    Reload grace period from properties (for dynamic tuning). Console may call this.
    Parameters:
    ctx - router context for property lookup
    Returns:
    current grace period in ms
  - runJob
```
public void runJob()
```
    Execute the iterative search, selecting floodfill peers from the k-buckets and sending DatabaseLookupMessages to each. Continues until a reply is received or the search time expires.
    Specified by:
    runJob in interface Job
    Overrides:
    runJob in class FloodSearchJob
  - setMaxConcurrentDefault
```
public static void setMaxConcurrentDefault(int val)
```
    Sets the maximum concurrent default value.
  - setMaxLeaseSetLookupTime
```
public static void setMaxLeaseSetLookupTime(int val)
```
    Parameters:
    val - LeaseSet lookup deadline cap in ms, clamped to [3000, MAX_SEARCH_TIME]
  - setMaxRouterInfoLookupTime
```
public static void setMaxRouterInfoLookupTime(int val)
```
    Parameters:
    val - RouterInfo lookup deadline cap in ms, clamped to [3000, MAX_SEARCH_TIME]
  - success
```
void success()
```
    Called when the search completes successfully. Credits the responding peer in the profile manager, records timing stats, and queues any follow-up jobs.
    Overrides:
    success in class FloodSearchJob
  - timeSent
```
long timeSent(Hash peer)
```
    When did we send the query to the peer?
    Parameters:
    peer - the peer to check
    Returns:
    context time, or -1 if never sent
  - wasQueried
```
public boolean wasQueried(Hash peer)
```
    Did we send a request to this peer?
    Parameters:
    peer - the peer
    Returns:
    true if a query was sent to this peer
  - wasRecentlyQueried
```
public static boolean wasRecentlyQueried(Hash peer)
```
    Was this peer recently queried (within grace period)? Used to avoid false positive bans for late but legitimate replies.
    Parameters:
    peer - the peer
    Returns:
    true if the peer was queried recently and is in the grace period

Class IterativeSearchJob

Field Summary

Fields inherited from class net.i2p.router.networkdb.kademlia.FloodSearchJob

Fields inherited from class net.i2p.router.JobImpl

Constructor Summary

Method Summary

Methods inherited from class net.i2p.router.networkdb.kademlia.FloodSearchJob

Methods inherited from class net.i2p.router.JobImpl

Methods inherited from class java.lang.Object

Field Detail

DEFAULT_ENCRYPT_RI

PROP_ENCRYPT_RI

Constructor Detail

IterativeSearchJob

IterativeSearchJob

Method Detail

cancelJob

clearRecentlyQueried

dropped

failed

failed

getFromHash

getMaxConcurrentDefault

getMaxLeaseSetLookupTime

getMaxRouterInfoLookupTime

getName

newPeerToTry

reloadGracePeriod

runJob

setMaxConcurrentDefault

setMaxLeaseSetLookupTime

setMaxRouterInfoLookupTime

success

timeSent

wasQueried

wasRecentlyQueried