class FloodOnlySearchJob extends FloodSearchJob
Modifier and Type | Field and Description |
---|---|
protected ReplyJob |
_onReply |
protected Job |
_onTimeout |
protected MessageSelector |
_replySelector |
_created, _dead, _expiration, _facade, _isLease, _key, _log, _lookupsRemaining, _onFailed, _onFind, _success, _timeoutMs, CONCURRENT_SEARCHES
Constructor and Description |
---|
FloodOnlySearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease) |
Modifier and Type | Method and Description |
---|---|
(package private) int |
decrementRemaining(Hash peer)
Note that we heard from the peer
|
(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() |
(package private) void |
success()
Deprecated, unused, see FOSJ override
|
addDeferred, decrementRemaining, getCreated, getExpiration, getKey, getLookupsRemaining
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
protected final MessageSelector _replySelector
protected final ReplyJob _onReply
protected final Job _onTimeout
public FloodOnlySearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)
public boolean shouldProcessDSRM()
public void runJob()
FloodSearchJob
runJob
in interface Job
runJob
in class FloodSearchJob
public String getName()
FloodSearchJob
getName
in interface Job
getName
in class FloodSearchJob
int decrementRemaining(Hash peer)
void failed()
FloodSearchJob
failed
in class FloodSearchJob
void success()
FloodSearchJob
success
in class FloodSearchJob