[hornetq-commits] JBoss hornetq SVN: r8453 - trunk/src/main/org/hornetq/core/journal/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-28 17:57:54 -0500 (Sat, 28 Nov 2009)
New Revision: 8453

Modified:
   trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java
Log:
Replacing perfBlast

Modified: trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2009-11-28 22:04:18 UTC (rev 8452)
+++ trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2009-11-28 22:57:54 UTC (rev 8453)
@@ -3370,13 +3370,29 @@
          {
             lockAppend.lock();
 
-//            HornetQBuffer bb = newBuffer(128 * 1024);
-//
-//            for (int i = 0; i < pages; i++)
-//            {
-//               appendRecord(bb, false, false, null, null);
-//            }
+            final ByteArrayEncoding byteEncoder = new ByteArrayEncoding(new byte[128 * 1024]);
+            
+            JournalInternalRecord blastRecord = new JournalInternalRecord()
+            {
 
+               @Override
+               public int getEncodeSize()
+               {
+                  return byteEncoder.getEncodeSize();
+               }
+
+               public void encode(HornetQBuffer buffer)
+               {
+                  byteEncoder.encode(buffer);
+               }
+            };
+            
+
+            for (int i = 0; i < pages; i++)
+            {
+               appendRecord(blastRecord, false, false, null, null);
+            }
+
             lockAppend.unlock();
          }
          catch (Exception e)