From ed0d321d0ad56b9ea3d370d8b6b34fce2c8ef892 Mon Sep 17 00:00:00 2001
From: Alan Conway <aconway@apache.org>
Date: Tue, 12 Jun 2012 21:20:07 +0000
Subject: QPID-3603: Introduced RemoteBackup to track backup status.

The primary creates RemoteBackup object for each connected or expected
backup. On first being promoted, the new primary has a RemoteBackup
for each of the known backups at the time of the failure.

The RemoteBackup manages queue guards for its backup and
tracks it's readiness.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1349540 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/ha/Membership.cpp | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)

(limited to 'cpp/src/qpid/ha/Membership.cpp')

diff --git a/cpp/src/qpid/ha/Membership.cpp b/cpp/src/qpid/ha/Membership.cpp
index 6c6961f094..92436c9e56 100644
--- a/cpp/src/qpid/ha/Membership.cpp
+++ b/cpp/src/qpid/ha/Membership.cpp
@@ -19,6 +19,9 @@
  *
  */
 #include "Membership.h"
+#include <boost/bind.hpp>
+#include <iostream>
+#include <iterator>
 
 namespace qpid {
 namespace ha {
@@ -77,23 +80,26 @@ types::Variant::List Membership::asList(sys::Mutex::ScopedLock&) const {
 void Membership::update(sys::Mutex::ScopedLock& l) {
     if (updateCallback) {
         types::Variant::List list = asList(l);
-        IdSet ids = otherBackups(l);
         sys::Mutex::ScopedUnlock u(lock);
-        updateCallback(list, ids);
+        // FIXME aconway 2012-06-06: messy: Make this a data object,
+        // move locking into HaBroker?
+        updateCallback(list);
     }
+    QPID_LOG(debug, " HA: Membership update: " << brokers);
 }
 
-IdSet Membership::otherBackups() const {
+BrokerInfo::Set Membership::otherBackups() const {
     sys::Mutex::ScopedLock l(lock);
     return otherBackups(l);
 }
 
-IdSet Membership::otherBackups(sys::Mutex::ScopedLock&) const {
-    IdSet result;
+BrokerInfo::Set Membership::otherBackups(sys::Mutex::ScopedLock&) const {
+    BrokerInfo::Set result;
     for (BrokerMap::const_iterator i = brokers.begin(); i != brokers.end(); ++i)
         if (isBackup(i->second.getStatus()) && i->second.getSystemId() != self)
-            result.insert(i->second.getSystemId());
+            result.insert(i->second);
     return result;
 }
 
+
 }} // namespace qpid::ha
-- 
cgit v1.2.1