From 193f0bbc42337d2a27d94b6b1d113258e41e0a0f Mon Sep 17 00:00:00 2001
From: zab2 <zab2@mail.i2p>
Date: Sun, 11 Aug 2013 20:21:06 +0000
Subject: [PATCH] More elegant
---
.../i2p/client/streaming/ConnectionPacketHandler.java | 10 ++--------
1 file changed, 2 insertions(+), 8 deletions(-)
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java
index 64e16cffa5..2bc867c475 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java
@@ -5,8 +5,6 @@ import java.util.List;
import net.i2p.I2PAppContext;
import net.i2p.I2PException;
import net.i2p.data.Destination;
-import net.i2p.stat.FrequencyStat;
-import net.i2p.stat.RateStat;
import net.i2p.util.Log;
import net.i2p.util.SimpleScheduler;
import net.i2p.util.SimpleTimer;
@@ -202,9 +200,7 @@ class ConnectionPacketHandler {
if (_log.shouldLog(Log.DEBUG))
_log.debug("immediate ack");
con.ackImmediately();
- FrequencyStat fs = _context.statManager().getFrequency("stream.ack.dup.immediate");
- if (fs != null)
- fs.eventOccurred();
+ _context.statManager().updateFrequency("stream.ack.dup.immediate");
} else {
final long delay = nextSendTime - now;
if (_log.shouldLog(Log.DEBUG))
@@ -583,9 +579,7 @@ class ConnectionPacketHandler {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Ack dup on " + _con + ", but we have sent (" + (_con.getLastSendTime()-_created) + ")");
}
- RateStat rs = _context.statManager().getRate("stream.ack.dup.sent");
- if (rs != null)
- rs.addData(sent ? 1 : 0);
+ _context.statManager().addRateData("stream.ack.dup.sent", sent ? 1 : 0);
}
}
}
--
GitLab