diff --git a/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java b/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java index 68a237f52d2ef6a654f719c4316aafb315413a65..7338592b4eaccc247acdc83a976c7b1c5c35f5ee 100644 --- a/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java +++ b/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java @@ -48,7 +48,7 @@ public class CommSystemFacadeImpl extends CommSystemFacade { public CommSystemFacadeImpl(RouterContext context) { _context = context; _log = _context.logManager().getLog(CommSystemFacadeImpl.class); - _context.statManager().createRateStat("transport.getBidsJobTime", "How long does it take?", "Transport", new long[] { 10*60*1000l }); + //_context.statManager().createRateStat("transport.getBidsJobTime", "How long does it take?", "Transport", new long[] { 10*60*1000l }); _netMonitorStatus = true; _geoIP = new GeoIP(_context); startGeoIP(); @@ -142,9 +142,10 @@ public class CommSystemFacadeImpl extends CommSystemFacade { public void processMessage(OutNetMessage msg) { //GetBidsJob j = new GetBidsJob(_context, this, msg); //j.runJob(); - long before = _context.clock().now(); + //long before = _context.clock().now(); GetBidsJob.getBids(_context, this, msg); - _context.statManager().addRateData("transport.getBidsJobTime", _context.clock().now() - before, 0); + // < 0.4 ms + //_context.statManager().addRateData("transport.getBidsJobTime", _context.clock().now() - before); } @Override diff --git a/router/java/src/net/i2p/router/transport/GetBidsJob.java b/router/java/src/net/i2p/router/transport/GetBidsJob.java index 4215d8f0d174bbf79f98debad2c5b2c9486bd933..85da18c13fe8b713779443200d4cb38317a6ecbe 100644 --- a/router/java/src/net/i2p/router/transport/GetBidsJob.java +++ b/router/java/src/net/i2p/router/transport/GetBidsJob.java @@ -47,7 +47,7 @@ class GetBidsJob extends JobImpl { if (log.shouldLog(Log.WARN)) log.warn("Attempt to send a message to a banlisted peer - " + to); //context.messageRegistry().peerFailed(to); - context.statManager().addRateData("transport.bidFailBanlisted", msg.getLifetime(), 0); + context.statManager().addRateData("transport.bidFailBanlisted", msg.getLifetime()); fail(context, msg); return; } @@ -56,7 +56,7 @@ class GetBidsJob extends JobImpl { if (to.equals(us)) { if (log.shouldLog(Log.ERROR)) log.error("wtf, send a message to ourselves? nuh uh. msg = " + msg); - context.statManager().addRateData("transport.bidFailSelf", msg.getLifetime(), 0); + context.statManager().addRateData("transport.bidFailSelf", msg.getLifetime()); fail(context, msg); return; } @@ -65,11 +65,11 @@ class GetBidsJob extends JobImpl { if (bid == null) { int failedCount = msg.getFailedTransports().size(); if (failedCount == 0) { - context.statManager().addRateData("transport.bidFailNoTransports", msg.getLifetime(), 0); + context.statManager().addRateData("transport.bidFailNoTransports", msg.getLifetime()); // This used to be "no common transports" but it is almost always no transports at all context.banlist().banlistRouter(to, _x("No transports (hidden or starting up?)")); } else if (failedCount >= facade.getTransportCount()) { - context.statManager().addRateData("transport.bidFailAllTransports", msg.getLifetime(), 0); + context.statManager().addRateData("transport.bidFailAllTransports", msg.getLifetime()); // fail after all transports were unsuccessful context.netDb().fail(to); }