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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-09-02 19:59:03 -0400 (Thu, 02 Sep 2010)
New Revision: 9633

Modified:
   branches/Branch_2_1/tests/src/org/hornetq/tests/integration/journal/NIOJournalCompactTest.java
Log:
HORNETQ-485 - adding new tests on compacting

Modified: branches/Branch_2_1/tests/src/org/hornetq/tests/integration/journal/NIOJournalCompactTest.java
===================================================================
--- branches/Branch_2_1/tests/src/org/hornetq/tests/integration/journal/NIOJournalCompactTest.java	2010-09-02 23:53:00 UTC (rev 9632)
+++ branches/Branch_2_1/tests/src/org/hornetq/tests/integration/journal/NIOJournalCompactTest.java	2010-09-02 23:59:03 UTC (rev 9633)
@@ -23,6 +23,7 @@
 import junit.framework.Assert;
 
 import org.hornetq.api.core.Pair;
+import org.hornetq.core.journal.EncodingSupport;
 import org.hornetq.core.journal.PreparedTransactionInfo;
 import org.hornetq.core.journal.RecordInfo;
 import org.hornetq.core.journal.SequentialFile;
@@ -232,6 +233,119 @@
 
    }
 
+   public void testCompactPrepareRestart() throws Exception
+   {
+      setup(2, 60 * 1024, false);
+
+      createJournal();
+      
+      startJournal();
+      
+      load();
+
+      startCompact();
+      
+      addTx(1, 2);
+      
+      prepare(1, new SimpleEncoding(10, (byte)0));
+      
+      finishCompact();
+      
+      stopJournal();
+      
+      createJournal();
+      
+      startJournal();
+      
+      loadAndCheck();
+      
+      startCompact();
+      
+      commit(1);
+      
+      finishCompact();
+      
+      journal.compact();
+      
+      stopJournal();
+      
+      createJournal();
+
+      startJournal();
+      
+      loadAndCheck();
+   }
+
+   public void testCompactPrepareRestart2() throws Exception
+   {
+      setup(2, 60 * 1024, false);
+
+      createJournal();
+      
+      startJournal();
+      
+      load();
+
+      addTx(1, 2);
+      
+      prepare(1, new SimpleEncoding(10, (byte)0));
+      
+      stopJournal();
+      
+      createJournal();
+      
+      startJournal();
+      
+      loadAndCheck();
+      
+      startCompact();
+      
+      commit(1);
+      
+      finishCompact();
+      
+      journal.compact();
+      
+      stopJournal();
+      
+      createJournal();
+
+      startJournal();
+      
+      loadAndCheck();
+   }
+
+   public void testCompactPrepareRestart3() throws Exception
+   {
+      setup(2, 60 * 1024, false);
+
+      createJournal();
+      
+      startJournal();
+      
+      load();
+
+      addTx(1, 2, 3);
+      
+      prepare(1, new SimpleEncoding(10, (byte)0));
+      
+      startCompact();
+      
+      commit(1);
+      
+      finishCompact();
+      
+      journal.compact();
+      
+      stopJournal();
+      
+      createJournal();
+
+      startJournal();
+      
+      loadAndCheck();
+   }
+
    public void testOnRollback() throws Exception
    {