Package 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

abstract class StoreJob
extends JobImpl

Stores through this always request a reply. Unused directly - see FloodfillStoreJob

Field Summary

Fields

Modifier and Type	Field	Description
protected Log	_log
protected StoreState	_state
static String	MIN_STORE_ENCLS2_VERSION	Was supported in 38, but they're now sigtype 11 which wasn't added until 39
static String	MIN_STORE_LS2_VERSION
static String	MIN_STORE_VERSION

Constructor Summary

Constructors

Constructor	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)

Method Summary

Modifier and Type	Method	Description
protected void	fail()	Send totally failed
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.
(package private) static boolean	shouldStoreEncLS2To(RouterInfo ri)	Is it new enough?
(package private) static boolean	shouldStoreLS2To(RouterInfo ri)	Is it new enough?
(package private) static boolean	shouldStoreTo(RouterInfo ri)	Is it new enough?
protected void	succeed()	Send was totally successful

Methods inherited from class net.i2p.router.JobImpl

dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString

Methods inherited from class java.lang.Object

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

Field Detail

_log

protected final Log _log

_state

protected final StoreState _state

MIN_STORE_VERSION

public static final String MIN_STORE_VERSION

Since:

0.9.28

See Also:

Constant Field Values

MIN_STORE_LS2_VERSION

public static final String MIN_STORE_LS2_VERSION

Since:

0.9.38

See Also:

Constant Field Values

MIN_STORE_ENCLS2_VERSION

public static final String MIN_STORE_ENCLS2_VERSION

Was supported in 38, but they're now sigtype 11 which wasn't added until 39

Since:

0.9.39

See Also:

Constant Field Values

Constructor Detail

StoreJob

public StoreJob(RouterContext context,
                KademliaNetworkDatabaseFacade facade,
                Hash key,
                DatabaseEntry data,
                Job onSuccess,
                Job onFailure,
                long timeoutMs)

Send a data structure to the floodfills

StoreJob

public StoreJob(RouterContext context,
                KademliaNetworkDatabaseFacade 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 Detail

getName

public 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()

overridden in FSJ

getRedundancy

protected int getRedundancy()

overridden in FSJ

shouldStoreTo

static boolean shouldStoreTo(RouterInfo ri)

Is it new enough?

Since:

0.9.33

shouldStoreLS2To

static boolean shouldStoreLS2To(RouterInfo ri)

Is it new enough?

Since:

0.9.38

shouldStoreEncLS2To

static boolean shouldStoreEncLS2To(RouterInfo ri)

Is it new enough?

Since:

0.9.39

succeed

protected void succeed()

Send was totally successful

fail

protected void fail()

Send totally failed