summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2012-07-18 19:06:02 +0000
committerAlan Conway <aconway@apache.org>2012-07-18 19:06:02 +0000
commite6e9c66e515ca69e08e1882d266c9849a42670e3 (patch)
tree954b3c4d9d0e3efde29d63952bb71970cafcf3b7 /qpid/cpp/src
parentfb4e845bb1b914ebdc2941ad0adcb03fc47d0aeb (diff)
downloadqpid-python-e6e9c66e515ca69e08e1882d266c9849a42670e3.tar.gz
NO-JIRA: HA Minor logging improvements.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1363047 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/ha/HaBroker.cpp2
-rw-r--r--qpid/cpp/src/qpid/ha/Primary.cpp5
2 files changed, 3 insertions, 4 deletions
diff --git a/qpid/cpp/src/qpid/ha/HaBroker.cpp b/qpid/cpp/src/qpid/ha/HaBroker.cpp
index a0502b94ae..a4e7c94ca6 100644
--- a/qpid/cpp/src/qpid/ha/HaBroker.cpp
+++ b/qpid/cpp/src/qpid/ha/HaBroker.cpp
@@ -288,7 +288,7 @@ void HaBroker::setMembership(const Variant::List& brokers) {
membership.assign(brokers);
QPID_LOG(debug, logPrefix << "Membership update: " << membership);
BrokerInfo info;
- // Update my status to what the primary thinks.
+ // Update my status to what the primary says.
if (membership.get(systemId, info) && status != info.getStatus())
setStatus(info.getStatus(), l);
membershipUpdated(brokers);
diff --git a/qpid/cpp/src/qpid/ha/Primary.cpp b/qpid/cpp/src/qpid/ha/Primary.cpp
index 2a3eb86b64..08e2379097 100644
--- a/qpid/cpp/src/qpid/ha/Primary.cpp
+++ b/qpid/cpp/src/qpid/ha/Primary.cpp
@@ -129,11 +129,10 @@ void Primary::checkReady(Mutex::ScopedLock&) {
void Primary::checkReady(BackupMap::iterator i, Mutex::ScopedLock& l) {
if (i != backups.end() && i->second->isReady()) {
BrokerInfo info = i->second->getBrokerInfo();
- QPID_LOG(info, "Expected backup is ready: " << info);
info.setStatus(READY);
+ QPID_LOG(info, "Expected backup is ready: " << info);
haBroker.addBroker(info);
- expectedBackups.erase(i->second);
- checkReady(l);
+ if (expectedBackups.erase(i->second)) checkReady(l);
}
}