[jboss-cvs] JBoss Messaging SVN: r7710 - in trunk: tests/src/org/jboss/messaging/tests/integration/cluster/distribution and 2 other directories.

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

Author: clebert.suconic at jboss.com
Date: 2009-08-12 00:32:27 -0400 (Wed, 12 Aug 2009)
New Revision: 7710

Modified:
   trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java
   trunk/tests/src/org/jboss/messaging/tests/integration/cluster/distribution/ClusterTestBase.java
   trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestBase.java
   trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java
   trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java
Log:
Adding assertions

Modified: trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java	2009-08-11 18:57:24 UTC (rev 7709)
+++ trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java	2009-08-12 04:32:27 UTC (rev 7710)
@@ -406,6 +406,16 @@
       resetBuffer(buffer, buffer.limit());
       buffer.position(0);
    }
+   
+   // Protected -------------------------------------------------------------------------
+   
+   protected void finalize()
+   {
+      if (opened)
+      {
+         log.warn("AsynchronousFile: " + this.fileName + " being finalized with opened state");
+      }
+   }
 
    // Private ---------------------------------------------------------------------------
 

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/cluster/distribution/ClusterTestBase.java	2009-08-11 18:57:24 UTC (rev 7709)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/cluster/distribution/ClusterTestBase.java	2009-08-12 04:32:27 UTC (rev 7710)
@@ -106,6 +106,8 @@
       servers = new MessagingServer[MAX_SERVERS];
 
       sfs = new ClientSessionFactory[MAX_SERVERS];
+      
+      consumers = new ConsumerHolder[MAX_CONSUMERS];
 
       super.tearDown();
    }

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestBase.java	2009-08-11 18:57:24 UTC (rev 7709)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestBase.java	2009-08-12 04:32:27 UTC (rev 7710)
@@ -103,8 +103,6 @@
 
       journal = null;
 
-      assertEquals(0, AsynchronousFileImpl.getTotalMaxIO());
-
       super.tearDown();
    }
 

Modified: trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java	2009-08-11 18:57:24 UTC (rev 7709)
+++ trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java	2009-08-12 04:32:27 UTC (rev 7710)
@@ -22,7 +22,6 @@
 
 package org.jboss.messaging.tests.util;
 
-import java.io.File;
 import java.lang.management.ManagementFactory;
 import java.lang.ref.WeakReference;
 import java.util.HashMap;

Modified: trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java	2009-08-11 18:57:24 UTC (rev 7709)
+++ trunk/tests/src/org/jboss/messaging/tests/util/UnitTestCase.java	2009-08-12 04:32:27 UTC (rev 7710)
@@ -50,6 +50,7 @@
 
 import junit.framework.TestCase;
 
+import org.jboss.messaging.core.asyncio.impl.AsynchronousFileImpl;
 import org.jboss.messaging.core.buffers.ChannelBuffers;
 import org.jboss.messaging.core.client.ClientMessage;
 import org.jboss.messaging.core.client.ClientSession;
@@ -570,7 +571,9 @@
    {
       deleteDirectory(new File(getTestDir()));
 
-      assertEquals(0, InVMRegistry.instance.size());          
+      assertEquals(0, InVMRegistry.instance.size());
+      
+      assertEquals(0, AsynchronousFileImpl.getTotalMaxIO());
 
       super.tearDown();
    }