FloodfillNetworkDatabaseFacade

net.i2p.router.networkdb.kademlia.FloodfillNetworkDatabaseFacade

All Implemented Interfaces:: Service

public class FloodfillNetworkDatabaseFacadeextends KademliaNetworkDatabaseFacade

The Kademlia network database, using floodfill participants as the only storage tier.

Nested Class Summary
Nested Classes
Modifier and Type
Class
Description
private class
FloodfillNetworkDatabaseFacade.BatchedSearchTimeoutProcessor
Batched job that processes all search timeouts periodically.
private class
FloodfillNetworkDatabaseFacade.DelayedPublish
Don't actually publish unless the RI didn't change during the delay.
private class
FloodfillNetworkDatabaseFacade.DropLookupFailedJob
Remove a failing peer after a lookup timeout.
private class
FloodfillNetworkDatabaseFacade.DropLookupFoundJob
Verify a failing peer after a successful lookup.
private static class
FloodfillNetworkDatabaseFacade.FloodFailedJob
Record the store failure in the peer profile.
private static class
FloodfillNetworkDatabaseFacade.FloodSuccessJob
Note in the profile that the store succeeded.
private static class
FloodfillNetworkDatabaseFacade.TimeoutEntry
Lightweight entry for batched timeout processing.
Field Summary
Modifier and Type
Field
Description
private final ConcurrentHashMap<Hash, FloodSearchJob>
_activeFloodQueries
Active flood queries keyed by search hash.
private final ContactDrivenRefreshJob
_contactRefreshJob
Job to refresh RouterInfo on contact.
private final Job
_ffMonitor
Floodfill monitor job for capability management.
private boolean
_floodfillEnabled
Whether this router is currently floodfill-enabled.
private FloodThrottler
_floodThrottler
Throttles excessive flood operations.
private final IntroducerLookupJob
_introducerLookupJob
Job to prefetch introducer RIs of unreachable peers.
private static long
_lastClientSubDbWarn
Rate-limit Client subDb exploratory drop WARN (10s).
private LookupBanHammer
_lookupBanner
Ban hammer for abusive lookup peers.
private LookupThrottler
_lookupThrottler
Throttles excessive lookup operations.
private final ProbeStalePeerJob
_probeStalePeerJob
Job to probe stale floodfill peers.
private final ConcurrentHashMap<Long, List<FloodfillNetworkDatabaseFacade.TimeoutEntry>>
_searchTimeouts
Batched search timeout entries keyed by bucket.
private final FloodfillNetworkDatabaseFacade.BatchedSearchTimeoutProcessor
_timeoutProcessor
Periodic processor for elapsed search timeouts.
private final Set<Hash>
_verifiesInProgress
Hashes whose verification is in progress.
static final char
CAPABILITY_BW_UNLIMITED
Unlimited bandwidth capability flag.
static final char
CAPABILITY_BW12
Bandwidth 12 Kbps capability flag.
static final char
CAPABILITY_BW128
Bandwidth 128 Kbps capability flag.
static final char
CAPABILITY_BW256
Bandwidth 256 Kbps capability flag.
static final char
CAPABILITY_BW32
Bandwidth 32 Kbps capability flag.
static final char
CAPABILITY_BW512
Bandwidth 512 Kbps capability flag.
static final char
CAPABILITY_BW64
Bandwidth 64 Kbps capability flag.
static final char
CAPABILITY_CONGESTION_MODERATE
Moderate congestion capability flag.
static final char
CAPABILITY_CONGESTION_SEVERE
Severe congestion capability flag.
static final char
CAPABILITY_FLOODFILL
Floodfill capability flag.
static final char
CAPABILITY_NO_TUNNELS
No tunnels capability flag.
static final char
CAPABILITY_UNREACHABLE
Unreachable capability flag.
private static final long
CLIENT_SUBDB_WARN_INTERVAL
Interval between the client subDB warnings.
private static final int
FLOOD_PRIORITY
Priority for flood outbound messages.
private static final int
FLOOD_TIMEOUT
Timeout for individual flood messages.
private static final int
INITIAL_CONCURRENT
Initial number of concurrent floodfill peers for store operations.
private static final int
MAX_DB_BEFORE_SKIPPING_SEARCH
Maximum database size before skipping exploratory searches.
private static final int
MAX_LAG_BEFORE_SKIP_SEARCH
Max job queue lag before skipping exploratory searches.
(package private) static final long
MAX_RI_AGE_BEFORE_REFRESH_MS
Max age (ms) for a RouterInfo stored in our NetDB before we consider refreshing it.
static final int
MAX_TO_FLOOD
This is the flood redundancy.
protected static final int
MIN_ACTIVE_PEERS
Minimum number of active peers before dropping router info lookups.
private static final int
NEXT_FLOOD_QTY
Number of additional peers to flood near routing key rollover.
private static final long
NEXT_RKEY_LS_ADVANCE_TIME
Advance time before midnight to flood to next routing key for LeaseSet.
(package private) static final long
NEXT_RKEY_RI_ADVANCE_TIME
Advance time before midnight to flood to next routing key for RouterInfo.
static final String
PROP_FLOODFILL_AT_RESTART
Config property recording floodfill status at previous restart.
static final String
PROP_FLOODFILL_PARTICIPANT
Config property for floodfill participation.
private static final int
PUBLISH_JOB_DELAY
Delay before publishing RouterInfo at startup.
(package private) 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.
Fields inherited from class KademliaNetworkDatabaseFacade
_context, _log, _networkID, _peerSelector, CURRENT_VERSION, DEFAULT_DB_DIR, DONT_FAIL_PERIOD, IP_GROUP_BUCKET_LIMIT, IP_GROUP_GLOBAL_LIMIT, MAX_EXPLORE_QUEUE, MAX_INTRO_SLOTS, MIN_REMAINING_ROUTERS, MIN_RESEED, MIN_ROUTER_VERSION, MIN_VERSION, PROP_BLOCK_MY_COUNTRY, PROP_BUCKET_SIZE, PROP_DB_DIR, PROP_IP_COUNTRY, PROP_MIN_ROUTER_VERSION, PROP_ROUTER_INFO_EXPIRATION_ADJUSTED, PROP_VALIDATE_ROUTERS_AFTER, UNVERIFIED_MAX, UNVERIFIED_MAX_AGE
Modifier and Type
Field
Description
protected final RouterContext
_context
_context.
protected final Log
_log
Class logger.
protected final int
_networkID
Network identifier.
protected final PeerSelector
_peerSelector
_peerSelector.
static String
CURRENT_VERSION
Current minor version identifier for net DB format.
static final String
DEFAULT_DB_DIR
Default database directory name.
static long
DONT_FAIL_PERIOD
For 15 minutes after startup, don't fail db entries so that if we were offline for a while, we'll have a chance of finding some live peers with the previous references.
(package private) static final int
IP_GROUP_BUCKET_LIMIT
Max bucket entries sharing one IP group — eclipse/Sybil resistance, mirrors kubo's table.go limits.
(package private) static final int
IP_GROUP_GLOBAL_LIMIT
Max entries across all buckets sharing one IP group.
(package private) static final int
MAX_EXPLORE_QUEUE
Maximum number of peers to place in the queue to explore.
(package private) static final int
MAX_INTRO_SLOTS
Introducer slots per transport address.
protected static final int
MIN_REMAINING_ROUTERS
If we have less than this many routers left, don't drop any more, even if they're failing or doing bad stuff.
(package private) static final int
MIN_RESEED
Reseed if below this.
static final String
MIN_ROUTER_VERSION
Lowest peer version that may be selected for a KBucket probe.
static final String
MIN_VERSION
Lowest peer version whose LeaseSets we will store and serve.
static final String
PROP_BLOCK_MY_COUNTRY
Config property for blocking own-country peers.
(package private) static final String
PROP_BUCKET_SIZE
Property: Kademlia bucket size (K), read once at startup.
static final String
PROP_DB_DIR
Config property for database directory.
static final String
PROP_IP_COUNTRY
Config property for IP country override.
(package private) static final String
PROP_MIN_ROUTER_VERSION
Property: minimum router version for exploration.
(package private) static final String
PROP_ROUTER_INFO_EXPIRATION_ADJUSTED
Property: adjusted RouterInfo expiration time in ms.
(package private) static final String
PROP_VALIDATE_ROUTERS_AFTER
Property: delay before validating routers in ms.
(package private) static final int
UNVERIFIED_MAX
Max peers held awaiting direct-contact verification.
(package private) static final long
UNVERIFIED_MAX_AGE
Drop a pending peer from the verification queue after this long; it is still in the netdb, it just stops being a bucket candidate until it proves itself.
Constructor Summary
Constructors
Constructor
Description
FloodfillNetworkDatabaseFacade(RouterContext context)
Main DB.
FloodfillNetworkDatabaseFacade(RouterContext context, Hash dbid)
Sub DBs.
Method Summary
Modifier and Type
Method
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.
private void
failSearchCallbacks(Job onFindJob, Job onFailedLookupJob)
Queue failure callbacks so a search that cannot start never leaves the caller waiting for a timeout that will never be scheduled.
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()
Whether this router is currently acting as a floodfill.
List<Hash>
getFloodfillPeers()
List of the hashes of currently known floodfill peers.
List<RouterInfo>
getKnownRouterData()
Return all RouterInfo entries from the local data store.
private FloodfillNetworkDatabaseFacade
getMainFacade()
Main (router) NetDb facade, or null if not yet available.
String
getTunnelName(Destination d)
Look up the tunnel pool nickname for a destination.
static boolean
isFloodfill(RouterInfo peer)
Checks if a RouterInfo has floodfill capability.
(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) 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.
private Set<Hash>
selectFloodfillParticipants(Set<Hash> toIgnore, int concurrent)
Selects a set of floodfill participant peers to which data should be sent: random selection among the filtered floodfill participants, preferring peers not queried in the last 60s to spread load, with a fallback top-up so store operations never starve.
(package private) static Set<Hash>
selectStoreParticipants(List<Hash> shuffled, int concurrent, Set<Hash> recentlyQueried)
Select up to concurrent store participants, preferring peers not queried in the last 60s to spread load, with a fallback top-up so store operations never starve.
(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) static boolean
shouldFloodOnStore(boolean floodfillEnabled, DatabaseEntry ds)
Whether sendStore should wide-flood the entry via flood(DatabaseEntry) when this router participates in floodfill.
private boolean
shouldFloodTo(Hash key, int type, SigType lsSigType, Hash peer, RouterInfo target)
Determines if we should flood the database store to a peer.
(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) static int
storeJobCount(boolean floodfillEnabled, DatabaseEntry ds, int selectedCount)
How many FloodfillStoreJob instances sendStore should schedule alongside (or instead of) a wide flood.
(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 KademliaNetworkDatabaseFacade
accessLeaseSet, addContact, blindCache, bucketSize, buildBucketTable, clearNegativeCache, createPeerSelector, decrementActiveFloodfillQuery, dropAfterLookupFailed, entryLinks, fail, failPermanently, findNearestRouters, getAllRouters, getBlindData, getBlindData, getClientLeases, getDataStore, getDbDir, getDebugStats, getExploreKeys, getFloodfillLeases, getKBuckets, getKBucketSetSize, getKnownLeaseSets, getKnownRouters, getLastExploreNewDate, getLastRouterInfoPublishTime, getLeases, getPeerSelector, getPeerTimeout, getPublishedLeases, getRouters, getStoredRouterInfoCount, getUnpublishedLeases, getUnverifiedPeerCount, getUnverifiedPeersSnapshot, hasActiveRepublishJob, hasDirectContact, hasDirectContact, incrementActiveFloodfillQuery, invalidRouterInfoBanReason, invalidRouterInfoBanReason, ipDiversityAllows, ipGroup, ipGroups, isClientDb, isFloodfillOverloaded, isInitialized, isNegativeCached, isNegativeCachedForever, isNewer, isRecentlyQueried, lookupDestination, lookupDestinationLocally, lookupFailed, lookupLeaseSet, lookupLeaseSet, lookupLeaseSetLocally, lookupLeaseSetRemotely, lookupLeaseSetRemotely, lookupLocally, lookupLocallyWithoutValidation, lookupRIUnvalidated, lookupRouterInfo, lookupRouterInfoLocally, lookupRouterInfoRemote, lookupTimeout, markQueried, peekNegativeCached, promoteUnverifiedPeers, publish, purgeMatchingRouters, queueForExploration, registerPublishingJob, removeBlindData, removeFromExploreKeys, removeLeaseSetFromTracking, removePublishingJob, removeRouterInfo, renderStatusHTML, rescan, reseedChecker, routerInfoPublishSuccessful, routingKeyChanged, searchComplete, setBlindData, setLastExploreNewDate, shouldAcceptLeaseSet, shouldFailLocalWithoutRemoteSearch, shouldFallbackLocalLookupToMain, stopPublishing, store, store, store, store, stripStoreWrapper, tooManyIntroducers, toString, unpublish, validate, validate
Modifier and Type
Method
Description
void
accessLeaseSet(Hash key)
Record access to a LeaseSet for refresh tracking.
(package private) boolean
addContact(Hash key)
Policy entry point for peers learned from search replies, where no RouterInfo is in hand yet: direct-contact gate only.
protected BlindCache
blindCache()
Returns the blind data cache used by this database.
(package private) static int
bucketSize(RouterContext context)
Bucket size (K) from the property, clamped to what KBucketSet accepts.
(package private) static String
buildBucketTable(List<String[]> rows, int capacity, java.util.function.Function<String,String> entryRenderer, java.util.function.Function<String,String> tr)
Build the bucket table from the rows of KBucketSet.getDebugBucketRows(): bucket index, XOR-distance bit range, entry count as a details/summary disclosure whose expanded content is the entry hashes rendered by the given function, and fill as a percentage of capacity.
void
clearNegativeCache(Hash key)
Clear any transient (non-permanent) negative-cache entry for the given key so the next KademliaNetworkDatabaseFacade.lookupLeaseSet(Hash, Job, Job, long) performs a real search instead of aborting instantly.
protected PeerSelector
createPeerSelector()
Creates a peer selector for the network database.
(package private) void
decrementActiveFloodfillQuery(Hash floodfill)
Decrement the active outbound query count for a floodfill peer.
(package private) boolean
dropAfterLookupFailed(Hash peer)
Final remove for a router info.
(package private) static String
entryLinks(String keys, java.util.function.Function<String,String> entryRenderer)
Entry hashes rendered through the given function, sorted for stable display.
void
fail(Hash dbEntry)
Final remove for a leaseset.
(package private) void
failPermanently(Destination dest)
Negative cache until restart.
Set<Hash>
findNearestRouters(Hash key, int maxNumRouters, Set<Hash> peersToIgnore)
The routers closest to that key in response to a remote lookup.
Set<Hash>
getAllRouters()
Hashes for all known routers.
List<BlindData>
getBlindData()
All cached BlindData.
BlindData
getBlindData(SigningPublicKey spk)
BlindData for the given key.
Set<LeaseSet>
getClientLeases()
LeaseSets published by this router's clients.
(package private) DataStore
getDataStore()
The data store.
(package private) String
getDbDir()
For the main DB only.
long[]
getDebugStats()
Debug overview stats: total keys, bucket count, per-bucket capacity and fullest bucket size, as {keys, buckets, capacity, fullest}.
Set<Hash>
getExploreKeys()
Keys to explore.
Set<LeaseSet>
getFloodfillLeases()
LeaseSets stored in the floodfill database.
(package private) KBucketSet<Hash>
getKBuckets()
KBucketSet for the main DB.
protected int
getKBucketSetSize()
Size of the KBucketSet.
int
getKnownLeaseSets()
This is only used by StatisticsManager to publish the count if we are floodfill.
int
getKnownRouters()
This used to return the number of routers that were in both the kbuckets AND the data store, which was fine when the kbuckets held everything.
(package private) long
getLastExploreNewDate()
Time of the last explore run.
long
getLastRouterInfoPublishTime()
Time of the last successful RI publication.
Set<LeaseSet>
getLeases()
All known LeaseSets for display.
PeerSelector
getPeerSelector()
Returns the main database's peer selector.
int
getPeerTimeout(Hash peer)
How long to wait for one peer's reply, scaled from its profile.
Set<LeaseSet>
getPublishedLeases()
LeaseSets published to the network.
Set<RouterInfo>
getRouters()
RouterInfos stored in the database.
int
getStoredRouterInfoCount()
Number of RouterInfo files stored on disk, if using PersistentDataStore.
Set<LeaseSet>
getUnpublishedLeases()
LeaseSets not published to the network.
(package private) int
getUnverifiedPeerCount()
The pending-verification queue size, for tests and the debug console.
(package private) Set<Hash>
getUnverifiedPeersSnapshot()
Snapshot of the pending-verification queue, for the probe cycle to target.
(package private) boolean
hasActiveRepublishJob(Hash hash)
Check if an active republish job exists for the given destination.
(package private) boolean
hasDirectContact(Hash peer)
Have we ever heard from this peer directly, as opposed to merely being told about it? An established session or a profile with a received message or successful send counts.
(package private) static boolean
hasDirectContact(PeerProfile prof)
Direct-contact test on profile evidence only: heard-from or successful-send, never heard-about (that only means someone mentioned them).
(package private) int
incrementActiveFloodfillQuery(Hash floodfill)
Increment the active outbound query count for a floodfill peer.
(package private) String
invalidRouterInfoBanReason(RouterInfo ri)
The ban reason if this RouterInfo fails one of the RouterInfo validation rules - a version above every released version, an impossible publication date, or both the reachable and the unreachable flag at once - or null if it passes.
(package private) static String
invalidRouterInfoBanReason(RouterInfo ri, boolean banVersion, boolean banPubDate, boolean banCaps)
The validation rule a RouterInfo breaks, given which of the three rules are switched on.
(package private) boolean
ipDiversityAllows(Hash key, RouterInfo routerInfo)
Would adding this peer to its bucket exceed the per-bucket or global IP-group caps? Peers with no literal-IP address are unconstrained.
(package private) static Long
ipGroup(byte[] ip)
IP group key: /16 for IPv4, /48 for IPv6, packed into a long with a family marker bit so the two families never collide.
(package private) static Set<Long>
ipGroups(RouterInfo ri)
The distinct IP groups of a router's literal-IP addresses.
boolean
isClientDb()
Check if the database is a client DB.
(package private) boolean
isFloodfillOverloaded(Hash floodfill)
Check if a floodfill peer already has too many active outbound queries from this router.
boolean
isInitialized()
Checks whether the network database has been fully initialized.
(package private) boolean
isNegativeCached(Hash key)
Is the key in the negative lookup cache?
boolean
isNegativeCachedForever(Hash key)
Is it permanently negative cached?
static boolean
isNewer(LeaseSet a, LeaseSet b)
Utility to determine if a is newer than b.
(package private) boolean
isRecentlyQueried(Hash peer)
Check if a floodfill peer was queried recently (within cooldown period).
void
lookupDestination(Hash key, Job onFinishedJob, long timeoutMs, Hash fromLocalDest)
Lookup using the client's tunnels Succeeds even if LS validation and store fails due to unsupported sig type, expired, etc.
Destination
lookupDestinationLocally(Hash key)
Destination stored locally, or null.
(package private) void
lookupFailed(Hash key)
Increment in the negative lookup cache.
void
lookupLeaseSet(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs)
Look up a LeaseSet, locally first.
void
lookupLeaseSet(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, Hash fromLocalDest)
Lookup using the client's tunnels Use KademliaNetworkDatabaseFacade.lookupDestination(Hash, Job, long, Hash) if you don't need the LS or don't need it validated.
LeaseSet
lookupLeaseSetLocally(Hash key)
LeaseSet stored locally.
void
lookupLeaseSetRemotely(Hash key, Hash fromLocalDest)
Unconditionally lookup using the client's tunnels, with no jobs.
void
lookupLeaseSetRemotely(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, Hash fromLocalDest)
Unconditionally lookup using the client's tunnels.
DatabaseEntry
lookupLocally(Hash key)
Validated entry stored locally.
DatabaseEntry
lookupLocallyWithoutValidation(Hash key)
Not for use without validation.
(package private) RouterInfo
lookupRIUnvalidated(Hash key)
Look up a peer's RouterInfo without running the full KademliaNetworkDatabaseFacade.validate(RouterInfo) ban cascade.
void
lookupRouterInfo(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs)
Look up a RouterInfo, resolving over the network when not cached locally.
RouterInfo
lookupRouterInfoLocally(Hash key)
This will return immediately with the result or null.
void
lookupRouterInfoRemote(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs)
Look up a RouterInfo by hash, performing a network search if not locally cached.
(package private) void
lookupTimeout(Hash key)
Pure-timeout search failure (no peer replied).
(package private) void
markQueried(Hash peer)
Mark a floodfill peer as recently queried.
boolean
peekNegativeCached(Hash key)
Negative-cache check without recording an abort stat.
(package private) int
promoteUnverifiedPeers()
Move pending peers that have earned direct-contact evidence into the routing buckets, and drop those that waited too long.
void
publish(LeaseSet localLeaseSet)
Publishes a local LeaseSet to the network: stores it in this facade and, for a client facade, also in the floodfill facade, then schedules republishing.
void
purgeMatchingRouters()
Trigger a retroactive purge sweep of the NetDb.
void
queueForExploration(Collection<Hash> keys)
Queue keys for exploration.
(package private) boolean
registerPublishingJob(RepublishLeaseSetJob job)
Register a new job for tracking.
boolean
removeBlindData(SigningPublicKey spk)
For console ConfigKeyringHelper.
void
removeFromExploreKeys(Collection<Hash> toRemove)
Remove keys from the exploration set.
void
removeLeaseSetFromTracking(Hash key)
Remove a LeaseSet from refresh tracking.
(package private) void
removePublishingJob(Hash hash, RepublishLeaseSetJob job)
Remove a specific job from the tracking set.
void
removeRouterInfo(Hash key)
Remove a RouterInfo from the local netdb.
void
renderStatusHTML(Writer out)
Render the KBucket summary and a per-bucket table.
void
rescan()
Rescan the netdb directory for new RouterInfo files.
ReseedChecker
reseedChecker()
Reseed checker, or null for a client DB.
(package private) void
routerInfoPublishSuccessful()
Record the current time as the last successful RI publication.
void
routingKeyChanged()
Notify the netDB that the routing key changed at midnight UTC.
(package private) void
searchComplete(Hash key)
The search for the given key is no longer active.
void
setBlindData(BlindData bd)
BlindData to put in the cache.
(package private) void
setLastExploreNewDate(long when)
Time of the last explore run.
(package private) static boolean
shouldAcceptLeaseSet(LeaseSet stored, LeaseSet incoming, long now)
Determine whether an incoming LeaseSet may replace the currently stored copy.
(package private) static boolean
shouldFailLocalWithoutRemoteSearch(boolean isClientDb, boolean isLocalDest)
Whether a client sub-NetDb local miss for a destination this router hosts must fail immediately instead of starting a network search.
(package private) static boolean
shouldFallbackLocalLookupToMain(boolean isClientDb, boolean isLocalDest, boolean foundLocally)
Whether a client sub-NetDb local miss should be re-checked in the main NetDb.
(package private) void
stopPublishing(Hash target)
Stops publishing the given LeaseSet.
LeaseSet
store(Hash key, LeaseSet leaseSet)
Store the LeaseSet without persisting it to disk.
LeaseSet
store(Hash key, LeaseSet leaseSet, boolean force)
Store the leaseSet.
RouterInfo
store(Hash key, RouterInfo routerInfo)
Store the routerInfo.
(package private) RouterInfo
store(Hash key, RouterInfo routerInfo, boolean persist)
Store the routerInfo.
(package private) static String
stripStoreWrapper(String message)
Strip the "Invalid NetDbStore attempt" wrapper from a store rejection message, keeping the capability flags and the Router [id] the console renders as a link.
(package private) static boolean
tooManyIntroducers(Collection<RouterAddress> addrs)
Whether any single transport address advertises more introducers than the SSU2 spec allows.
String
toString()
Name this netdb for use in log messages.
void
unpublish(LeaseSet localLeaseSet)
Unpublish a LeaseSet from the network database.
String
validate(Hash key, LeaseSet leaseSet)
Validates whether the given LeaseSet is acceptable as valid and current based on current known parameters.
(package private) String
validate(RouterInfo routerInfo)
Determine whether this routerInfo will be accepted as valid and current given what we know now.
Methods inherited from class NetworkDatabaseFacade
store
Modifier and Type
Method
Description
DatabaseEntry
store(Hash key, DatabaseEntry entry)
Store a DatabaseEntry in the network database.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface Service
restart
Modifier and Type
Method
Description
void
restart()
Perform a soft restart.

Field Details
- CAPABILITY_FLOODFILL
  public static final char CAPABILITY_FLOODFILL
  Floodfill capability flag.
  See Also:
  Constant Field Values
- CAPABILITY_UNREACHABLE
  public static final char CAPABILITY_UNREACHABLE
  Unreachable 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_BW32
  public static final char CAPABILITY_BW32
  Bandwidth 32 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_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_BW512
  public static final char CAPABILITY_BW512
  Bandwidth 512 Kbps capability flag.
  See Also:
  Constant Field Values
- CAPABILITY_BW_UNLIMITED
  public static final char CAPABILITY_BW_UNLIMITED
  Unlimited bandwidth 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_NO_TUNNELS
  public static final char CAPABILITY_NO_TUNNELS
  No tunnels capability flag.
  See Also:
  Constant Field Values
- _activeFloodQueries
  private final ConcurrentHashMap<Hash, FloodSearchJob> _activeFloodQueries
  Active flood queries keyed by search hash.
- _floodfillEnabled
  private volatile boolean _floodfillEnabled
  Whether this router is currently floodfill-enabled.
- _verifiesInProgress
  private final Set<Hash> _verifiesInProgress
  Hashes whose verification is in progress.
- _floodThrottler
  private FloodThrottler _floodThrottler
  Throttles excessive flood operations.
- _lookupThrottler
  private LookupThrottler _lookupThrottler
  Throttles excessive lookup operations.
- _lookupBanner
  private LookupBanHammer _lookupBanner
  Ban hammer for abusive lookup peers.
- _ffMonitor
  private final Job _ffMonitor
  Floodfill monitor job for capability management.
- _probeStalePeerJob
  private final ProbeStalePeerJob _probeStalePeerJob
  Job to probe stale floodfill peers.
- _contactRefreshJob
  private final ContactDrivenRefreshJob _contactRefreshJob
  Job to refresh RouterInfo on contact.
- _introducerLookupJob
  private final IntroducerLookupJob _introducerLookupJob
  Job to prefetch introducer RIs of unreachable peers.
- _searchTimeouts
  private final ConcurrentHashMap<Long, List<FloodfillNetworkDatabaseFacade.TimeoutEntry>> _searchTimeouts
  Batched search timeout entries keyed by bucket.
- _timeoutProcessor
  private final FloodfillNetworkDatabaseFacade.BatchedSearchTimeoutProcessor _timeoutProcessor
  Periodic processor for elapsed search timeouts.
- 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 Raised to 10: wider RI/LS propagation improves lookup success and reduces dead-zone risk from date-based routing key rotation. Bandwidth cost is negligible (~2KB per store × 10 FFs).
  See Also:
  Constant Field Values
- FLOOD_PRIORITY
  private static final int FLOOD_PRIORITY
  Priority for flood outbound messages.
  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
- FLOOD_TIMEOUT
  private static final int FLOOD_TIMEOUT
  Timeout for individual flood messages.
  See Also:
  Constant Field Values
- 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
- NEXT_RKEY_LS_ADVANCE_TIME
  private static final long NEXT_RKEY_LS_ADVANCE_TIME
  Advance time before midnight to flood to next routing key for LeaseSet.
  See Also:
  Constant Field Values
- NEXT_FLOOD_QTY
  private static final int NEXT_FLOOD_QTY
  Number of additional peers to flood near routing key rollover.
  See Also:
  Constant Field Values
- MAX_LAG_BEFORE_SKIP_SEARCH
  private static final int MAX_LAG_BEFORE_SKIP_SEARCH
  Max job queue lag before skipping exploratory searches.
- PUBLISH_JOB_DELAY
  private static final int PUBLISH_JOB_DELAY
  Delay before publishing RouterInfo at startup.
  See Also:
  Constant Field Values
- _lastClientSubDbWarn
  private static volatile long _lastClientSubDbWarn
  Rate-limit Client subDb exploratory drop WARN (10s). @since 0.9.71+.
- CLIENT_SUBDB_WARN_INTERVAL
  private static final long CLIENT_SUBDB_WARN_INTERVAL
  Interval between the client subDB warnings.
  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
- 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
- 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
- INITIAL_CONCURRENT
  private static final int INITIAL_CONCURRENT
  Initial number of concurrent floodfill peers for store operations.
  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.
- MAX_DB_BEFORE_SKIPPING_SEARCH
  private static final int MAX_DB_BEFORE_SKIPPING_SEARCH
  Maximum database size before skipping exploratory searches.
Constructor Details
- FloodfillNetworkDatabaseFacade
  public FloodfillNetworkDatabaseFacade(RouterContext context)
  Main DB.
  Parameters:
  context - the router context
- FloodfillNetworkDatabaseFacade
  public FloodfillNetworkDatabaseFacade(RouterContext context, Hash dbid)
  Sub DBs.
  Parameters:
  context - the router context
  dbid - null for main DB
Method Details
- startup
  public void startup()
  Start monitor jobs, throttle, and optional router refresh.
  Specified by:
  startup in interface Service
  Overrides:
  startup in class KademliaNetworkDatabaseFacade
- createHandlers
  protected void createHandlers()
  Register message handlers for DatabaseLookup and DatabaseStore.
  Overrides:
  createHandlers in class KademliaNetworkDatabaseFacade
- 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 target key whose search timeout is being registered
  search - the search term
  timeoutMs - the absolute time when the timeout expires
- processElapsedTimeouts
  public void processElapsedTimeouts()
  Process all elapsed search timeouts. Called by BatchedSearchTimeoutJob.
- startTimeoutProcessor
  public void startTimeoutProcessor()
  Start the batched timeout processor. Called from startup().
- 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
- 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
- shouldFloodOnStore
  static boolean shouldFloodOnStore(boolean floodfillEnabled, DatabaseEntry ds)
  Whether sendStore should wide-flood the entry via flood(DatabaseEntry) when this router participates in floodfill.
  Floodfill participants wide-flood both RouterInfos (existing) and LeaseSets so published LSs reach the routing-key-closest peers that lookups query, not only the few peers chosen for the reply-based store job. Narrow store-only delivery leaves keys missing on other floodfills (verify FailNoKey).
  Parameters:
  floodfillEnabled - whether this router is a floodfill participant
  ds - the entry being stored, may be null
  Returns:
  true if flood() should be invoked for this entry
- storeJobCount
  static int storeJobCount(boolean floodfillEnabled, DatabaseEntry ds, int selectedCount)
  How many FloodfillStoreJob instances sendStore should schedule alongside (or instead of) a wide flood.
  Floodfill + RouterInfo: 0 — wide flood only (existing; no reply-based job). Floodfill + LeaseSet: 1 — wide flood covers propagation; this job supplies reply-based success/failure callbacks and verify accounting. Otherwise: selectedCount staggered multi-peer jobs (non-floodfill path).
  Parameters:
  floodfillEnabled - whether this router is a floodfill participant
  ds - the entry being stored, may be null
  selectedCount - peers chosen by selectFloodfillParticipants
  Returns:
  number of FloodfillStoreJob instances to schedule; never negative
- 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
  ds - the database entry
  onSuccess - may be null; called on reply-based store success (not used for wide-flood-only RI path)
  onFailure - may be null; called when no floodfill peers are available or reply-based store fails
  sendTimeout - timeout in ms for the reply-based FloodfillStoreJob path
  toIgnore - may be null, if non-null, all attempted and skipped targets will be added as of 0.9.53; passed through to FloodfillStoreJob (unused for wide-flood-only RI path)
- selectFloodfillParticipants
  private Set<Hash> selectFloodfillParticipants(Set<Hash> toIgnore, int concurrent)
  Selects a set of floodfill participant peers to which data should be sent: random selection among the filtered floodfill participants, preferring peers not queried in the last 60s to spread load, with a fallback top-up so store operations never starve.
  Parameters:
  toIgnore - the set of peer hashes to exclude from selection, may be null
  concurrent - the maximum number of peers to select
  Returns:
  a set of floodfill participant Hashes; never null but possibly empty if no suitable peers found
- selectStoreParticipants
  static Set<Hash> selectStoreParticipants(List<Hash> shuffled, int concurrent, Set<Hash> recentlyQueried)
  Select up to concurrent store participants, preferring peers not queried in the last 60s to spread load, with a fallback top-up so store operations never starve.
  Parameters:
  shuffled - the shuffled candidate peers (may be empty)
  concurrent - the maximum number of peers to select
  recentlyQueried - hashes of peers queried within the cooldown period
  Returns:
  the selected peers; never null, possibly empty
- shouldThrottleFlood
  boolean shouldThrottleFlood(Hash key)
  Increments and tests.
  Parameters:
  key - the key being flooded, tested against the per-key flood allowance
  Returns:
  true if the flood should be throttled for this key
- 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
- shouldThrottleLookup
  boolean shouldThrottleLookup(Hash from, TunnelId id)
  Increments and tests.
  Parameters:
  from - the peer hash that sent the lookup
  id - the tunnel ID the lookup arrived on
  Returns:
  true if the lookup should be throttled for this peer/tunnel
- floodConditional
  public boolean floodConditional(DatabaseEntry ds)
  If we are floodfill AND the key is not throttled, flood it, otherwise don't.
  Parameters:
  ds - the entry to flood, which must be a LeaseSet for the store to accept it
  Returns:
  if we did
- 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.
  Parameters:
  ds - the entry to store and flood to the closest floodfill participants
- shouldFloodTo
  private boolean shouldFloodTo(Hash key, int type, SigType lsSigType, Hash peer, RouterInfo target)
  Determines if we should flood the database store to a peer.
  Parameters:
  key - the database entry hash
  type - database store type
  lsSigType - may be null
  peer - the target peer hash
  target - the peer's RouterInfo, may be null
  Returns:
  true if the store should be flooded to this peer
- 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.
  Parameters:
  yes - true to become floodfill, false to stop
- setFloodfillEnabledFromMonitor
  void setFloodfillEnabledFromMonitor(boolean yes)
  Package private, called from FloodfillMonitorJob. This does not wake up the floodfill monitor.
  Parameters:
  yes - true to become floodfill, false to stop; true also creates the throttler and HFDSMJ stats
- floodfillEnabled
  public boolean floodfillEnabled()
  Whether this router is currently acting as a floodfill.
  Overrides:
  floodfillEnabled in class NetworkDatabaseFacade
  Returns:
  true if enabled, as set from the config or the floodfill monitor
- isFloodfill
  public static boolean isFloodfill(RouterInfo peer)
  Checks if a RouterInfo has floodfill capability.
  Parameters:
  peer - may be null, returns false if null
  Returns:
  true if the RouterInfo advertises the 'f' floodfill capability
- getKnownRouterData
  public List<RouterInfo> getKnownRouterData()
  Return all RouterInfo entries from the local data store.
  Returns:
  list of known RouterInfo objects, never null
- 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).
  Specified by:
  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:
  always null; the caller is notified through onFindJob or onFailedLookupJob
- 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. Every path either schedules a search or queues onFailedLookupJob — never returns without notifying the caller.
  Specified by:
  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
  fromLocalDest - use these tunnels for the lookup, or null for exploratory
  Returns:
  null always
- getMainFacade
  private FloodfillNetworkDatabaseFacade getMainFacade()
  Main (router) NetDb facade, or null if not yet available. Client sub-DBs delegate exploratory searches here so callbacks always fire.
  Returns:
  the main FloodfillNetworkDatabaseFacade, or null
- failSearchCallbacks
  private void failSearchCallbacks(Job onFindJob, Job onFailedLookupJob)
  Queue failure callbacks so a search that cannot start never leaves the caller waiting for a timeout that will never be scheduled. Success and failure jobs may both be non-null (lookupDestination); on failure both roles collapse to the finished/failed job.
  Parameters:
  onFindJob - may be null
  onFailedLookupJob - may be null
- complete
  void complete(Hash key)
  Must be called by the search job queued by search() on success or failure.
  Parameters:
  key - the key whose pending search is being retired
- 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 hash we heard from or about
- 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.
  Parameters:
  peer - the stale peer's router hash, which keys the deduplication map
  ri - the peer's RouterInfo, used by the job to verify the entry
- 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
- isVerifyInProgress
  boolean isVerifyInProgress(Hash h)
  Checks if verification is in progress for the specified hash.
  Parameters:
  h - the key whose verifying floodfill is being tested
  Returns:
  true if a FloodfillVerifyStoreJob for this key is still running
- verifyStarted
  void verifyStarted(Hash h)
  Marks verification as started for the specified hash.
  Parameters:
  h - the key being verified by a FloodfillVerifyStoreJob
- verifyFinished
  void verifyFinished(Hash h)
  Marks verification as finished for the specified hash.
  Parameters:
  h - the key whose verifying floodfill has just completed
- 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 router hash to drop after the lookup failure
  info - the router info
- getTunnelName
  public String getTunnelName(Destination d)
  Look up the tunnel pool nickname for a destination.
  Parameters:
  d - the destination whose inbound, else outbound, pool nickname is wanted
  Returns:
  the configured nickname, or the empty string if neither pool has one

Nested Class Summary

Field Summary

Fields inherited from class KademliaNetworkDatabaseFacade

Constructor Summary

Method Summary

Methods inherited from class KademliaNetworkDatabaseFacade

Methods inherited from class NetworkDatabaseFacade

Methods inherited from class Object

Methods inherited from interface Service

Field Details

CAPABILITY_FLOODFILL

CAPABILITY_UNREACHABLE

CAPABILITY_BW12

CAPABILITY_BW32

CAPABILITY_BW64

CAPABILITY_BW128

CAPABILITY_BW256

CAPABILITY_BW512

CAPABILITY_BW_UNLIMITED

CAPABILITY_CONGESTION_MODERATE

CAPABILITY_CONGESTION_SEVERE

CAPABILITY_NO_TUNNELS

_activeFloodQueries

_floodfillEnabled

_verifiesInProgress

_floodThrottler

_lookupThrottler

_lookupBanner

_ffMonitor

_probeStalePeerJob

_contactRefreshJob

_introducerLookupJob

_searchTimeouts

_timeoutProcessor

MAX_TO_FLOOD

FLOOD_PRIORITY

MAX_RI_AGE_BEFORE_REFRESH_MS

FLOOD_TIMEOUT

NEXT_RKEY_RI_ADVANCE_TIME

NEXT_RKEY_LS_ADVANCE_TIME

NEXT_FLOOD_QTY

MAX_LAG_BEFORE_SKIP_SEARCH

PUBLISH_JOB_DELAY

_lastClientSubDbWarn

CLIENT_SUBDB_WARN_INTERVAL

PROP_FLOODFILL_PARTICIPANT

PROP_FLOODFILL_AT_RESTART

PUBLISH_TIMEOUT

INITIAL_CONCURRENT

MIN_ACTIVE_PEERS

MAX_DB_BEFORE_SKIPPING_SEARCH

Constructor Details

FloodfillNetworkDatabaseFacade

FloodfillNetworkDatabaseFacade

Method Details

startup

createHandlers

registerSearchTimeout

processElapsedTimeouts

startTimeoutProcessor

shutdown

publish

shouldFloodOnStore

storeJobCount

sendStore

selectFloodfillParticipants

selectStoreParticipants

shouldThrottleFlood

shouldBanLookup

shouldThrottleLookup

floodConditional

flood

shouldFloodTo

setFloodfillEnabled

setFloodfillEnabledFromMonitor

floodfillEnabled

isFloodfill

getKnownRouterData

search

search