zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix NPE if stats are not enabled

Browse Source
This commit is contained in:
zab2
2013-08-11 11:58:51 +00:00
parent 7171edad24
commit fd297118f9
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java
View File

@@ -5,6 +5,8 @@ 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;
@@ -200,7 +202,9 @@ class ConnectionPacketHandler {
if (_log.shouldLog(Log.DEBUG))
_log.debug("immediate ack");
con.ackImmediately();
_context.statManager().getFrequency("stream.ack.dup.immediate").eventOccurred();
FrequencyStat fs = _context.statManager().getFrequency("stream.ack.dup.immediate");
if (fs != null)
fs.eventOccurred();
} else {
final long delay = nextSendTime - now;
if (_log.shouldLog(Log.DEBUG))
@@ -579,7 +583,9 @@ class ConnectionPacketHandler {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Ack dup on " + _con + ", but we have sent (" + (_con.getLastSendTime()-_created) + ")");
}
_context.statManager().getRate("stream.ack.dup.sent").addData(sent ? 1 : 0);
RateStat rs = _context.statManager().getRate("stream.ack.dup.sent");
if (rs != null)
rs.addData(sent ? 1 : 0);
}
}
}