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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-08-12 16:18:00 -0400 (Thu, 12 Aug 2010)
New Revision: 9535

Modified:
   trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java
Log:
HORNETQ-482 fixing typo

Modified: trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2010-08-12 19:39:55 UTC (rev 9534)
+++ trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2010-08-12 20:18:00 UTC (rev 9535)
@@ -1463,9 +1463,9 @@
          private void checkDeleteSize()
          {
             // HORNETQ-482 - Flush deletes only if memory is critical 
-            if (recordsToDelete.size() > DELETE_FLUSH && (runtime.freeMemory() > (runtime.maxMemory() * 0.8)))
+            if (recordsToDelete.size() > DELETE_FLUSH && (runtime.freeMemory() < (runtime.maxMemory() * 0.2)))
             {
-               log.debug("Flushing deletes during loading, deleteCount = " + recordsToDelete.size());
+               log.info("Flushing deletes during loading, deleteCount = " + recordsToDelete.size());
                // Clean up when the list is too large, or it won't be possible to load large sets of files
                // Done as part of JBMESSAGING-1678
                Iterator<RecordInfo> iter = records.iterator();
@@ -1480,6 +1480,8 @@
                }
 
                recordsToDelete.clear();
+               
+               log.info("flush delete done");
             }
          }