forked from I2P_Developers/i2p.i2p
NTCP stat cleanup
This commit is contained in:
@@ -98,7 +98,7 @@ class EventPumper implements Runnable {
|
|||||||
_transport = transport;
|
_transport = transport;
|
||||||
_expireIdleWriteTime = MAX_EXPIRE_IDLE_TIME;
|
_expireIdleWriteTime = MAX_EXPIRE_IDLE_TIME;
|
||||||
_context.statManager().createRateStat("ntcp.pumperKeySetSize", "", "ntcp", new long[] {10*60*1000} );
|
_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.pumperLoopsPerSecond", "", "ntcp", new long[] {10*60*1000} );
|
||||||
_context.statManager().createRateStat("ntcp.zeroRead", "", "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} );
|
_context.statManager().createRateStat("ntcp.zeroReadDrop", "", "ntcp", new long[] {10*60*1000} );
|
||||||
@@ -175,7 +175,7 @@ class EventPumper implements Runnable {
|
|||||||
//if (_log.shouldLog(Log.DEBUG))
|
//if (_log.shouldLog(Log.DEBUG))
|
||||||
// _log.debug("select returned " + count);
|
// _log.debug("select returned " + count);
|
||||||
Set<SelectionKey> selected = _selector.selectedKeys();
|
Set<SelectionKey> selected = _selector.selectedKeys();
|
||||||
_context.statManager().addRateData("ntcp.pumperKeysPerLoop", selected.size());
|
//_context.statManager().addRateData("ntcp.pumperKeysPerLoop", selected.size());
|
||||||
processKeys(selected);
|
processKeys(selected);
|
||||||
// does clear() do anything useful?
|
// does clear() do anything useful?
|
||||||
selected.clear();
|
selected.clear();
|
||||||
|
@@ -43,7 +43,7 @@ class NTCPSendFinisher {
|
|||||||
_context = context;
|
_context = context;
|
||||||
_log = _context.logManager().getLog(NTCPSendFinisher.class);
|
_log = _context.logManager().getLog(NTCPSendFinisher.class);
|
||||||
_transport = transport;
|
_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() {
|
public void start() {
|
||||||
@@ -88,17 +88,18 @@ class NTCPSendFinisher {
|
|||||||
*/
|
*/
|
||||||
private class RunnableEvent implements Runnable {
|
private class RunnableEvent implements Runnable {
|
||||||
private final OutNetMessage _msg;
|
private final OutNetMessage _msg;
|
||||||
private final long _queued;
|
//private final long _queued;
|
||||||
|
|
||||||
public RunnableEvent(OutNetMessage msg) {
|
public RunnableEvent(OutNetMessage msg) {
|
||||||
_msg = msg;
|
_msg = msg;
|
||||||
_queued = _context.clock().now();
|
//_queued = _context.clock().now();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void run() {
|
public void run() {
|
||||||
try {
|
try {
|
||||||
_transport.afterSend(_msg, true, false, _msg.getSendTime());
|
_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) {
|
} catch (Throwable t) {
|
||||||
_log.log(Log.CRIT, " wtf, afterSend borked", t);
|
_log.log(Log.CRIT, " wtf, afterSend borked", t);
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user