net.i2p.router.networkdb.kademlia
class StoreJob extends JobImpl
Modifier and Type | Field and Description |
---|---|
protected Log |
_log |
protected StoreState |
_state |
Constructor and Description |
---|
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,
Set<Hash> toSkip) |
Modifier and Type | Method and Description |
---|---|
protected void |
fail()
Send totally failed
|
String |
getName()
Descriptive name of the task
|
protected int |
getParallelization() |
protected int |
getRedundancy() |
void |
runJob()
Actually perform the task.
|
protected void |
succeed()
Send was totally successful
|
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
protected Log _log
protected 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, 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 void runJob()
Job
protected int getParallelization()
protected int getRedundancy()
protected void succeed()
protected void fail()