activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject git commit: Fix for: https://issues.apache.org/jira/browse/AMQ-4837 : LevelDB corrupted in AMQ cluster.
Date Fri, 01 Nov 2013 16:13:38 GMT
Updated Branches:
  refs/heads/trunk ec4c2d946 -> 190da2969


Fix for: https://issues.apache.org/jira/browse/AMQ-4837 : LevelDB corrupted in AMQ cluster.

- The tracked flushed offset was not getting initialized to match the initial size of the
log file.  This invalid flushed offset was being used to do the initial sync /w the slave
and then things went downhill.


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/190da296
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/190da296
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/190da296

Branch: refs/heads/trunk
Commit: 190da29691cbebaf8bd315ad6b8be02f64cbb6b2
Parents: ec4c2d9
Author: Hiram Chirino <hiram@hiramchirino.com>
Authored: Fri Nov 1 12:08:19 2013 -0400
Committer: Hiram Chirino <hiram@hiramchirino.com>
Committed: Fri Nov 1 12:13:33 2013 -0400

----------------------------------------------------------------------
 .../src/main/scala/org/apache/activemq/leveldb/RecordLog.scala     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/190da296/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
----------------------------------------------------------------------
diff --git a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
index 1dc94aa..d35becd 100644
--- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
+++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
@@ -118,7 +118,7 @@ case class RecordLog(directory: File, logSuffix:String) {
       force
     }
 
-    val flushed_offset = new AtomicLong(0)
+    val flushed_offset = new AtomicLong(append_offset)
 
     def append_position = {
       position+append_offset


Mime
View raw message