Class KademliaNetworkDatabaseFacade
java.lang.Object
net.i2p.router.NetworkDatabaseFacade
net.i2p.router.networkdb.kademlia.KademliaNetworkDatabaseFacade
- All Implemented Interfaces:
Service
- Direct Known Subclasses:
FloodfillNetworkDatabaseFacade
public abstract class KademliaNetworkDatabaseFacade extends NetworkDatabaseFacade
Kademlia based version of the network database.
Never instantiated directly; see FloodfillNetworkDatabaseFacade.
-
Field Summary
Fields Modifier and Type Field Description protected RouterContext_contextprotected Log_logprotected int_networkIDprotected PeerSelector_peerSelectorstatic StringDEFAULT_DB_DIRstatic longDONT_FAIL_PERIODFor 10 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 intMAX_EXPLORE_QUEUEMaximum number of peers to place in the queue to exploreprotected static intMIN_REMAINING_ROUTERSIf 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 intMIN_RESEEDReseed if below this.(package private) static StringPROP_BUCKET_SIZEstatic StringPROP_DB_DIR(package private) static StringPROP_EXPLORE_QUEUE(package private) static StringPROP_KAD_B(package private) static StringPROP_MIN_ROUTER_VERSION(package private) static StringPROP_ROUTER_INFO_EXPIRATION_ADJUSTED(package private) static StringPROP_VALIDATE_ROUTERS_AFTERprotected static longPUBLISH_JOB_DELAYThis needs to be long enough to give us time to start up, but less than 20m (when we start accepting tunnels and could be a IBGW) Actually no, we need this soon if we are a new router or other routers have forgotten about us, else we can't build IB exploratory tunnels. -
Constructor Summary
Constructors Constructor Description KademliaNetworkDatabaseFacade(RouterContext context) -
Method Summary
Modifier and Type Method Description protected voidcreateHandlers()unused, see overrideprotected abstract PeerSelectorcreatePeerSelector()(package private) voiddropAfterLookupFailed(Hash peer)Final remove for a router info.voidfail(Hash dbEntry)Final remove for a leaseset.(package private) voidfailPermanently(Destination dest)Negative cache until restartSet<Hash>findNearestRouters(Hash key, int maxNumRouters, Set<Hash> peersToIgnore)Get the routers closest to that key in response to a remote lookup Only used by ../HDLMJ Set MAY INCLUDE our own router - add to peersToIgnore if you don't wantSet<Hash>getAllRouters()get the hashes for all known routersList<BlindData>getBlindData()For console ConfigKeyringHelperBlindDatagetBlindData(SigningPublicKey spk)(package private) DataStoregetDataStore()(package private) StringgetDbDir()Set<Hash>getExploreKeys()(package private) KBucketSet<Hash>getKBuckets()protected intgetKBucketSetSize()This is fast and doesn't use synchronization, but it includes both routerinfos and leasesets.intgetKnownLeaseSets()This is only used by StatisticsManager to publish the count if we are floodfill.intgetKnownRouters()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) longgetLastExploreNewDate()longgetLastRouterInfoPublishTime()The last time we successfully published our RI.Set<LeaseSet>getLeases()public for NetDbRenderer in routerconsolePeerSelectorgetPeerSelector()intgetPeerTimeout(Hash peer)todo: does this need more tuning?Set<RouterInfo>getRouters()public for NetDbRenderer in routerconsolebooleanisInitialized()(package private) booleanisNegativeCached(Hash key)Is the key in the negative lookup cache?booleanisNegativeCachedForever(Hash key)Is it permanently negative cached?protected voidlookupBeforeDropping(Hash peer, RouterInfo info)don't use directly - see F.N.D.F.voidlookupDestination(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.DestinationlookupDestinationLocally(Hash key)Lookup locally in netDB and in badDest cache Succeeds even if LS validation fails due to unsupported sig type, expired, etc.(package private) voidlookupFailed(Hash key)Increment in the negative lookup cachevoidlookupLeaseSet(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs)Lookup using exploratory tunnels.voidlookupLeaseSet(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, Hash fromLocalDest)Lookup using the client's tunnels Use lookupDestination() if you don't need the LS or don't need it validated.LeaseSetlookupLeaseSetLocally(Hash key)Use lookupDestination() if you don't need the LS or don't need it validated.voidlookupLeaseSetRemotely(Hash key, Hash fromLocalDest)Unconditionally lookup using the client's tunnels.voidlookupLeaseSetRemotely(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, Hash fromLocalDest)Unconditionally lookup using the client's tunnels.DatabaseEntrylookupLocally(Hash key)DatabaseEntrylookupLocallyWithoutValidation(Hash key)Not for use without validationvoidlookupRouterInfo(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs)RouterInfolookupRouterInfoLocally(Hash key)This will return immediately with the result or null.voidpublish(LeaseSet localLeaseSet)voidpublish(RouterInfo localRouterInfo)Stores to local db only.voidqueueForExploration(Collection<Hash> keys)booleanremoveBlindData(SigningPublicKey spk)For console ConfigKeyringHelpervoidremoveFromExploreKeys(Collection<Hash> toRemove)voidrenderStatusHTML(Writer out)Debug info, HTML formattedvoidrescan()ReseedCheckerreseedChecker()voidrestart()Perform a soft restart.(package private) voidrouterInfoPublishSuccessful()Set the last time we successfully published our RI.voidroutingKeyChanged()Notify the netDB that the routing key changed at midnight UTC(package private) SearchJobsearch(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, boolean isLease)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) Unused - called only by FNDF.searchFull() from FloodSearchJob which is overridden - don't use this.(package private) SearchJobsearch(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, boolean isLease, Hash fromLocalDest)Unused - see FNDF(package private) voidsearchComplete(Hash key)The search for the given key is no longer activeabstract voidsendStore(Hash key, DatabaseEntry ds, Job onSuccess, Job onFailure, long sendTimeout, Set<Hash> toIgnore)unused (overridden in FNDF)voidsetBlindData(BlindData bd)(package private) voidsetLastExploreNewDate(long when)voidshutdown()Instruct the service that the router is shutting down and that it should do whatever is necessary to go down gracefully.voidstartup()Instruct the service that it should start normal operation.(package private) voidstopPublishing(Hash target)LeaseSetstore(Hash key, LeaseSet leaseSet)Store the leaseSet.RouterInfostore(Hash key, RouterInfo routerInfo)Store the routerInfo.(package private) RouterInfostore(Hash key, RouterInfo routerInfo, boolean persist)Store the routerInfo.voidunpublish(LeaseSet localLeaseSet)(package private) Stringvalidate(RouterInfo routerInfo)Determine whether this routerInfo will be accepted as valid and current given what we know now.
-
Field Details
-
_log
-
_peerSelector
-
_context
-
_networkID
protected final int _networkID -
PROP_MIN_ROUTER_VERSION
- See Also:
- Constant Field Values
-
DONT_FAIL_PERIOD
public static long DONT_FAIL_PERIODFor 10 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 -
PROP_DB_DIR
- See Also:
- Constant Field Values
-
DEFAULT_DB_DIR
- See Also:
- Constant Field Values
-
MIN_RESEED
static final int MIN_RESEEDReseed if below this.- Since:
- 0.9.4
- See Also:
- Constant Field Values
-
MIN_REMAINING_ROUTERS
protected static final int MIN_REMAINING_ROUTERSIf we have less than this many routers left, don't drop any more, even if they're failing or doing bad stuff. As of 0.9.4, we make this LOWER than the min for reseeding, so a reseed will be forced if necessary.- See Also:
- Constant Field Values
-
PROP_ROUTER_INFO_EXPIRATION_ADJUSTED
- See Also:
- Constant Field Values
-
PROP_VALIDATE_ROUTERS_AFTER
- See Also:
- Constant Field Values
-
PUBLISH_JOB_DELAY
protected static final long PUBLISH_JOB_DELAYThis needs to be long enough to give us time to start up, but less than 20m (when we start accepting tunnels and could be a IBGW) Actually no, we need this soon if we are a new router or other routers have forgotten about us, else we can't build IB exploratory tunnels. Unused.- See Also:
- Constant Field Values
-
MAX_EXPLORE_QUEUE
static final int MAX_EXPLORE_QUEUEMaximum number of peers to place in the queue to explore- See Also:
- Constant Field Values
-
PROP_EXPLORE_QUEUE
- See Also:
- Constant Field Values
-
PROP_BUCKET_SIZE
- See Also:
- Constant Field Values
-
PROP_KAD_B
- See Also:
- Constant Field Values
-
-
Constructor Details
-
Method Details
-
searchComplete
The search for the given key is no longer active -
isInitialized
public boolean isInitialized()- Overrides:
isInitializedin classNetworkDatabaseFacade
-
createPeerSelector
-
getPeerSelector
-
reseedChecker
- Overrides:
reseedCheckerin classNetworkDatabaseFacade- Since:
- 0.9
-
getKBuckets
KBucketSet<Hash> getKBuckets() -
getDataStore
DataStore getDataStore() -
getLastExploreNewDate
long getLastExploreNewDate() -
setLastExploreNewDate
void setLastExploreNewDate(long when) -
getExploreKeys
- Returns:
- unmodifiable set
-
removeFromExploreKeys
-
queueForExploration
-
shutdown
public void shutdown()Description copied from interface:ServiceInstruct the service that the router is shutting down and that it should do whatever is necessary to go down gracefully. It should not depend on other components at this point. This call DOES block. -
restart
public void restart()Description copied from interface:ServicePerform a soft restart. -
rescan
public void rescan()- Overrides:
rescanin classNetworkDatabaseFacade
-
getDbDir
String getDbDir() -
startup
public void startup()Description copied from interface:ServiceInstruct the service that it should start normal operation. This call DOES block until the service is ready. -
createHandlers
protected void createHandlers()unused, see override -
findNearestRouters
Get the routers closest to that key in response to a remote lookup Only used by ../HDLMJ Set MAY INCLUDE our own router - add to peersToIgnore if you don't want- Specified by:
findNearestRoutersin classNetworkDatabaseFacade- Parameters:
key- the real key, NOT the routing keypeersToIgnore- can be nullmaxNumRouters- The maximum number of routers to return
-
getAllRouters
get the hashes for all known routers- Specified by:
getAllRoutersin classNetworkDatabaseFacade
-
getKnownRouters
public 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. But now that is probably not what you want. Just return the count in the data store.- Overrides:
getKnownRoutersin classNetworkDatabaseFacade
-
getKnownLeaseSets
public int getKnownLeaseSets()This is only used by StatisticsManager to publish the count if we are floodfill. So to hide a clue that a popular eepsite is hosted on a floodfill router, only count leasesets that are "received as published", as of 0.7.14- Overrides:
getKnownLeaseSetsin classNetworkDatabaseFacade
-
getKBucketSetSize
protected int getKBucketSetSize()This is fast and doesn't use synchronization, but it includes both routerinfos and leasesets. Use it to avoid deadlocks. No - not true - the KBS contains RIs only. -
getBlindData
- Overrides:
getBlindDatain classNetworkDatabaseFacade- Parameters:
spk- unblinded key- Returns:
- BlindData or null
- Since:
- 0.9.40
-
setBlindData
- Overrides:
setBlindDatain classNetworkDatabaseFacade- Parameters:
bd- new BlindData to put in the cache- Since:
- 0.9.40
-
getBlindData
For console ConfigKeyringHelper- Overrides:
getBlindDatain classNetworkDatabaseFacade- Since:
- 0.9.41
-
removeBlindData
For console ConfigKeyringHelper- Overrides:
removeBlindDatain classNetworkDatabaseFacade- Parameters:
spk- the unblinded public key- Returns:
- true if removed
- Since:
- 0.9.41
-
routingKeyChanged
public void routingKeyChanged()Notify the netDB that the routing key changed at midnight UTC- Overrides:
routingKeyChangedin classNetworkDatabaseFacade- Since:
- 0.9.50
-
lookupLocally
- Specified by:
lookupLocallyin classNetworkDatabaseFacade- Returns:
- RouterInfo, LeaseSet, or null, validated
- Since:
- 0.8.3
-
lookupLocallyWithoutValidation
Not for use without validation- Specified by:
lookupLocallyWithoutValidationin classNetworkDatabaseFacade- Returns:
- RouterInfo, LeaseSet, or null, NOT validated
- Since:
- 0.9.9, public since 0.9.38
-
lookupLeaseSet
Lookup using exploratory tunnels. Use lookupDestination() if you don't need the LS or don't need it validated.- Specified by:
lookupLeaseSetin classNetworkDatabaseFacade
-
lookupLeaseSet
public void lookupLeaseSet(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, Hash fromLocalDest)Lookup using the client's tunnels Use lookupDestination() if you don't need the LS or don't need it validated.- Specified by:
lookupLeaseSetin classNetworkDatabaseFacade- Parameters:
fromLocalDest- use these tunnels for the lookup, or null for exploratory- Since:
- 0.9.10
-
lookupLeaseSetRemotely
Unconditionally lookup using the client's tunnels. No success or failed jobs, no local lookup, no checks. Use this to refresh a leaseset before expiration.- Specified by:
lookupLeaseSetRemotelyin classNetworkDatabaseFacade- Parameters:
fromLocalDest- use these tunnels for the lookup, or null for exploratory- Since:
- 0.9.25
-
lookupLeaseSetRemotely
public void lookupLeaseSetRemotely(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, Hash fromLocalDest)Unconditionally lookup using the client's tunnels.- Specified by:
lookupLeaseSetRemotelyin classNetworkDatabaseFacade- Parameters:
fromLocalDest- use these tunnels for the lookup, or null for exploratoryonFindJob- may be nullonFailedLookupJob- may be null- Since:
- 0.9.47
-
lookupLeaseSetLocally
Use lookupDestination() if you don't need the LS or don't need it validated.- Specified by:
lookupLeaseSetLocallyin classNetworkDatabaseFacade
-
lookupDestination
Lookup using the client's tunnels Succeeds even if LS validation and store fails due to unsupported sig type, expired, etc. Note that there are not separate success and fail jobs. Caller must call lookupDestinationLocally() in the job to determine success.- Specified by:
lookupDestinationin classNetworkDatabaseFacade- Parameters:
onFinishedJob- non-nullfromLocalDest- use these tunnels for the lookup, or null for exploratory- Since:
- 0.9.16
-
lookupDestinationLocally
Lookup locally in netDB and in badDest cache Succeeds even if LS validation fails due to unsupported sig type, expired, etc.- Specified by:
lookupDestinationLocallyin classNetworkDatabaseFacade- Since:
- 0.9.16
-
lookupRouterInfo
- Specified by:
lookupRouterInfoin classNetworkDatabaseFacade
-
lookupRouterInfoLocally
This will return immediately with the result or null. However, this may still fire off a lookup if the RI is present but expired (and will return null). This may result in deadlocks. For true local only, use lookupLocallyWithoutValidation()- Specified by:
lookupRouterInfoLocallyin classNetworkDatabaseFacade
-
publish
- Specified by:
publishin classNetworkDatabaseFacade- Throws:
IllegalArgumentException- if the leaseSet is not valid
-
stopPublishing
-
publish
Stores to local db only. Overridden in FNDF to actually send to the floodfills.- Specified by:
publishin classNetworkDatabaseFacade- Throws:
IllegalArgumentException- if the local router info is invalid
-
routerInfoPublishSuccessful
void routerInfoPublishSuccessful()Set the last time we successfully published our RI.- Since:
- 0.9.9
-
getLastRouterInfoPublishTime
public long getLastRouterInfoPublishTime()The last time we successfully published our RI.- Overrides:
getLastRouterInfoPublishTimein classNetworkDatabaseFacade- Since:
- 0.9.9
-
store
Store the leaseSet. If the store fails due to unsupported crypto, it will negative cache the hash until restart.- Specified by:
storein classNetworkDatabaseFacade- Returns:
- previous entry or null
- Throws:
IllegalArgumentException- if the leaseSet is not validUnsupportedCryptoException- if that's why it failed.
-
validate
Determine whether this routerInfo will be accepted as valid and current given what we know now. Call this before each use, to check expiration- Returns:
- reason why the entry is not valid, or null if it is valid
- Throws:
IllegalArgumentException- Since:
- 0.9.7
-
store
Store the routerInfo. If the store fails due to unsupported crypto, it will banlist the router hash until restart and then throw UnsupportedCrytpoException.- Specified by:
storein classNetworkDatabaseFacade- Returns:
- previous entry or null
- Throws:
IllegalArgumentException- if the routerInfo is not validUnsupportedCryptoException- if that's why it failed.
-
store
Store the routerInfo. If the store fails due to unsupported crypto, it will banlist the router hash until restart and then throw UnsupportedCrytpoException.- Returns:
- previous entry or null
- Throws:
IllegalArgumentException- if the routerInfo is not validUnsupportedCryptoException- if that's why it failed.
-
fail
Final remove for a leaseset. For a router info, will look up in the network before dropping.- Specified by:
failin classNetworkDatabaseFacade
-
lookupBeforeDropping
don't use directly - see F.N.D.F. override -
dropAfterLookupFailed
Final remove for a router info. Do NOT use for leasesets. -
unpublish
- Specified by:
unpublishin classNetworkDatabaseFacade
-
search
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) Unused - called only by FNDF.searchFull() from FloodSearchJob which is overridden - don't use this.- Throws:
UnsupportedOperationException- always
-
search
SearchJob search(Hash key, Job onFindJob, Job onFailedLookupJob, long timeoutMs, boolean isLease, Hash fromLocalDest)Unused - see FNDF- Throws:
UnsupportedOperationException- always- Since:
- 0.9.10
-
getLeases
public for NetDbRenderer in routerconsole- Overrides:
getLeasesin classNetworkDatabaseFacade
-
getRouters
public for NetDbRenderer in routerconsole- Overrides:
getRoutersin classNetworkDatabaseFacade
-
getPeerTimeout
todo: does this need more tuning? -
sendStore
public abstract void sendStore(Hash key, DatabaseEntry ds, Job onSuccess, Job onFailure, long sendTimeout, Set<Hash> toIgnore)unused (overridden in FNDF) -
lookupFailed
Increment in the negative lookup cache- Parameters:
key- for Destinations or RouterIdentities- Since:
- 0.9.4 moved from FNDF to KNDF in 0.9.16
-
isNegativeCached
Is the key in the negative lookup cache?- Parameters:
key- for Destinations or RouterIdentities- Since:
- 0.9.4 moved from FNDF to KNDF in 0.9.16
-
failPermanently
Negative cache until restart- Since:
- 0.9.16
-
isNegativeCachedForever
Is it permanently negative cached?- Overrides:
isNegativeCachedForeverin classNetworkDatabaseFacade- Parameters:
key- only for Destinations; for RouterIdentities, see Banlist- Since:
- 0.9.16
-
renderStatusHTML
Debug info, HTML formatted- Specified by:
renderStatusHTMLin interfaceService- Overrides:
renderStatusHTMLin classNetworkDatabaseFacade- Throws:
IOException- Since:
- 0.9.10
-