FloodfillNetworkDatabaseFacade (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.NetworkDatabaseFacade
- - net.i2p.router.networkdb.kademlia.KademliaNetworkDatabaseFacade
  - - net.i2p.router.networkdb.kademlia.FloodfillNetworkDatabaseFacade

All Implemented Interfaces:: Service

public class FloodfillNetworkDatabaseFacade
extends KademliaNetworkDatabaseFacade

The network database

Field Summary

Fields
Modifier and Type	Field and Description
`(package private) static ConcurrentHashMap<Hash,Long>`	`_recentlyQueriedFloodfills` Tracks recently-queried floodfill peers across all concurrent searches to avoid hammering the same floodfill.
`static char`	`CAPABILITY_BW_UNLIMITED` Unlimited bandwidth capability flag.
`static char`	`CAPABILITY_BW12` Bandwidth 12 Kbps capability flag.
`static char`	`CAPABILITY_BW128` Bandwidth 128 Kbps capability flag.
`static char`	`CAPABILITY_BW256` Bandwidth 256 Kbps capability flag.
`static char`	`CAPABILITY_BW32` Bandwidth 32 Kbps capability flag.
`static char`	`CAPABILITY_BW512` Bandwidth 512 Kbps capability flag.
`static char`	`CAPABILITY_BW64` Bandwidth 64 Kbps capability flag.
`static char`	`CAPABILITY_CONGESTION_MODERATE` Moderate congestion capability flag.
`static char`	`CAPABILITY_CONGESTION_SEVERE` Severe congestion capability flag.
`static char`	`CAPABILITY_FLOODFILL` Floodfill capability flag.
`static char`	`CAPABILITY_NO_TUNNELS` No tunnels capability flag.
`static char`	`CAPABILITY_UNREACHABLE` Unreachable capability flag.
`(package private) static long`	`MAX_RI_AGE_BEFORE_REFRESH_MS` Max age (ms) for a RouterInfo stored in our NetDB before we consider refreshing it.
`static int`	`MAX_TO_FLOOD` This is the flood redundancy.
`protected static int`	`MIN_ACTIVE_PEERS` Minimum number of active peers before dropping router info lookups.
`(package private) static long`	`NEXT_RKEY_RI_ADVANCE_TIME` Advance time before midnight to flood to next routing key for RouterInfo.
`static String`	`PROP_FLOODFILL_AT_RESTART` Config property recording floodfill status at previous restart.
`static String`	`PROP_FLOODFILL_PARTICIPANT` Config property for floodfill participation.
`(package private) static long`	`PUBLISH_TIMEOUT` This maybe could be shorter than RepublishLeaseSetJob.REPUBLISH_LEASESET_TIMEOUT, because we are sending direct, but unresponsive floodfills may take a while due to timeouts.
`(package private) static long`	`RECENTLY_QUERIED_COOLDOWN` R e c e n t l y q u e r i e d c o o l d o w n

Fields inherited from class net.i2p.router.networkdb.kademlia.KademliaNetworkDatabaseFacade
_context, _log, _networkID, _peerSelector, CURRENT_VERSION, DEFAULT_DB_DIR, DONT_FAIL_PERIOD, MAX_EXPLORE_QUEUE, MIN_REMAINING_ROUTERS, MIN_RESEED, MIN_ROUTER_VERSION, MIN_VERSION, PROP_BLOCK_MY_COUNTRY, PROP_BUCKET_SIZE, PROP_DB_DIR, PROP_EXPLORE_QUEUE, PROP_IP_COUNTRY, PROP_KAD_B, PROP_MIN_ROUTER_VERSION, PROP_ROUTER_INFO_EXPIRATION_ADJUSTED, PROP_VALIDATE_ROUTERS_AFTER

Constructor Summary
Constructors
Constructor and Description
FloodfillNetworkDatabaseFacade(RouterContext context)
Main DB
FloodfillNetworkDatabaseFacade(RouterContext context, Hash dbid)
Sub DBs

Constructors
Constructor and Description
`FloodfillNetworkDatabaseFacade(RouterContext context)` Main DB
`FloodfillNetworkDatabaseFacade(RouterContext context, Hash dbid)` Sub DBs

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`complete(Hash key)` Must be called by the search job queued by search() on success or failure
`void`	`contactHeardFrom(Hash peer)` Notify that we heard from or about a peer (e.g.
`protected void`	`createHandlers()` Register message handlers for DatabaseLookup and DatabaseStore.
`(package private) static void`	`decrementActiveFloodfillQuery(Hash floodfill)` Decrement the active outbound query count for a floodfill peer.
`void`	`flood(DatabaseEntry ds)` Send to a subset of all floodfill peers.
`boolean`	`floodConditional(DatabaseEntry ds)` If we are floodfill AND the key is not throttled, flood it, otherwise don't.
`boolean`	`floodfillEnabled()` For convenience, so users don't have to cast to FNDF, and unit tests using Dummy NDF will work.
`List<Hash>`	`getFloodfillPeers()` List of the hashes of currently known floodfill peers.
`List<RouterInfo>`	`getKnownRouterData()` Return all RouterInfo entries from the local data store.
`String`	`getTunnelName(Destination d)` Look up the tunnel pool nickname for a destination.
`(package private) static int`	`incrementActiveFloodfillQuery(Hash floodfill)` Increment the active outbound query count for a floodfill peer.
`static boolean`	`isFloodfill(RouterInfo peer)` Checks if a RouterInfo has floodfill capability.
`(package private) static boolean`	`isFloodfillOverloaded(Hash floodfill)` Check if a floodfill peer already has too many active outbound queries from this router.
`(package private) static boolean`	`isRecentlyQueried(Hash peer)` Check if a floodfill peer was queried recently (within cooldown period).
`(package private) boolean`	`isVerifyInProgress(Hash h)` Checks if verification is in progress for the specified hash.
`protected void`	`lookupBeforeDropping(Hash peer, RouterInfo info)` Search for a newer router info, drop it from the db if the search fails, unless just started up or have bigger problems.
`(package private) static void`	`markQueried(Hash peer)` Mark a floodfill peer as recently queried.
`(package private) void`	`probeStalePeer(Hash peer, RouterInfo ri)` Fire a DirectLookupJob for a stale peer, deduplicated via _activeFloodQueries.
`void`	`processElapsedTimeouts()` Process all elapsed search timeouts.
`void`	`publish(RouterInfo localRouterInfo)` Send our RI to the closest floodfill.
`void`	`registerSearchTimeout(Hash peer, IterativeSearchJob search, long timeoutMs)` Register a search timeout to be processed in batches.
`(package private) SearchJob`	`search(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, boolean isLease)` Lookup using exploratory tunnels.
`(package private) SearchJob`	`search(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, boolean isLease, Hash fromLocalDest)` Lookup using the client's tunnels.
`(package private) void`	`sendStore(Hash key, DatabaseEntry ds, Job onSuccess, Job onFailure, long sendTimeout, Set<Hash> toIgnore)` Send out a store.
`void`	`setFloodfillEnabled(boolean yes)` Public, called from console.
`(package private) void`	`setFloodfillEnabledFromMonitor(boolean yes)` Package private, called from FloodfillMonitorJob.
`(package private) boolean`	`shouldBanLookup(Hash from, TunnelId id)` Check if lookup from a peer should be banned.
`(package private) boolean`	`shouldThrottleFlood(Hash key)` Increments and tests.
`(package private) boolean`	`shouldThrottleLookup(Hash from, TunnelId id)` Increments and tests.
`void`	`shutdown()` If we are floodfill, turn it off and tell everybody.
`void`	`startTimeoutProcessor()` Start the batched timeout processor.
`void`	`startup()` Start monitor jobs, throttle, and optional router refresh.
`(package private) void`	`verifyFinished(Hash h)` Marks verification as finished for the specified hash.
`(package private) void`	`verifyStarted(Hash h)` Marks verification as started for the specified hash.

Methods inherited from class net.i2p.router.networkdb.kademlia.KademliaNetworkDatabaseFacade
accessLeaseSet, blindCache, cleanupLURouters, createPeerSelector, dropAfterLookupFailed, fail, failPermanently, findNearestRouters, getAllRouters, getBlindData, getBlindData, getClientLeases, getDataStore, getDbDir, getExploreKeys, getFloodfillLeases, getKBuckets, getKBucketSetSize, getKnownLeaseSets, getKnownRouters, getLastExploreNewDate, getLastRouterInfoPublishTime, getLeases, getPeerSelector, getPeerTimeout, getPublishedLeases, getRouterIPPort, getRouters, getStoredRouterInfoCount, getUnpublishedLeases, hasActiveRepublishJob, isClientDb, isInitialized, isNegativeCached, isNegativeCachedForever, isNewer, lookupDestination, lookupDestinationLocally, lookupFailed, lookupLeaseSet, lookupLeaseSet, lookupLeaseSetLocally, lookupLeaseSetRemotely, lookupLeaseSetRemotely, lookupLocally, lookupLocallyWithoutValidation, lookupRouterInfo, lookupRouterInfoLocally, lookupRouterInfoRemote, markHostCheckerLeaseSet, negativeCacheNow, publish, purgeMatchingRouters, queueForExploration, registerPublishingJob, removeBlindData, removeFromCache, removeFromExploreKeys, removeLeaseSetFromTracking, removePublishingJob, removeRouterInfo, renderStatusHTML, rescan, reseedChecker, routerInfoPublishSuccessful, routingKeyChanged, searchComplete, setBlindData, setLastExploreNewDate, stopPublishing, store, store, store, store, toString, unpublish, validate, validate

Methods inherited from class net.i2p.router.NetworkDatabaseFacade
store

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.i2p.router.Service
restart

- Field Detail
  - _recentlyQueriedFloodfills
```
static final ConcurrentHashMap<Hash,Long> _recentlyQueriedFloodfills
```
    Tracks recently-queried floodfill peers across all concurrent searches to avoid hammering the same floodfill. Entries expire after 60s.
  - CAPABILITY_BW_UNLIMITED
```
public static final char CAPABILITY_BW_UNLIMITED
```
    Unlimited bandwidth capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_BW12
```
public static final char CAPABILITY_BW12
```
    Bandwidth 12 Kbps capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_BW128
```
public static final char CAPABILITY_BW128
```
    Bandwidth 128 Kbps capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_BW256
```
public static final char CAPABILITY_BW256
```
    Bandwidth 256 Kbps capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_BW32
```
public static final char CAPABILITY_BW32
```
    Bandwidth 32 Kbps capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_BW512
```
public static final char CAPABILITY_BW512
```
    Bandwidth 512 Kbps capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_BW64
```
public static final char CAPABILITY_BW64
```
    Bandwidth 64 Kbps capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_CONGESTION_MODERATE
```
public static final char CAPABILITY_CONGESTION_MODERATE
```
    Moderate congestion capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_CONGESTION_SEVERE
```
public static final char CAPABILITY_CONGESTION_SEVERE
```
    Severe congestion capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_FLOODFILL
```
public static final char CAPABILITY_FLOODFILL
```
    Floodfill capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_NO_TUNNELS
```
public static final char CAPABILITY_NO_TUNNELS
```
    No tunnels capability flag.
    See Also:
    Constant Field Values
  - CAPABILITY_UNREACHABLE
```
public static final char CAPABILITY_UNREACHABLE
```
    Unreachable capability flag.
    See Also:
    Constant Field Values
  - MAX_RI_AGE_BEFORE_REFRESH_MS
```
static final long MAX_RI_AGE_BEFORE_REFRESH_MS
```
    Max age (ms) for a RouterInfo stored in our NetDB before we consider refreshing it. RIs published within this window are treated as fresh.
    See Also:
    Constant Field Values
  - MAX_TO_FLOOD
```
public static final int MAX_TO_FLOOD
```
    This is the flood redundancy. Entries are sent to this many other floodfills. Was 7 through release 0.9; 5 for 0.9.1. 4 as of 0.9.2; 3 as of 0.9.9
    See Also:
    Constant Field Values
  - MIN_ACTIVE_PEERS
```
protected static final int MIN_ACTIVE_PEERS
```
    Minimum number of active peers before dropping router info lookups. NTCP connections drop quickly but SSU takes a while, so this is kept a little higher than 1 or 2.
  - NEXT_RKEY_RI_ADVANCE_TIME
```
static final long NEXT_RKEY_RI_ADVANCE_TIME
```
    Advance time before midnight to flood to next routing key for RouterInfo.
    See Also:
    Constant Field Values
  - PROP_FLOODFILL_AT_RESTART
```
public static final String PROP_FLOODFILL_AT_RESTART
```
    Config property recording floodfill status at previous restart.
    See Also:
    Constant Field Values
  - PROP_FLOODFILL_PARTICIPANT
```
public static final String PROP_FLOODFILL_PARTICIPANT
```
    Config property for floodfill participation.
    See Also:
    Constant Field Values
  - PUBLISH_TIMEOUT
```
static final long PUBLISH_TIMEOUT
```
    This maybe could be shorter than RepublishLeaseSetJob.REPUBLISH_LEASESET_TIMEOUT, because we are sending direct, but unresponsive floodfills may take a while due to timeouts.
    See Also:
    Constant Field Values
  - RECENTLY_QUERIED_COOLDOWN
```
static final long RECENTLY_QUERIED_COOLDOWN
```
    R e c e n t l y q u e r i e d c o o l d o w n
    See Also:
    Constant Field Values
- Constructor Detail
  - FloodfillNetworkDatabaseFacade
```
public FloodfillNetworkDatabaseFacade(RouterContext context)
```
    Main DB
  - FloodfillNetworkDatabaseFacade
```
public FloodfillNetworkDatabaseFacade(RouterContext context,
                                      Hash dbid)
```
    Sub DBs
    Parameters:
    dbid - null for main DB
- Method Detail
  - complete
```
void complete(Hash key)
```
    Must be called by the search job queued by search() on success or failure
  - contactHeardFrom
```
public void contactHeardFrom(Hash peer)
```
    Notify that we heard from or about a peer (e.g. received a DatabaseStoreMessage from them). The ContactDrivenRefreshJob will consider refreshing their RouterInfo if it is stale.
    Parameters:
    peer - the peer
  - createHandlers
```
protected void createHandlers()
```
    Register message handlers for DatabaseLookup and DatabaseStore.
    Overrides:
    createHandlers in class KademliaNetworkDatabaseFacade
  - decrementActiveFloodfillQuery
```
static void decrementActiveFloodfillQuery(Hash floodfill)
```
    Decrement the active outbound query count for a floodfill peer. Call when the search for this peer completes, fails, or times out.
  - flood
```
public void flood(DatabaseEntry ds)
```
    Send to a subset of all floodfill peers. We do this to implement Kademlia within the floodfills, i.e. we flood to those closest to the key.
  - floodConditional
```
public boolean floodConditional(DatabaseEntry ds)
```
    If we are floodfill AND the key is not throttled, flood it, otherwise don't.
    Returns:
    if we did
  - floodfillEnabled
```
public boolean floodfillEnabled()
```
    Description copied from class: NetworkDatabaseFacade
    For convenience, so users don't have to cast to FNDF, and unit tests using Dummy NDF will work.
    Overrides:
    floodfillEnabled in class NetworkDatabaseFacade
    Returns:
    whether this router participates in floodfill
  - getFloodfillPeers
```
public List<Hash> getFloodfillPeers()
```
    List of the hashes of currently known floodfill peers.
    Returns:
    list of floodfill peer hashes, not including our own hash; not sorted and not shuffled
  - getKnownRouterData
```
public List<RouterInfo> getKnownRouterData()
```
    Return all RouterInfo entries from the local data store.
    Returns:
    list of known RouterInfo objects, never null
  - getTunnelName
```
public String getTunnelName(Destination d)
```
    Look up the tunnel pool nickname for a destination.
  - incrementActiveFloodfillQuery
```
static int incrementActiveFloodfillQuery(Hash floodfill)
```
    Increment the active outbound query count for a floodfill peer. Call when sendQuery() dispatches a DatabaseLookupMessage to this peer.
    Returns:
    the new count
  - isFloodfill
```
public static boolean isFloodfill(RouterInfo peer)
```
    Checks if a RouterInfo has floodfill capability.
    Parameters:
    peer - may be null, returns false if null
    Returns:
    whether floodfill
  - isFloodfillOverloaded
```
static boolean isFloodfillOverloaded(Hash floodfill)
```
    Check if a floodfill peer already has too many active outbound queries from this router. Spreads the load across available floodfills so no single peer is saturated.
    Returns:
    true if the peer should be skipped for now
  - isRecentlyQueried
```
static boolean isRecentlyQueried(Hash peer)
```
    Check if a floodfill peer was queried recently (within cooldown period).
    Returns:
    true if the peer was queried within the last 60s
  - isVerifyInProgress
```
boolean isVerifyInProgress(Hash h)
```
    Checks if verification is in progress for the specified hash.
  - lookupBeforeDropping
```
protected void lookupBeforeDropping(Hash peer,
                                    RouterInfo info)
```
    Search for a newer router info, drop it from the db if the search fails, unless just started up or have bigger problems.
    Overrides:
    lookupBeforeDropping in class KademliaNetworkDatabaseFacade
    Parameters:
    peer - the peer
    info - the router info
  - markQueried
```
static void markQueried(Hash peer)
```
    Mark a floodfill peer as recently queried. Other searches will avoid this peer for the cooldown period.
  - probeStalePeer
```
void probeStalePeer(Hash peer,
                    RouterInfo ri)
```
    Fire a DirectLookupJob for a stale peer, deduplicated via _activeFloodQueries. Caller should already have verified the peer is stale and not recently probed.
  - processElapsedTimeouts
```
public void processElapsedTimeouts()
```
    Process all elapsed search timeouts. Called by BatchedSearchTimeoutJob.
  - publish
```
public void publish(RouterInfo localRouterInfo)
             throws IllegalArgumentException
```
    Send our RI to the closest floodfill.
    Overrides:
    publish in class KademliaNetworkDatabaseFacade
    Parameters:
    localRouterInfo - the RouterInfo to publish
    Throws:
    IllegalArgumentException - if the local router info is invalid
  - registerSearchTimeout
```
public void registerSearchTimeout(Hash peer,
                                  IterativeSearchJob search,
                                  long timeoutMs)
```
    Register a search timeout to be processed in batches. Instead of creating individual IterativeTimeoutJob for each peer, we register here and a single BatchedSearchTimeoutJob processes all at once.
    Parameters:
    peer - the peer
    search - the search term
    timeoutMs - the absolute time when the timeout expires
  - search
```
SearchJob search(Hash key,
                 Job onFindJob,
                 Job onFailedLookupJob,
                 long timeoutMs,
                 boolean isLease)
```
    Lookup using exploratory tunnels. Caller should check negative cache and/or banlist before calling. Begin a kademlia style search for the key specified, which can take up to timeoutMs and will fire the appropriate jobs on success or timeout (or if the kademlia search completes without any match)
    Overrides:
    search in class KademliaNetworkDatabaseFacade
    Parameters:
    key - the hash to search for
    onFindJob - job on find
    onFailedLookupJob - job on failure
    timeoutMs - timeout in ms
    isLease - whether searching for lease
    Returns:
    null always
  - search
```
SearchJob search(Hash key,
                 Job onFindJob,
                 Job onFailedLookupJob,
                 long timeoutMs,
                 boolean isLease,
                 Hash fromLocalDest)
```
    Lookup using the client's tunnels. Caller should check negative cache and/or banlist before calling.
    Overrides:
    search in class KademliaNetworkDatabaseFacade
    Parameters:
    fromLocalDest - use these tunnels for the lookup, or null for exploratory
    key - the hash to search for
    onFindJob - job on find
    onFailedLookupJob - job on failure
    timeoutMs - timeout in ms
    isLease - whether searching for lease
    Returns:
    null always
  - sendStore
```
void sendStore(Hash key,
               DatabaseEntry ds,
               Job onSuccess,
               Job onFailure,
               long sendTimeout,
               Set<Hash> toIgnore)
```
    Send out a store.
    Specified by:
    sendStore in class KademliaNetworkDatabaseFacade
    Parameters:
    key - the DatabaseEntry hash
    onSuccess - may be null, always called if we are ff and ds is an RI
    onFailure - may be null, ignored if we are ff and ds is an RI
    sendTimeout - timeout in ms for send operations if we are ff and ds is an RI
    toIgnore - may be null, if non-null, all attempted and skipped targets will be added as of 0.9.53, unused if we are ff and ds is an RI
    ds - the database entry
  - setFloodfillEnabled
```
public void setFloodfillEnabled(boolean yes)
```
    Public, called from console. This wakes up the floodfill monitor, which will rebuild the RI and log in the event log, and call setFloodfillEnabledFromMonitor which really sets it.
  - setFloodfillEnabledFromMonitor
```
void setFloodfillEnabledFromMonitor(boolean yes)
```
    Package private, called from FloodfillMonitorJob. This does not wake up the floodfill monitor.
  - shouldBanLookup
```
boolean shouldBanLookup(Hash from,
                        TunnelId id)
```
    Check if lookup from a peer should be banned.
    Parameters:
    from - the peer hash
    id - the tunnel ID
    Returns:
    true if the lookup should be banned
  - shouldThrottleFlood
```
boolean shouldThrottleFlood(Hash key)
```
    Increments and tests.
    Returns:
    true if the flood should be throttled for this key
  - shouldThrottleLookup
```
boolean shouldThrottleLookup(Hash from,
                             TunnelId id)
```
    Increments and tests.
    Returns:
    true if the lookup should be throttled for this peer/tunnel
  - shutdown
```
public void shutdown()
```
    If we are floodfill, turn it off and tell everybody.
    Specified by:
    shutdown in interface Service
    Overrides:
    shutdown in class KademliaNetworkDatabaseFacade
  - startTimeoutProcessor
```
public void startTimeoutProcessor()
```
    Start the batched timeout processor. Called from startup().
  - startup
```
public void startup()
```
    Start monitor jobs, throttle, and optional router refresh.
    Specified by:
    startup in interface Service
    Overrides:
    startup in class KademliaNetworkDatabaseFacade
  - verifyFinished
```
void verifyFinished(Hash h)
```
    Marks verification as finished for the specified hash.
  - verifyStarted
```
void verifyStarted(Hash h)
```
    Marks verification as started for the specified hash.

Class FloodfillNetworkDatabaseFacade

Field Summary

Fields inherited from class net.i2p.router.networkdb.kademlia.KademliaNetworkDatabaseFacade

Constructor Summary

Method Summary

Methods inherited from class net.i2p.router.networkdb.kademlia.KademliaNetworkDatabaseFacade

Methods inherited from class net.i2p.router.NetworkDatabaseFacade

Methods inherited from class java.lang.Object

Methods inherited from interface net.i2p.router.Service

Field Detail

_recentlyQueriedFloodfills

CAPABILITY_BW_UNLIMITED

CAPABILITY_BW12

CAPABILITY_BW128

CAPABILITY_BW256

CAPABILITY_BW32

CAPABILITY_BW512

CAPABILITY_BW64

CAPABILITY_CONGESTION_MODERATE

CAPABILITY_CONGESTION_SEVERE

CAPABILITY_FLOODFILL

CAPABILITY_NO_TUNNELS

CAPABILITY_UNREACHABLE

MAX_RI_AGE_BEFORE_REFRESH_MS

MAX_TO_FLOOD

MIN_ACTIVE_PEERS

NEXT_RKEY_RI_ADVANCE_TIME

PROP_FLOODFILL_AT_RESTART

PROP_FLOODFILL_PARTICIPANT

PUBLISH_TIMEOUT

RECENTLY_QUERIED_COOLDOWN

Constructor Detail

FloodfillNetworkDatabaseFacade

FloodfillNetworkDatabaseFacade

Method Detail

complete

contactHeardFrom

createHandlers

decrementActiveFloodfillQuery

flood

floodConditional

floodfillEnabled

getFloodfillPeers

getKnownRouterData

getTunnelName

incrementActiveFloodfillQuery

isFloodfill

isFloodfillOverloaded

isRecentlyQueried

isVerifyInProgress

lookupBeforeDropping

markQueried

probeStalePeer

processElapsedTimeouts

publish

registerSearchTimeout

search

search

sendStore

setFloodfillEnabled

setFloodfillEnabledFromMonitor

shouldBanLookup

shouldThrottleFlood

shouldThrottleLookup

shutdown

startTimeoutProcessor

startup

verifyFinished

verifyStarted