[jboss-svn-commits] JBL Code SVN: r34445 - labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task.

[jboss-svn-commits at lists.jboss.org]

Author: whitingjr
Date: 2010-08-02 04:56:33 -0400 (Mon, 02 Aug 2010)
New Revision: 34445

Modified:
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task/RecursiveTask.java
Log:
Changed to use the connection handler to de cache the connection object.

Modified: labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task/RecursiveTask.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task/RecursiveTask.java	2010-08-02 08:55:24 UTC (rev 34444)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task/RecursiveTask.java	2010-08-02 08:56:33 UTC (rev 34445)
@@ -24,13 +24,11 @@
 
 import java.util.Stack;
 
-import org.apache.commons.dbutils.DbUtils;
 import org.apache.commons.lang.mutable.MutableLong;
 import org.apache.log4j.Logger;
 import org.apache.log4j.NDC;
 import org.jboss.jbossts.performance.configuration.JPAConfiguration;
 import org.jboss.jbossts.performance.resource.SynchronizeTask;
-import org.jboss.resource.adapter.jdbc.WrappedConnection;
 import org.testng.Assert;
 
 /**
@@ -48,6 +46,7 @@
    @SuppressWarnings("unchecked")
    private final Stack parentNDC;
    private final JPAConfiguration taskConfiguration;
+   
    public RecursiveTask(final JPAConfiguration configuration)
    {
       this.recurseCount = configuration.getIterationCount();
@@ -79,8 +78,9 @@
                 * this thread to execute the task. nano seconds */
                this.taskConfiguration.getTestConfiguration().getResults().add(( totalTime.toLong()/this.recurseCount));// serialized modification, insertion order not important
             }
-            DbUtils.closeQuietly(((WrappedConnection)this.taskConfiguration.getConnectionHandler().getConnectionA()));//really release the connection
-            DbUtils.closeQuietly(((WrappedConnection)this.taskConfiguration.getConnectionHandler().getConnectionB()));//really release the connection
+            //TODO: investigate why the connection is not being released back to the pool
+            this.taskConfiguration.getConnectionHandler().deCacheConnection(this.taskConfiguration.getConnectionHandler().getConnectionA()); //really release the connection
+            this.taskConfiguration.getConnectionHandler().deCacheConnection(this.taskConfiguration.getConnectionHandler().getConnectionB()); //really release the connection
             this.taskConfiguration.getTestConfiguration().getCompletionBarrier().await();// await all threads have finished
          }
       }