Author: fhanik
Date: Fri Apr 28 15:17:56 2006
New Revision: 398026
URL: http://svn.apache.org/viewcvs?rev=398026&view=rev
Log:
Adjusted some of the measurements
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java?rev=398026&r1=398025&r2=398026&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/LoadTest.java
Fri Apr 28 15:17:56 2006
@@ -43,11 +43,12 @@
*/
public class LoadTest implements MembershipListener,ChannelListener, Runnable {
protected static org.apache.commons.logging.Log log =
org.apache.commons.logging.LogFactory.getLog(LoadTest.class);
- public static int size = 1020;
+ public static int size = 24000;
public static Object mutex = new Object();
public boolean doRun = true;
public long bytesReceived = 0;
+ public float mBytesReceived = 0;
public int messagesReceived = 0;
public boolean send = true;
public boolean debug = false;
@@ -146,7 +147,8 @@
Thread.sleep(pause);
}
} catch (ChannelException x) {
- log.error("Unable to send message:"+x.getMessage(),x);
+ if ( debug ) log.error("Unable to send
message:"+x.getMessage(),x);
+ log.error("Unable to send message:"+x.getMessage());
Member[] faulty = x.getFaultyMembers();
for (int i=0; i<faulty.length; i++ )
log.error("Faulty: "+faulty[i]);
--counter;
@@ -219,6 +221,7 @@
bytesReceived+=((LoadMessage)msg).getMessage().length;
+
mBytesReceived+=((float)((LoadMessage)msg).getMessage().length)/1024f/1024f;
messagesReceived++;
if ( (messagesReceived%statsInterval)==0 ||
(messagesReceived==msgCount)) {
float bytes =
(float)(((LoadMessage)msg).getMessage().length*messagesReceived);
@@ -226,9 +229,10 @@
log.info("****RECEIVE
STATS-"+Thread.currentThread().getName()+"*****"+
"\n\tMessage count :"+(long)messagesReceived+
"\n\tTotal bytes :"+(long)bytes+
+ "\n\tTotal mbytes :"+(long)mBytesReceived+
"\n\tTime since 1st:"+seconds+" seconds"+
"\n\tBytes/second :"+(bytes/seconds)+
- "\n\tMBytes/second :"+(bytes/seconds/1024f/1024f));
+ "\n\tMBytes/second :"+(mBytesReceived/seconds));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
