net.i2p.router.networkdb.kademlia
public class FloodSearchJob extends JobImpl
Modifier and Type | Field and Description |
---|---|
protected boolean |
_dead |
protected long |
_expiration |
protected FloodfillNetworkDatabaseFacade |
_facade |
protected boolean |
_isLease |
protected Hash |
_key |
protected Log |
_log |
protected int |
_lookupsRemaining |
protected List<Job> |
_onFailed |
protected List<Job> |
_onFind |
protected long |
_origExpiration |
protected int |
_timeoutMs |
Constructor and Description |
---|
FloodSearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
addDeferred(Job onFind,
Job onFailed,
long timeoutMs,
boolean isLease) |
protected void |
decrementRemaining() |
(package private) void |
failed() |
long |
getExpiration() |
protected Hash |
getKey() |
protected int |
getLookupsRemaining() |
String |
getName()
Descriptive name of the task
|
void |
runJob()
Actually perform the task.
|
(package private) void |
success() |
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
protected Log _log
protected FloodfillNetworkDatabaseFacade _facade
protected Hash _key
protected long _expiration
protected int _timeoutMs
protected long _origExpiration
protected boolean _isLease
protected volatile int _lookupsRemaining
protected volatile boolean _dead
public FloodSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)
public long getExpiration()
public void runJob()
Job
protected Hash getKey()
protected void decrementRemaining()
protected int getLookupsRemaining()
void failed()
void success()