activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject git commit: Adding more debug info to help trouble shoot election issues with leveldb replication elections.
Date Wed, 02 Oct 2013 14:46:03 GMT
Updated Branches:
  refs/heads/trunk 887ac0ba4 -> 8804341c1


Adding more debug info to help trouble shoot election issues with leveldb replication elections.


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

Branch: refs/heads/trunk
Commit: 8804341c19f7f9450f22cef8fb842ffab31b5e5f
Parents: 887ac0b
Author: Hiram Chirino <hiram@hiramchirino.com>
Authored: Wed Oct 2 10:45:47 2013 -0400
Committer: Hiram Chirino <hiram@hiramchirino.com>
Committed: Wed Oct 2 10:45:58 2013 -0400

----------------------------------------------------------------------
 .../apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala  | 2 ++
 .../org/apache/activemq/leveldb/replicated/MasterElector.scala     | 2 ++
 2 files changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/8804341c/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
----------------------------------------------------------------------
diff --git a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
index 368ea96..4595a1b 100644
--- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
+++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
@@ -181,7 +181,9 @@ class ElectingLevelDBStore extends ProxyLevelDBStore {
 
     val zk_group = ZooKeeperGroupFactory.create(zk_client, zkPath)
     val master_elector = new MasterElector(this)
+    debug("Starting ZooKeeper group monitor")
     master_elector.start(zk_group)
+    debug("Joining ZooKeeper group")
     master_elector.join
 
     this.setUseLock(true)

http://git-wip-us.apache.org/repos/asf/activemq/blob/8804341c/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
----------------------------------------------------------------------
diff --git a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
index b5d8e10..84f93d0 100644
--- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
+++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
@@ -90,6 +90,8 @@ class MasterElector(store: ElectingLevelDBStore) extends ClusteredSingleton[Leve
     }
 
     def changed:Unit = elector.synchronized {
+      debug("ZooKeeper group changed: %s", members)
+
 //      info(eid+" cluster state changed: "+members)
       if (isMaster) {
         // We are the master elector, we will choose which node will startup the MasterLevelDBStore


Mime
View raw message