Author: clebert.suconic(a)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());