Package net.i2p.router.networkdb.kademlia

Class FloodSearchJob

java.lang.Object

net.i2p.router.JobImpl

net.i2p.router.networkdb.kademlia.FloodSearchJob

All Implemented Interfaces:

Job

Direct Known Subclasses:

FloodOnlySearchJob, IterativeSearchJob

abstract class FloodSearchJob
extends JobImpl

Try sending a search to some floodfill peers, but if we don't get a successful match within half the allowed lookup time, give up and start querying through the normal (kademlia) channels. This should cut down on spurious lookups caused by simple delays in responses from floodfill peers NOTE: Unused directly - see FloodOnlySearchJob extension which overrides almost everything. TODO: Comment out or delete what we don't use here. Note that this does NOT extend SearchJob.

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	_created
protected boolean	_dead
protected long	_expiration
protected final FloodfillNetworkDatabaseFacade	_facade
protected final boolean	_isLease
protected final Hash	_key
protected final Log	_log
protected final AtomicInteger	_lookupsRemaining
protected final List<Job>	_onFailed
protected final List<Job>	_onFind
protected boolean	_success
protected int	_timeoutMs
protected static final int	CONCURRENT_SEARCHES

Constructor Summary

Constructors

Constructor	Description
FloodSearchJob(RouterContext ctx, FloodfillNetworkDatabaseFacade facade, Hash key, Job onFind, Job onFailed, int timeoutMs, boolean isLease)

Method Summary

Modifier and Type	Method	Description
(package private) void	addDeferred(Job onFind, Job onFailed, long timeoutMs, boolean isLease)	Add jobs to an existing search
protected int	decrementRemaining()
(package private) void	failed()	Deprecated, unused, see FOSJ override
long	getCreated()	System time, NOT context time
long	getExpiration()	using context clock
Hash	getKey()
protected int	getLookupsRemaining()
String	getName()	Deprecated, unused, see FOSJ override
void	runJob()	Deprecated, unused, see FOSJ override
(package private) void	success()	Deprecated, unused, see FOSJ override

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

Field Details

_log

protected final Log _log

_facade

protected final FloodfillNetworkDatabaseFacade _facade

_key

protected final Hash _key

_onFind

protected final List<Job> _onFind

_onFailed

protected final List<Job> _onFailed

_expiration

protected long _expiration

_timeoutMs

protected int _timeoutMs

_isLease

protected final boolean _isLease

_lookupsRemaining

protected final AtomicInteger _lookupsRemaining

_dead

protected volatile boolean _dead

_created

protected final long _created

_success

protected boolean _success

CONCURRENT_SEARCHES

protected static final int CONCURRENT_SEARCHES

See Also:

• Constant Field Values

Constructor Details

FloodSearchJob

public FloodSearchJob(RouterContext ctx,
 FloodfillNetworkDatabaseFacade facade,
 Hash key,
 Job onFind,
 Job onFailed,
 int timeoutMs,
 boolean isLease)

Parameters:

onFind - may be null

onFailed - may be null

Method Details

getCreated

public long getCreated()

System time, NOT context time

addDeferred

void addDeferred(Job onFind,
 Job onFailed,
 long timeoutMs,
 boolean isLease)

Add jobs to an existing search

Parameters:

onFind - may be null

onFailed - may be null

timeoutMs - ignored

isLease - ignored

getExpiration

public long getExpiration()

using context clock

runJob

public void runJob()

Deprecated, unused, see FOSJ override

getName

public String getName()

Deprecated, unused, see FOSJ override

getKey

public Hash getKey()

decrementRemaining

protected int decrementRemaining()

Returns:

number remaining after decrementing

getLookupsRemaining

protected int getLookupsRemaining()

failed

void failed()

Deprecated, unused, see FOSJ override

success

void success()

Deprecated, unused, see FOSJ override