net.i2p.router.networkdb.kademlia
class FloodOnlySearchJob extends FloodSearchJob
Modifier and Type | Field and Description |
---|---|
protected ReplyJob |
_onReply |
protected Job |
_onTimeout |
protected MessageSelector |
_replySelector |
_expiration, _facade, _isLease, _key, _log, _lookupsRemaining, _onFailed, _onFind, _origExpiration, _timeoutMs
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) void |
decrementRemaining(Hash peer)
Note that we heard from the peer
|
(package private) void |
failed() |
long |
getCreated() |
String |
getName()
Descriptive name of the task
|
void |
runJob()
Actually perform the task.
|
boolean |
shouldProcessDSRM() |
(package private) void |
success() |
addDeferred, decrementRemaining, getExpiration, getKey, getLookupsRemaining
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
protected MessageSelector _replySelector
protected ReplyJob _onReply
protected Job _onTimeout
public FloodOnlySearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)
public long getCreated()
public boolean shouldProcessDSRM()
public void runJob()
Job
runJob
in interface Job
runJob
in class FloodSearchJob
public String getName()
Job
getName
in interface Job
getName
in class FloodSearchJob
void decrementRemaining(Hash peer)
void failed()
failed
in class FloodSearchJob
void success()
success
in class FloodSearchJob