Author: mvecera(a)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 } }