Author: fhanik
Date: Thu May 18 18:52:17 2006
New Revision: 407685
URL: http://svn.apache.org/viewvc?rev=407685&view=rev
Log:
More accurate reporting
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java?rev=407685&r1=407684&r2=407685&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
Thu May 18 18:52:17 2006
@@ -39,6 +39,7 @@
protected static org.apache.commons.logging.Log log =
org.apache.commons.logging.LogFactory.getLog(ThroughputInterceptor.class);
double mbTx = 0;
+ double mbAppTx = 0;
double mbRx = 0;
double timeTx = 0;
AtomicLong msgTxCnt = new AtomicLong(1);
@@ -61,6 +62,7 @@
throw x;
}
mbTx += ((double)(bytes*destination.length))/(1024d*1024d);
+ mbAppTx += ((double)(bytes))/(1024d*1024d);
if ( access.addAndGet(-1) == 0 ) {
long stop = System.currentTimeMillis();
timeTx += ( (double) (stop - start)) / 1000d;
@@ -89,11 +91,15 @@
StringBuffer buf = new StringBuffer("ThroughputInterceptor
Report[\n\tTx Msg:");
buf.append(msgTxCnt).append(" messages\n\tSent:");
buf.append(df.format(mbTx));
- buf.append(" MB\n\tTime:");
+ buf.append(" MB (total)\n\tSent:");
+ buf.append(df.format(mbAppTx));
+ buf.append(" MB (application)\n\tTime:");
buf.append(df.format(timeTx));
buf.append(" seconds\n\tSpeed:");
buf.append(df.format(mbTx/timeTx));
- buf.append(" MB/sec\n\tError Msg:");
+ buf.append(" MB/sec (total)\n\tSpeed:");
+ buf.append(df.format(mbAppTx/timeTx));
+ buf.append(" MB/sec (application)\n\tError Msg:");
buf.append(msgTxErr).append("\n\tRx Msg:");
buf.append(msgRxCnt);
buf.append(" messages\n\tReceived:");
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
