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

lookup stat tweak

Browse Source
This commit is contained in:
zzz
2013-06-21 15:13:16 +00:00
parent 5bd028bff5
commit 1444f1239f
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
router/java/src/net/i2p/router/networkdb/kademlia/FloodfillNetworkDatabaseFacade.java
View File

@ -50,7 +50,8 @@ public class FloodfillNetworkDatabaseFacade extends KademliaNetworkDatabaseFacad
_context.statManager().createRequiredRateStat("netDb.successTime", "Time for successful lookup (ms)", "NetworkDatabase", new long[] { 60*60*1000l, 24*60*60*1000l });
_context.statManager().createRateStat("netDb.failedTime", "How long a failed search takes", "NetworkDatabase", new long[] { 60*60*1000l, 24*60*60*1000l });
_context.statManager().createRateStat("netDb.retries", "How many additional queries for an iterative search", "NetworkDatabase", new long[] { 60*60*1000l });
_context.statManager().createRateStat("netDb.failedRetries", "How many additional queries for an iterative search", "NetworkDatabase", new long[] { 60*60*1000l });
_context.statManager().createRateStat("netDb.successRetries", "How many additional queries for an iterative search", "NetworkDatabase", new long[] { 60*60*1000l });
_context.statManager().createRateStat("netDb.failedAttemptedPeers", "How many peers we sent a search to when the search fails", "NetworkDatabase", new long[] { 10*60*1000l });
_context.statManager().createRateStat("netDb.successPeers", "How many peers are contacted in a successful search", "NetworkDatabase", new long[] { 60*60*1000l, 24*60*60*1000l });
_context.statManager().createRateStat("netDb.failedPeers", "How many peers fail to respond to a lookup?", "NetworkDatabase", new long[] { 60*60*1000l, 24*60*60*1000l });

4
router/java/src/net/i2p/router/networkdb/kademlia/IterativeSearchJob.java
View File

@ -380,7 +380,7 @@ class IterativeSearchJob extends FloodSearchJob {
", peers queried: " + tries);
}
getContext().statManager().addRateData("netDb.failedTime", time, 0);
getContext().statManager().addRateData("netDb.retries", Math.max(0, tries - 1), 0);
getContext().statManager().addRateData("netDb.failedRetries", Math.max(0, tries - 1), 0);
for (Job j : _onFailed) {
getContext().jobQueue().addJob(j);
}
@ -414,7 +414,7 @@ class IterativeSearchJob extends FloodSearchJob {
_log.info(getJobId() + ": Iterative search for " + _key + " successful after " + time +
", peers queried: " + tries);
getContext().statManager().addRateData("netDb.successTime", time, 0);
getContext().statManager().addRateData("netDb.retries", tries - 1, 0);
getContext().statManager().addRateData("netDb.successRetries", tries - 1, 0);
for (Job j : _onFind) {
getContext().jobQueue().addJob(j);
}