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

Tunnel build stat tweak (commented out)

Browse Source
This commit is contained in:
zzz
2016-04-16 16:21:28 +00:00
parent b66bc39db3
commit 696c2152b3
1 changed files with 18 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java
View File

@@ -68,6 +68,10 @@ class BuildExecutor implements Runnable {
//_context.statManager().createRateStat("tunnel.pendingRemaining", "How many inbound requests are pending after a pass (period is how long the pass takes)?", "Tunnels", new long[] { 60*1000, 10*60*1000 }); //_context.statManager().createRateStat("tunnel.pendingRemaining", "How many inbound requests are pending after a pass (period is how long the pass takes)?", "Tunnels", new long[] { 60*1000, 10*60*1000 });
_context.statManager().createRateStat("tunnel.buildFailFirstHop", "How often we fail to build a OB tunnel because we can't contact the first hop", "Tunnels", new long[] { 60*1000, 10*60*1000 }); _context.statManager().createRateStat("tunnel.buildFailFirstHop", "How often we fail to build a OB tunnel because we can't contact the first hop", "Tunnels", new long[] { 60*1000, 10*60*1000 });
_context.statManager().createRateStat("tunnel.buildReplySlow", "Build reply late, but not too late", "Tunnels", new long[] { 10*60*1000 }); _context.statManager().createRateStat("tunnel.buildReplySlow", "Build reply late, but not too late", "Tunnels", new long[] { 10*60*1000 });
//ctx.statManager().createRateStat("tunnel.buildClientExpireIB", "", "Tunnels", new long[] { 60*60*1000 });
//ctx.statManager().createRateStat("tunnel.buildClientExpireOB", "", "Tunnels", new long[] { 60*60*1000 });
//ctx.statManager().createRateStat("tunnel.buildExploratoryExpireIB", "", "Tunnels", new long[] { 60*60*1000 });
//ctx.statManager().createRateStat("tunnel.buildExploratoryExpireOB", "", "Tunnels", new long[] { 60*60*1000 });
// Get stat manager, get recognized bandwidth tiers // Get stat manager, get recognized bandwidth tiers
StatManager statMgr = _context.statManager(); StatManager statMgr = _context.statManager();
@@ -184,7 +188,7 @@ class BuildExecutor implements Runnable {
String bwTier = "Unknown"; String bwTier = "Unknown";
if (ri != null) bwTier = ri.getBandwidthTier(); // Returns "Unknown" if none recognized if (ri != null) bwTier = ri.getBandwidthTier(); // Returns "Unknown" if none recognized
// Record that a peer of the given tier expired // Record that a peer of the given tier expired
_context.statManager().addRateData("tunnel.tierExpire" + bwTier, 1, 0); _context.statManager().addRateData("tunnel.tierExpire" + bwTier, 1);
didNotReply(cfg.getReplyMessageId(), peer); didNotReply(cfg.getReplyMessageId(), peer);
// Blame everybody since we don't know whose fault it is. // Blame everybody since we don't know whose fault it is.
// (it could be our exploratory tunnel's fault too...) // (it could be our exploratory tunnel's fault too...)
@@ -194,10 +198,19 @@ class BuildExecutor implements Runnable {
TunnelPool pool = cfg.getTunnelPool(); TunnelPool pool = cfg.getTunnelPool();
if (pool != null) if (pool != null)
pool.buildComplete(cfg); pool.buildComplete(cfg);
if (cfg.getDestination() == null) if (cfg.getDestination() == null) {
_context.statManager().addRateData("tunnel.buildExploratoryExpire", 1, 0); _context.statManager().addRateData("tunnel.buildExploratoryExpire", 1);
else //if (cfg.isInbound())
_context.statManager().addRateData("tunnel.buildClientExpire", 1, 0); // _context.statManager().addRateData("tunnel.buildExploratoryExpireIB", 1);
//else
// _context.statManager().addRateData("tunnel.buildExploratoryExpireOB", 1);
} else {
_context.statManager().addRateData("tunnel.buildClientExpire", 1);
//if (cfg.isInbound())
// _context.statManager().addRateData("tunnel.buildClientExpireIB", 1);
//else
// _context.statManager().addRateData("tunnel.buildClientExpireOB", 1);
}
} }
} }