[jboss-svn-commits] JBL Code SVN: r32168 - 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-03-22 09:33:35 -0400 (Mon, 22 Mar 2010)
New Revision: 32168

Modified:
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task/RecursiveTask.java
Log:
Changed class to close connection objects before exiting thread. This means the maximum connection limit is not exceeded when expired worker threads cached connection object is not closed.

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-03-22 12:46:46 UTC (rev 32167)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/task/RecursiveTask.java	2010-03-22 13:33:35 UTC (rev 32168)
@@ -78,6 +78,8 @@
                 * 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(this.taskConfiguration.getConnectionHandler().getConnectionA());
+            DbUtils.closeQuietly(this.taskConfiguration.getConnectionHandler().getConnectionB());
             this.taskConfiguration.getTestConfiguration().getCompletionBarrier().await();// await all threads have finished
          }
       }
@@ -133,25 +135,4 @@
    {
       return taskConfiguration;
    }
-   
-   @Override
-   protected void finalize() throws Throwable
-   {
-      try
-      {
-         DbUtils.closeQuietly(this.taskConfiguration.getConnectionHandler().getConnectionA());
-      }
-      catch (SQLException sqlexception)
-      {
-         logger.warn(sqlexception.getMessage(), sqlexception);
-      }
-      try
-      {
-         DbUtils.closeQuietly(this.taskConfiguration.getConnectionHandler().getConnectionB());
-      }
-      catch (SQLException sqlexception)
-      {
-         logger.warn(sqlexception.getMessage(), sqlexception);
-      }
-   }
 }