Package net.i2p.router.networkdb.kademlia

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 floodfills
FloodfillStoreJob(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 task
protected int	getParallelization()	overridden in FSJ
protected int	getRedundancy()	overridden in FSJ
protected void	succeed()	Send was totally successful

Methods 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, madeReady, requeue, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 class StoreJob

getRedundancy

protected int getRedundancy()

Description copied from class: StoreJob

overridden in FSJ

Overrides:

getRedundancy in class StoreJob

succeed

protected void succeed()

Send was totally successful

Overrides:

succeed in class StoreJob

getName

public String getName()

Description copied from interface: Job

Descriptive name of the task

Specified by:

getName in interface Job

Overrides:

getName in class StoreJob