[hornetq-commits] JBoss hornetq SVN: r9653 - branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-09-07 18:46:19 -0400 (Tue, 07 Sep 2010)
New Revision: 9653

Modified:
   branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java
   branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java
Log:
fixing stress tests

Modified: branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java
===================================================================
--- branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java	2010-09-07 19:21:34 UTC (rev 9652)
+++ branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java	2010-09-07 22:46:19 UTC (rev 9653)
@@ -280,6 +280,8 @@
       
       journal.forceMoveNextFile();
       
+      journal.checkReclaimStatus();
+      
       Thread.sleep(5000);
       
       assertEquals(0, journal.getDataFilesCount());

Modified: branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java
===================================================================
--- branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java	2010-09-07 19:21:34 UTC (rev 9652)
+++ branches/Branch_2_1/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java	2010-09-07 22:46:19 UTC (rev 9653)
@@ -116,7 +116,11 @@
          if (i % 2 == 0 && i > 0)
          {
             System.out.println("DataFiles = " + journal.getDataFilesCount());
+            
             journal.forceMoveNextFile();
+            journal.debugWait();
+            journal.checkReclaimStatus();
+            
             if (journal.getDataFilesCount() != 0)
             {
                System.out.println("DebugJournal:"  + journal.debug());