mirror of https://github.com/apache/activemq.git
fix leveldb variant of org.apache.activemq.bugs.AMQ2584Test - add rudimentary size calculation to leveldb
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1423854 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
7400977609
commit
d1292441a2
|
@ -436,6 +436,8 @@ class LevelDBClient(store: LevelDBStore) {
|
|||
def tempIndexFile = directory / ("temp"+INDEX_SUFFIX)
|
||||
def snapshotIndexFile(id:Long) = create_sequence_file(directory,id, INDEX_SUFFIX)
|
||||
|
||||
def size: Long = logRefs.size * store.logSize
|
||||
|
||||
def createLog: RecordLog = {
|
||||
new RecordLog(logDirectory, LOG_SUFFIX)
|
||||
}
|
||||
|
|
|
@ -528,7 +528,7 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P
|
|||
}
|
||||
|
||||
def size: Long = {
|
||||
return 0
|
||||
return db.client.size
|
||||
}
|
||||
|
||||
def checkpoint(sync: Boolean): Unit = db.checkpoint(sync)
|
||||
|
|
Loading…
Reference in New Issue