From 7175b1cdb97d2fe436c9402e8560d13c977ffba4 Mon Sep 17 00:00:00 2001 From: zab2 Date: Sat, 7 Nov 2015 02:22:17 +0000 Subject: [PATCH] Make the search limit configurable --- .../net/i2p/router/networkdb/kademlia/IterativeSearchJob.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/IterativeSearchJob.java b/router/java/src/net/i2p/router/networkdb/kademlia/IterativeSearchJob.java index 3bd24f667..d9bbf2889 100644 --- a/router/java/src/net/i2p/router/networkdb/kademlia/IterativeSearchJob.java +++ b/router/java/src/net/i2p/router/networkdb/kademlia/IterativeSearchJob.java @@ -125,8 +125,9 @@ class IterativeSearchJob extends FloodSearchJob { _expiration = _timeoutMs + ctx.clock().now(); _rkey = ctx.routingKeyGenerator().getRoutingKey(key); _toTry = new TreeSet(new XORComparator(_rkey)); - _totalSearchLimit = (facade.floodfillEnabled() && ctx.router().getUptime() > 30*60*1000) ? + int totalSearchLimit = (facade.floodfillEnabled() && ctx.router().getUptime() > 30*60*1000) ? TOTAL_SEARCH_LIMIT_WHEN_FF : TOTAL_SEARCH_LIMIT; + _totalSearchLimit = ctx.getProperty("netdb.searchLimit", totalSearchLimit); _unheardFrom = new HashSet(CONCURRENT_SEARCHES); _failedPeers = new HashSet(_totalSearchLimit); _sentTime = new ConcurrentHashMap(_totalSearchLimit);