You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2013/05/15 15:58:25 UTC
svn commit: r1482845 - in
/activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb:
DBManager.scala LevelDBStore.scala
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