zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

limit max explore queue

Browse Source
This commit is contained in:
zzz
2011-09-20 03:28:16 +00:00
parent a139d915bd
commit 8a78de2b8c
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
router/java/src/net/i2p/router/networkdb/kademlia/KademliaNetworkDatabaseFacade.java
View File

@@ -131,6 +131,8 @@ public class KademliaNetworkDatabaseFacade extends NetworkDatabaseFacade {
but less than 20m (when we start accepting tunnels and could be a IBGW) */
protected final static long PUBLISH_JOB_DELAY = 5*60*1000l;
private static final int MAX_EXPLORE_QUEUE = 128;
public KademliaNetworkDatabaseFacade(RouterContext context) {
_context = context;
_log = _context.logManager().getLog(getClass());
@@ -184,7 +186,9 @@ public class KademliaNetworkDatabaseFacade extends NetworkDatabaseFacade {
public void queueForExploration(Set<Hash> keys) {
if (!_initialized) return;
_exploreKeys.addAll(keys);
for (Iterator<Hash> iter = keys.iterator(); iter.hasNext() && _exploreKeys.size() < MAX_EXPLORE_QUEUE; ) {
_exploreKeys.add(iter.next());
}
_context.statManager().addRateData("netDb.exploreKeySet", _exploreKeys.size(), 0);
}