activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1482845 - in /activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb: DBManager.scala LevelDBStore.scala
Date Wed, 15 May 2013 13:58:25 GMT
Author: chirino
Date: Wed May 15 13:58:25 2013
New Revision: 1482845

URL: http://svn.apache.org/r1482845
Log:
Don't delay flushes for now.  Seems to cause more harm than good.

Modified:
    activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
    activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala

Modified: activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala?rev=1482845&r1=1482844&r2=1482845&view=diff
==============================================================================
--- activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
(original)
+++ activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
Wed May 15 13:58:25 2013
@@ -207,7 +207,7 @@ class DelayableUOW(val manager:DBManager
   }
 
   def completeAsap() = this.synchronized { disableDelay=true }
-  def delayable = !disableDelay && delayableActions>0 && manager.flushDelay>=0
+  def delayable = !disableDelay && delayableActions>0 && manager.flushDelay>0
 
   def rm(msg:MessageId) = {
     actions -= msg

Modified: activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala?rev=1482845&r1=1482844&r2=1482845&view=diff
==============================================================================
--- activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala
(original)
+++ activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala
Wed May 15 13:58:25 2013
@@ -168,7 +168,7 @@ class LevelDBStore extends LockableServi
   @BeanProperty
   var indexCacheSize: Long = 1024 * 1024 * 256L
   @BeanProperty
-  var flushDelay = 1000*5
+  var flushDelay = 0
   @BeanProperty
   var asyncBufferSize = 1024*1024*4
   @BeanProperty



Mime
View raw message