[jboss-cvs] JBoss Messaging SVN: r7370 - trunk/tests/src/org/jboss/messaging/tests/stress/journal/remote.

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

Author: clebert.suconic at jboss.com
Date: 2009-06-16 17:00:10 -0400 (Tue, 16 Jun 2009)
New Revision: 7370

Modified:
   trunk/tests/src/org/jboss/messaging/tests/stress/journal/remote/RemoteJournalAppender.java
Log:
Fixing stress test (appendCommit needs to be sync, or the test could eventually fail)

Modified: trunk/tests/src/org/jboss/messaging/tests/stress/journal/remote/RemoteJournalAppender.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/stress/journal/remote/RemoteJournalAppender.java	2009-06-16 17:17:08 UTC (rev 7369)
+++ trunk/tests/src/org/jboss/messaging/tests/stress/journal/remote/RemoteJournalAppender.java	2009-06-16 21:00:10 UTC (rev 7370)
@@ -23,9 +23,9 @@
 package org.jboss.messaging.tests.stress.journal.remote;
 
 import java.nio.ByteBuffer;
-import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicLong;
 
+import org.jboss.messaging.core.config.impl.ConfigurationImpl;
 import org.jboss.messaging.core.journal.LoadManager;
 import org.jboss.messaging.core.journal.PreparedTransactionInfo;
 import org.jboss.messaging.core.journal.RecordInfo;
@@ -76,7 +76,7 @@
       }
       catch (Exception e)
       {
-         e.printStackTrace();
+         e.printStackTrace(System.out);
          System.exit(-1);
       }
       
@@ -142,7 +142,7 @@
 
    public static JournalImpl createJournal(String journalType, String journalDir)
    {
-      JournalImpl journal = new JournalImpl(10485760, 2, getFactory(journalType, journalDir), "journaltst", "tst", 5000);
+      JournalImpl journal = new JournalImpl(10485760, 2, getFactory(journalType, journalDir), "journaltst", "tst", 500);
       return journal;
    }
    
@@ -151,7 +151,11 @@
    {
       if (factoryType.equals("aio"))
       {
-         return new AIOSequentialFileFactory(directory);
+         return new AIOSequentialFileFactory(directory,
+                                             ConfigurationImpl.DEFAULT_JOURNAL_AIO_BUFFER_SIZE,
+                                             ConfigurationImpl.DEFAULT_JOURNAL_AIO_BUFFER_TIMEOUT,
+                                             ConfigurationImpl.DEFAULT_JOURNAL_AIO_FLUSH_SYNC,
+                                             false);
       }
       else
       {
@@ -216,7 +220,7 @@
                   if (++transactionCounter == transactionSize)
                   {
                      System.out.println("Commit transaction " + transactionId);
-                     journal.appendCommitRecord(transactionId, false);
+                     journal.appendCommitRecord(transactionId, true);
                      transactionCounter = 0;
                      transactionId = nextID.incrementAndGet();
                   }
@@ -229,7 +233,7 @@
    
             if (transactionCounter != 0)
             {
-               journal.appendCommitRecord(transactionId, false);
+               journal.appendCommitRecord(transactionId, true);
             }
             
             if (transactionSize == 0)