[jboss-cvs] JBoss Messaging SVN: r7449 - branches/clebert_temp_expirement/tests/src/org/jboss/messaging/tests/unit/core/journal/impl.

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

Author: clebert.suconic at jboss.com
Date: 2009-06-24 00:49:11 -0400 (Wed, 24 Jun 2009)
New Revision: 7449

Modified:
   branches/clebert_temp_expirement/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestUnit.java
Log:
adding new test

Modified: branches/clebert_temp_expirement/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestUnit.java
===================================================================
--- branches/clebert_temp_expirement/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestUnit.java	2009-06-24 04:48:19 UTC (rev 7448)
+++ branches/clebert_temp_expirement/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalImplTestUnit.java	2009-06-24 04:49:11 UTC (rev 7449)
@@ -1666,7 +1666,6 @@
       assertEquals(1, journal.getIDMapSize());
    }
 
-   
    public void testPrepareNoReclaim() throws Exception
    {
       setup(2, calculateRecordSize(JournalImpl.SIZE_HEADER, getAlignment()) + calculateRecordSize(recordLength,
@@ -2317,6 +2316,22 @@
       loadAndCheck();
    }
 
+   public void testAddReload() throws Exception
+   {
+      setup(10, 10 * 1024, true);
+      createJournal();
+      startJournal();
+      load();
+      addTx(1, 1);
+      commit(1);
+
+      stopJournal();
+      createJournal();
+      startJournal();
+      loadAndCheck();
+
+   }
+
    public void testAddUpdateDeleteTransactionalRestartAndContinue() throws Exception
    {
       setup(10, 10 * 1024, true);
@@ -2945,7 +2960,7 @@
       createJournal();
       startJournal();
       load();
-      
+
       int transactionID = 0;
 
       for (int i = 0; i < 100; i++)
@@ -2997,18 +3012,17 @@
       }
 
       journal.forceMoveNextFile();
-      
+
       commit(transactionID++);
-      
+
       for (int i = 100; i < 200; i++)
       {
          updateTx(transactionID, i);
          deleteTx(transactionID, i);
       }
-      
+
       commit(transactionID++);
-      
- 
+
       System.out.println("Before reclaim ****************************");
       System.out.println(journal.debug());
       System.out.println("*****************************************");
@@ -3021,7 +3035,7 @@
       System.out.println("After reclaim ****************************");
       System.out.println(journal.debug());
       System.out.println("*****************************************");
-      
+
       journal.forceMoveNextFile();
       journal.checkAndReclaimFiles();
 
@@ -3042,7 +3056,7 @@
       createJournal();
       startJournal();
       load();
-      
+
       long transactionID = 0;
 
       for (int i = 0; i < 500; i++)
@@ -3069,9 +3083,8 @@
       }
 
       System.out.println("Number of Files: " + journal.getDataFilesCount());
-      
-      
-      for (int i = 0 ; i < 1000; i++)
+
+      for (int i = 0; i < 1000; i++)
       {
          if (!(i % 10 == 0))
          {
@@ -3086,8 +3099,7 @@
       System.out.println("Before compact ****************************");
       System.out.println(journal.debug());
       System.out.println("*****************************************");
-      
-      
+
       journal.compact();
 
    }