diff --git a/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java b/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java index 33bf70e90a16ef6ebdc20875c407055cd2fa36f0..d5d11b7d7fbea0d1b527650fa62d1ec0b34d1529 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java +++ b/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java @@ -98,7 +98,7 @@ class EventPumper implements Runnable { _transport = transport; _expireIdleWriteTime = MAX_EXPIRE_IDLE_TIME; _context.statManager().createRateStat("ntcp.pumperKeySetSize", "", "ntcp", new long[] {10*60*1000} ); - _context.statManager().createRateStat("ntcp.pumperKeysPerLoop", "", "ntcp", new long[] {10*60*1000} ); + //_context.statManager().createRateStat("ntcp.pumperKeysPerLoop", "", "ntcp", new long[] {10*60*1000} ); _context.statManager().createRateStat("ntcp.pumperLoopsPerSecond", "", "ntcp", new long[] {10*60*1000} ); _context.statManager().createRateStat("ntcp.zeroRead", "", "ntcp", new long[] {10*60*1000} ); _context.statManager().createRateStat("ntcp.zeroReadDrop", "", "ntcp", new long[] {10*60*1000} ); @@ -175,7 +175,7 @@ class EventPumper implements Runnable { //if (_log.shouldLog(Log.DEBUG)) // _log.debug("select returned " + count); Set<SelectionKey> selected = _selector.selectedKeys(); - _context.statManager().addRateData("ntcp.pumperKeysPerLoop", selected.size()); + //_context.statManager().addRateData("ntcp.pumperKeysPerLoop", selected.size()); processKeys(selected); // does clear() do anything useful? selected.clear(); diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPSendFinisher.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPSendFinisher.java index 630036204d5402a6f0c9c7a339265fc27397a88a..ee2fdffa54534f907f9e5d8f354c2a417e8acad4 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPSendFinisher.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPSendFinisher.java @@ -43,7 +43,7 @@ class NTCPSendFinisher { _context = context; _log = _context.logManager().getLog(NTCPSendFinisher.class); _transport = transport; - _context.statManager().createRateStat("ntcp.sendFinishTime", "How long to queue and excecute msg.afterSend()", "ntcp", new long[] {5*1000}); + //_context.statManager().createRateStat("ntcp.sendFinishTime", "How long to queue and excecute msg.afterSend()", "ntcp", new long[] {5*1000}); } public void start() { @@ -88,17 +88,18 @@ class NTCPSendFinisher { */ private class RunnableEvent implements Runnable { private final OutNetMessage _msg; - private final long _queued; + //private final long _queued; public RunnableEvent(OutNetMessage msg) { _msg = msg; - _queued = _context.clock().now(); + //_queued = _context.clock().now(); } public void run() { try { _transport.afterSend(_msg, true, false, _msg.getSendTime()); - _context.statManager().addRateData("ntcp.sendFinishTime", _context.clock().now() - _queued, 0); + // appx 0.1 ms + //_context.statManager().addRateData("ntcp.sendFinishTime", _context.clock().now() - _queued, 0); } catch (Throwable t) { _log.log(Log.CRIT, " wtf, afterSend borked", t); }