Job
FloodfillStoreJob
class StoreJob extends JobImpl
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected Log |
_log |
|
protected StoreState |
_state |
コンストラクタ | 説明 |
---|---|
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DatabaseEntry data,
Job onSuccess,
Job onFailure,
long timeoutMs) |
Send a data structure to the floodfills
|
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DatabaseEntry data,
Job onSuccess,
Job onFailure,
long timeoutMs,
java.util.Set<Hash> toSkip) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
protected void |
fail() |
Send totally failed
|
java.lang.String |
getName() |
Descriptive name of the task
|
protected int |
getParallelization() |
overridden in FSJ
|
protected int |
getRedundancy() |
overridden in FSJ
|
void |
runJob() |
Actually perform the task.
|
protected void |
succeed() |
Send was totally successful
|
static boolean |
supportsBigLeaseSets(RouterInfo ri) |
Does he support more than 6 leasesets?
|
static boolean |
supportsCert(RouterInfo ri,
Certificate cert) |
Does this router understand this cert?
|
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
protected final Log _log
protected final StoreState _state
public StoreJob(RouterContext context, KademliaNetworkDatabaseFacade facade, Hash key, DatabaseEntry data, Job onSuccess, Job onFailure, long timeoutMs)
public StoreJob(RouterContext context, KademliaNetworkDatabaseFacade facade, Hash key, DatabaseEntry data, Job onSuccess, Job onFailure, long timeoutMs, java.util.Set<Hash> toSkip)
toSkip
- set of peer hashes of people we dont want to send the data to (e.g. we
already know they have it). This can be null.public java.lang.String getName()
Job
public void runJob()
Job
protected int getParallelization()
protected int getRedundancy()
public static boolean supportsCert(RouterInfo ri, Certificate cert)
public static boolean supportsBigLeaseSets(RouterInfo ri)
protected void succeed()
protected void fail()