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 long`	`_created`
`protected boolean`	`_dead`
`protected long`	`_expiration`
`protected FloodfillNetworkDatabaseFacade`	`_facade`
`protected boolean`	`_isLease`
`protected Hash`	`_key`
`protected Log`	`_log`
`protected AtomicInteger`	`_lookupsRemaining`
`protected List<Job>`	`_onFailed`
`protected List<Job>`	`_onFind`
`protected boolean`	`_success`
`protected int`	`_timeoutMs`
`protected static int`	`CONCURRENT_SEARCHES`

Fields inherited from class net.i2p.router.JobImpl

_id

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
`protected 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, 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
  
  protected 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

Class FloodSearchJob

Field Summary

Fields inherited from class net.i2p.router.JobImpl

Constructor Summary

Method Summary

Methods inherited from class net.i2p.router.JobImpl

Methods inherited from class java.lang.Object

Field Details

Constructor Details

Method Details