You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2006/11/21 13:33:39 UTC
svn commit: r477648 -
/mina/branches/1.1/core/src/main/java/org/apache/mina/management/StatCollector.java
Author: jvermillard
Date: Tue Nov 21 04:33:38 2006
New Revision: 477648
URL: http://svn.apache.org/viewvc?view=rev&rev=477648
Log:
DIRMINA-299 continued,
fixing the closed session buggy numbers
Modified:
mina/branches/1.1/core/src/main/java/org/apache/mina/management/StatCollector.java
Modified: mina/branches/1.1/core/src/main/java/org/apache/mina/management/StatCollector.java
URL: http://svn.apache.org/viewvc/mina/branches/1.1/core/src/main/java/org/apache/mina/management/StatCollector.java?view=diff&rev=477648&r1=477647&r2=477648
==============================================================================
--- mina/branches/1.1/core/src/main/java/org/apache/mina/management/StatCollector.java (original)
+++ mina/branches/1.1/core/src/main/java/org/apache/mina/management/StatCollector.java Tue Nov 21 04:33:38 2006
@@ -206,7 +206,9 @@
{
totalProcessedSessions += 1;
polledSessions.add( session );
- session.setAttribute( KEY, new IoSessionStat() );
+ IoSessionStat sessionStats = new IoSessionStat();
+ sessionStats.lastPollingTime = System.currentTimeMillis();
+ session.setAttribute( KEY, sessionStats );
}
}
@@ -302,11 +304,10 @@
{
}
-
- msgWrittenThroughput = 0f;
- msgReadThroughput = 0f;
- bytesWrittenThroughput = 0f;
- bytesReadThroughput = 0f;
+ float tmpMsgWrittenThroughput = 0f;
+ float tmpMsgReadThroughput = 0f;
+ float tmpBytesWrittenThroughput = 0f;
+ float tmpBytesReadThroughput = 0f;
for ( Iterator iter = polledSessions.iterator(); iter.hasNext(); )
{
@@ -317,19 +318,24 @@
sessStat.byteReadThroughput = ( session.getReadBytes() - sessStat.lastByteRead )
/ ( pollingInterval / 1000f );
- bytesReadThroughput += sessStat.byteReadThroughput;
+ tmpBytesReadThroughput += sessStat.byteReadThroughput;
sessStat.byteWrittenThroughput = ( session.getWrittenBytes() - sessStat.lastByteWrite )
/ ( pollingInterval / 1000f );
- bytesWrittenThroughput += sessStat.byteWrittenThroughput;
+ tmpBytesWrittenThroughput += sessStat.byteWrittenThroughput;
sessStat.messageReadThroughput = ( session.getReadMessages() - sessStat.lastMessageRead )
/ ( pollingInterval / 1000f );
- msgReadThroughput += sessStat.messageReadThroughput;
+ tmpMsgReadThroughput += sessStat.messageReadThroughput;
sessStat.messageWrittenThroughput = ( session.getWrittenMessages() - sessStat.lastMessageWrite )
/ ( pollingInterval / 1000f );
- msgWrittenThroughput += sessStat.messageWrittenThroughput;
+ tmpMsgWrittenThroughput += sessStat.messageWrittenThroughput;
+
+ msgWrittenThroughput = tmpMsgWrittenThroughput;
+ msgReadThroughput = tmpMsgReadThroughput;
+ bytesWrittenThroughput = tmpBytesWrittenThroughput;
+ bytesReadThroughput = tmpMsgWrittenThroughput;
sessStat.lastPollingTime = System.currentTimeMillis();
}