[jbpm-commits] JBoss JBPM SVN: r3911 - jbpm3/tags/jbpm-3.2.5.SP1/modules/core/src/test/java/org/jbpm/perf.

[do-not-reply at jboss.org]

Author: mvecera at redhat.com
Date: 2009-02-18 03:53:25 -0500 (Wed, 18 Feb 2009)
New Revision: 3911

Modified:
   jbpm3/tags/jbpm-3.2.5.SP1/modules/core/src/test/java/org/jbpm/perf/AsyncCallTest.java
Log:
core, AsyncCallTest, fixed transactions

Modified: jbpm3/tags/jbpm-3.2.5.SP1/modules/core/src/test/java/org/jbpm/perf/AsyncCallTest.java
===================================================================
--- jbpm3/tags/jbpm-3.2.5.SP1/modules/core/src/test/java/org/jbpm/perf/AsyncCallTest.java	2009-02-18 07:32:15 UTC (rev 3910)
+++ jbpm3/tags/jbpm-3.2.5.SP1/modules/core/src/test/java/org/jbpm/perf/AsyncCallTest.java	2009-02-18 08:53:25 UTC (rev 3911)
@@ -21,10 +21,8 @@
  */
 package org.jbpm.perf;
 
-import junit.textui.TestRunner;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.hibernate.criterion.Junction;
 import org.jbpm.command.CommandService;
 import org.jbpm.command.StartProcessInstanceCommand;
 import org.jbpm.command.impl.CommandServiceImpl;
@@ -60,6 +58,7 @@
 
    @Override
    protected void tearDown() throws Exception {
+      beginSessionTransaction();
       jbpmContext.getGraphSession().deleteProcessDefinition(processDefinition.getId());
       super.tearDown();
    }
@@ -69,25 +68,28 @@
       log.info("=== EXECUTING PERFORMANCE TEST ================================================");
       log.info("");
 
+      long start = System.currentTimeMillis();
+
+      commitAndCloseSession();
       startJobExecutor();
 
-      long start = System.currentTimeMillis();
-
       for (int i = 0; i < INSTANCES; i++) {
+         beginSessionTransaction();
          StartProcessInstanceCommand startCommand = new StartProcessInstanceCommand();
          startCommand.setProcessDefinitionId(processDefinition.getId());
          startCommand.setProcessDefinitionName("processDefinition1");
          ProcessInstance pi = (ProcessInstance) commandService.execute(startCommand);
+         commitAndCloseSession();
       }
 
+      stopJobExecutor();
+
       long stop = System.currentTimeMillis();
       log.info("=== TEST FINISHED PROCESSING " + INSTANCES + " INSTANCES IN " + (stop - start) + " MILLIS ===");
       log.info("=== THIS IS " + INSTANCES / ((double) (stop - start) / 1000) + " PROCESSES PER SECOND ===");
-
-      stopJobExecutor();
    }
 
    public void execute(ExecutionContext executionContext) throws Exception {
-      // 023e:45AC NOP
+      // no-op
    }
 }