class IterativeSearchJob extends FloodSearchJob
Modifier and Type | Field and Description |
---|---|
static boolean |
DEFAULT_ENCRYPT_RI
only on fast boxes, for now
|
static String |
PROP_ENCRYPT_RI |
_created, _dead, _expiration, _facade, _isLease, _key, _log, _lookupsRemaining, _onFailed, _onFind, _success, _timeoutMs, CONCURRENT_SEARCHES
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.
|
Modifier and Type | Method and Description |
---|---|
(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
|
String |
getName()
Deprecated, unused, see FOSJ override
|
(package private) void |
newPeerToTry(Hash peer)
A new (floodfill) peer was discovered that may have the answer.
|
void |
runJob()
Deprecated, unused, see FOSJ override
|
(package private) void |
success()
Deprecated, unused, see FOSJ override
|
(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?
|
addDeferred, decrementRemaining, getCreated, getExpiration, getKey, getLookupsRemaining
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
public static final String PROP_ENCRYPT_RI
public static final boolean DEFAULT_ENCRYPT_RI
public IterativeSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)
public IterativeSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease, Hash fromLocalDest)
fromLocalDest
- use these tunnels for the lookup, or null for exploratorypublic void runJob()
FloodSearchJob
runJob
in interface Job
runJob
in class FloodSearchJob
public String getName()
FloodSearchJob
getName
in interface Job
getName
in class FloodSearchJob
void failed(Hash peer, boolean timedOut)
timedOut
- if true, will blame the peer's profilevoid newPeerToTry(Hash peer)
peer
- may not actually be newpublic Hash getFromHash()
public boolean wasQueried(Hash peer)
long timeSent(Hash peer)
void failed()
failed
in class FloodSearchJob
void success()
FloodSearchJob
success
in class FloodSearchJob