handle writing the stats before the period has been reached

This commit is contained in:
jrandom
2004-06-23 19:53:20 +00:00
committed by zzz
parent 3fea4ad2ba
commit 9ffd147470

View File

@ -216,20 +216,24 @@ public class StatisticsManager implements Service {
double recvBytes60m = 0; double recvBytes60m = 0;
RateStat sendRate = _context.statManager().getRate("transport.sendMessageSize"); RateStat sendRate = _context.statManager().getRate("transport.sendMessageSize");
Rate r = sendRate.getRate(5*60*1000); if (sendRate != null) {
if (r != null) Rate r = sendRate.getRate(5*60*1000);
sendBytes5m = r.getLastTotalValue(); if (r != null)
r = sendRate.getRate(60*60*1000); sendBytes5m = r.getLastTotalValue();
if (r != null) r = sendRate.getRate(60*60*1000);
sendBytes60m = r.getLastTotalValue(); if (r != null)
sendBytes60m = r.getLastTotalValue();
}
RateStat recvRate = _context.statManager().getRate("transport.receiveMessageSize"); RateStat recvRate = _context.statManager().getRate("transport.receiveMessageSize");
r = recvRate.getRate(5*60*1000); if (recvRate != null) {
if (r != null) Rate r = recvRate.getRate(5*60*1000);
recvBytes5m = r.getLastTotalValue(); if (r != null)
r = recvRate.getRate(60*60*1000); recvBytes5m = r.getLastTotalValue();
if (r != null) r = recvRate.getRate(60*60*1000);
recvBytes60m = r.getLastTotalValue(); if (r != null)
recvBytes60m = r.getLastTotalValue();
}
String throughputRate = renderThroughput(sendBytes5m, 5*60*1000); String throughputRate = renderThroughput(sendBytes5m, 5*60*1000);
stats.setProperty("stat_bandwidthSendBps.5m", throughputRate); stats.setProperty("stat_bandwidthSendBps.5m", throughputRate);