Cluster: debug snapshots of queue depth at broker join, help find inconsistencies.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@905674 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 5 deletions

diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h
index 977c873e29..ffb870606a 100644
--- a/cpp/src/qpid/cluster/Cluster.h
+++ b/cpp/src/qpid/cluster/Cluster.h
@@ -120,6 +120,9 @@ class Cluster : private Cpg::Handler, public management::Manageable {
 
     bool isElder() const;
 
+    // For debugging only. Can only be called in deliver thread.
+    void debugSnapshot(const char*, Connection* =0);
+
   private:
     typedef sys::Monitor::ScopedLock Lock;
 
@@ -178,10 +181,8 @@ class Cluster : private Cpg::Handler, public management::Manageable {
     void memberUpdate(Lock&);
     void setClusterId(const framing::Uuid&, Lock&);
     void erase(const ConnectionId&, Lock&);       
-
     void initMapCompleted(Lock&);
-
-
+    void becomeElder(Lock&);
 
     // == Called in CPG dispatch thread
     void deliver( // CPG deliver callback. 
@@ -202,8 +203,6 @@ class Cluster : private Cpg::Handler, public management::Manageable {
         const struct cpg_address */*joined*/, int /*nJoined*/
     );
 
-    void becomeElder();
-
     // == Called in management threads.
     virtual qpid::management::ManagementObject* GetManagementObject() const;
     virtual management::Manageable::status_t ManagementMethod (uint32_t methodId, management::Args& args, std::string& text);