directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jvermill...@apache.org
Subject svn commit: r475739 - /directory/branches/mina/1.0/core/src/main/java/org/apache/mina/management/StatCollector.java
Date Thu, 16 Nov 2006 13:57:39 GMT
Author: jvermillard
Date: Thu Nov 16 05:57:38 2006
New Revision: 475739

URL: http://svn.apache.org/viewvc?view=rev&rev=475739
Log:
DIRMINA-299 continued,
fixing the closed session buggy numbers

Modified:
    directory/branches/mina/1.0/core/src/main/java/org/apache/mina/management/StatCollector.java

Modified: directory/branches/mina/1.0/core/src/main/java/org/apache/mina/management/StatCollector.java
URL: http://svn.apache.org/viewvc/directory/branches/mina/1.0/core/src/main/java/org/apache/mina/management/StatCollector.java?view=diff&rev=475739&r1=475738&r2=475739
==============================================================================
--- directory/branches/mina/1.0/core/src/main/java/org/apache/mina/management/StatCollector.java
(original)
+++ directory/branches/mina/1.0/core/src/main/java/org/apache/mina/management/StatCollector.java
Thu Nov 16 05:57: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();
                 }



Mime
View raw message