[jbpm-commits] JBoss JBPM SVN: r3555 - jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load.

[do-not-reply at jboss.org]

Author: tom.baeyens at jboss.com
Date: 2008-12-26 10:10:04 -0500 (Fri, 26 Dec 2008)
New Revision: 3555

Modified:
   jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/AddCommentMessage.java
   jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/JobExecutorTestCase.java
   jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/MessageProcessingTest.java
Log:
load test fine tunings

Modified: jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/AddCommentMessage.java
===================================================================
--- jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/AddCommentMessage.java	2008-12-26 14:28:11 UTC (rev 3554)
+++ jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/AddCommentMessage.java	2008-12-26 15:10:04 UTC (rev 3555)
@@ -21,11 +21,8 @@
  */
 package org.jbpm.test.load;
 
-import java.util.Random;
-
 import org.hibernate.Session;
 import org.jbpm.env.Environment;
-import org.jbpm.log.Log;
 import org.jbpm.pvm.internal.job.MessageImpl;
 import org.jbpm.pvm.internal.model.CommentImpl;
 
@@ -35,7 +32,6 @@
 public class AddCommentMessage extends MessageImpl<Void>  {
   
   private static final long serialVersionUID = 1L;
-  static Random random = new Random();
   
   public AddCommentMessage() {
   }

Modified: jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/JobExecutorTestCase.java
===================================================================
--- jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/JobExecutorTestCase.java	2008-12-26 14:28:11 UTC (rev 3554)
+++ jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/JobExecutorTestCase.java	2008-12-26 15:10:04 UTC (rev 3555)
@@ -62,9 +62,13 @@
       log.debug("going to sleep for " + checkInterval + " millis, waiting for the job executor to process more jobs");
       Thread.sleep(checkInterval);
       jobsAvailable = areJobsAvailable();
+      logStatus();
     }
   }
 
+  public void logStatus() {
+  }
+
   public boolean areJobsAvailable() {
     return commandService.execute(new Command<Boolean>() {
       public Boolean execute(Environment environment) {

Modified: jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/MessageProcessingTest.java
===================================================================
--- jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/MessageProcessingTest.java	2008-12-26 14:28:11 UTC (rev 3554)
+++ jbpm4/trunk/modules/test-load/src/test/java/org/jbpm/test/load/MessageProcessingTest.java	2008-12-26 15:10:04 UTC (rev 3555)
@@ -47,7 +47,7 @@
   private static final Log log = Log.getLog(MessageProcessingTest.class.getName());
 
   static long nbrOfTestMessages = 10000; // nbrOfTestMessages must be dividable by insertGroupSize  
-  static long insertGroupSize = 10;
+  static long insertGroupSize = 50;
 
   static final long SECOND = 1000;  
   static final long MINUTE = 60 * SECOND;  
@@ -99,14 +99,14 @@
     memoryWriter.close();
   }
 
-  void logStatus() {
+  public void logStatus() {
     Runtime runtime = Runtime.getRuntime();
     long total = runtime.totalMemory();
     long free = runtime.freeMemory();
     long used = total - free;
     memoryWriter.println(used);
     
-    log.info(commentsAdded+" msgs in "+formatDuration(start, System.currentTimeMillis())+" mem:"+used);
+    log.info(commentsAdded+" msgs in "+formatDuration(start, System.currentTimeMillis()));
   }
 
   public void testMessageProcessing() throws Exception {
@@ -166,7 +166,7 @@
       assertTrue("message " + i + " is not processed: " + processedMessageNumbers, processedMessageNumbers.contains(i));
     }
   }
-
+  
   // helper methods ///////////////////////////////////////////////////////////
 
   public static String formatDuration(long start, long stop) {