Class FloodfillStoreJob
java.lang.Object
net.i2p.router.JobImpl
net.i2p.router.networkdb.kademlia.StoreJob
net.i2p.router.networkdb.kademlia.FloodfillStoreJob
- All Implemented Interfaces:
Job
class FloodfillStoreJob extends StoreJob
This extends StoreJob to fire off a FloodfillVerifyStoreJob after success.
Stores through this class always request a reply.
-
Field Summary
Fields inherited from class net.i2p.router.networkdb.kademlia.StoreJob
_log, _state, MIN_STORE_ENCLS2_VERSION, MIN_STORE_LS2_VERSION, MIN_STORE_VERSION
-
Constructor Summary
Constructors Constructor Description FloodfillStoreJob(RouterContext context, FloodfillNetworkDatabaseFacade facade, Hash key, DatabaseEntry data, Job onSuccess, Job onFailure, long timeoutMs)
Send a data structure to the floodfillsFloodfillStoreJob(RouterContext context, FloodfillNetworkDatabaseFacade facade, Hash key, DatabaseEntry data, Job onSuccess, Job onFailure, long timeoutMs, Set<Hash> toSkip)
-
Method Summary
Modifier and Type Method Description String
getName()
Descriptive name of the taskprotected int
getParallelization()
overridden in FSJprotected int
getRedundancy()
overridden in FSJprotected void
succeed()
Send was totally successfulMethods inherited from class net.i2p.router.networkdb.kademlia.StoreJob
fail, runJob, shouldStoreEncLS2To, shouldStoreLS2To, shouldStoreTo
Methods inherited from class net.i2p.router.JobImpl
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
-
Constructor Details
-
FloodfillStoreJob
public FloodfillStoreJob(RouterContext context, FloodfillNetworkDatabaseFacade facade, Hash key, DatabaseEntry data, Job onSuccess, Job onFailure, long timeoutMs)Send a data structure to the floodfills -
FloodfillStoreJob
public FloodfillStoreJob(RouterContext context, FloodfillNetworkDatabaseFacade facade, Hash key, DatabaseEntry data, Job onSuccess, Job onFailure, long timeoutMs, Set<Hash> 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.
-
-
Method Details
-
getParallelization
protected int getParallelization()Description copied from class:StoreJob
overridden in FSJ- Overrides:
getParallelization
in classStoreJob
-
getRedundancy
protected int getRedundancy()Description copied from class:StoreJob
overridden in FSJ- Overrides:
getRedundancy
in classStoreJob
-
succeed
protected void succeed()Send was totally successful -
getName
Description copied from interface:Job
Descriptive name of the task
-