net.i2p.router.networkdb.kademlia
Class StoreJob
java.lang.Object
net.i2p.router.JobImpl
net.i2p.router.networkdb.kademlia.StoreJob
- All Implemented Interfaces:
- Job
- Direct Known Subclasses:
- FloodfillStoreJob
class StoreJob
- extends JobImpl
Constructor Summary |
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DataStructure data,
Job onSuccess,
Job onFailure,
long timeoutMs)
Create a new search for the routingKey specified |
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DataStructure data,
Job onSuccess,
Job onFailure,
long timeoutMs,
java.util.Set toSkip)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
_state
protected StoreState _state
StoreJob
public StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DataStructure data,
Job onSuccess,
Job onFailure,
long timeoutMs)
- Create a new search for the routingKey specified
StoreJob
public StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DataStructure data,
Job onSuccess,
Job onFailure,
long timeoutMs,
java.util.Set toSkip)
- Parameters:
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.
getName
public java.lang.String getName()
- Description copied from interface:
Job
- Descriptive name of the task
runJob
public void runJob()
- Description copied from interface:
Job
- Actually perform the task. This call blocks until the Job is complete.
getParallelization
protected int getParallelization()
getRedundancy
protected int getRedundancy()
succeed
protected void succeed()
- Send was totally successful
fail
protected void fail()
- Send totally failed