Job
FloodOnlySearchJob
, IterativeSearchJob
public class FloodSearchJob extends JobImpl
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected long |
_created |
|
protected boolean |
_dead |
|
protected long |
_expiration |
|
protected FloodfillNetworkDatabaseFacade |
_facade |
|
protected boolean |
_isLease |
|
protected Hash |
_key |
|
protected Log |
_log |
|
protected java.util.concurrent.atomic.AtomicInteger |
_lookupsRemaining |
|
protected java.util.List<Job> |
_onFailed |
|
protected java.util.List<Job> |
_onFind |
|
protected boolean |
_success |
|
protected int |
_timeoutMs |
|
protected static int |
CONCURRENT_SEARCHES |
コンストラクタ | 説明 |
---|---|
FloodSearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
(package private) void |
addDeferred(Job onFind,
Job onFailed,
long timeoutMs,
boolean isLease) |
Add jobs to an existing search
|
protected int |
decrementRemaining() |
|
(package private) void |
failed() |
Deprecated, unused, see FOSJ override
|
long |
getCreated() |
System time, NOT context time
|
long |
getExpiration() |
using context clock
|
protected Hash |
getKey() |
|
protected int |
getLookupsRemaining() |
|
java.lang.String |
getName() |
Deprecated, unused, see FOSJ override
|
void |
runJob() |
Deprecated, unused, see FOSJ override
|
(package private) void |
success() |
Deprecated, unused, see FOSJ override
|
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
protected final Log _log
protected final FloodfillNetworkDatabaseFacade _facade
protected final Hash _key
protected final java.util.List<Job> _onFind
protected final java.util.List<Job> _onFailed
protected long _expiration
protected int _timeoutMs
protected final boolean _isLease
protected final java.util.concurrent.atomic.AtomicInteger _lookupsRemaining
protected volatile boolean _dead
protected final long _created
protected boolean _success
protected static final int CONCURRENT_SEARCHES
public FloodSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)
onFind
- may be nullonFailed
- may be nullpublic long getCreated()
void addDeferred(Job onFind, Job onFailed, long timeoutMs, boolean isLease)
onFind
- may be nullonFailed
- may be nulltimeoutMs
- ignoredisLease
- ignoredpublic long getExpiration()
public void runJob()
public java.lang.String getName()
protected Hash getKey()
protected int decrementRemaining()
protected int getLookupsRemaining()
void failed()
void success()