From 37a542c0095b78cefdff414eb691e81d55812273 Mon Sep 17 00:00:00 2001
From: zzz <zzz@mail.i2p>
Date: Wed, 8 Aug 2012 17:06:33 +0000
Subject: [PATCH] NTCP stat cleanup
---
.../src/net/i2p/router/transport/ntcp/EventPumper.java | 4 ++--
.../net/i2p/router/transport/ntcp/NTCPSendFinisher.java | 9 +++++----
2 files changed, 7 insertions(+), 6 deletions(-)
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 33bf70e90a..d5d11b7d7f 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 630036204d..ee2fdffa54 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);
}
--
GitLab