diff options
author | Alan Conway <aconway@apache.org> | 2014-01-27 20:35:02 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2014-01-27 20:35:02 +0000 |
commit | 344fe63e0f7628420cc639cd44e4c315a9ec370b (patch) | |
tree | e41913f8778b00eb65553efe4adbbcc52d02ae30 /qpid/cpp/src/qpid/ha/Primary.cpp | |
parent | b710193d135c55357d3333bd55a733a49c361632 (diff) | |
download | qpid-python-344fe63e0f7628420cc639cd44e4c315a9ec370b.tar.gz |
NO-JIRA: Minor rationalization of log statement priorities.
Demote "backup of queue x connected to y" from info to debug.
Tighten up redundant 'notice' messages around promotion of primary.
Promote 'DTX not implemented' to warning
Misc. other minor adjustments.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1561833 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/ha/Primary.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/ha/Primary.cpp | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/qpid/cpp/src/qpid/ha/Primary.cpp b/qpid/cpp/src/qpid/ha/Primary.cpp index 081fd7b6c7..3bb51b1813 100644 --- a/qpid/cpp/src/qpid/ha/Primary.cpp +++ b/qpid/cpp/src/qpid/ha/Primary.cpp @@ -105,14 +105,12 @@ Primary::Primary(HaBroker& hb, const BrokerInfo::Set& expect) : QueueReplicator::copy(hb.getBroker().getExchanges(), qrs); std::for_each(qrs.begin(), qrs.end(), boost::bind(&QueueReplicator::promoted, _1)); - if (expect.empty()) { - QPID_LOG(notice, logPrefix << "Promoted to primary. No expected backups."); - } - else { + if (!expect.empty()) { // NOTE: RemoteBackups must be created before we set the BrokerObserver // or ConnectionObserver so that there is no client activity while // the QueueGuards are created. - QPID_LOG(notice, logPrefix << "Promoted to primary. Expected backups: " << expect); + QPID_LOG(notice, logPrefix << "Promoted and recovering, waiting for backups: " + << expect); for (BrokerInfo::Set::const_iterator i = expect.begin(); i != expect.end(); ++i) { boost::shared_ptr<RemoteBackup> backup(new RemoteBackup(*i, 0)); backups[i->getSystemId()] = backup; @@ -147,7 +145,7 @@ void Primary::checkReady() { activate = active = true; } if (activate) { - QPID_LOG(notice, logPrefix << "Finished waiting for backups, primary is active."); + QPID_LOG(notice, logPrefix << "Promoted and active."); membership.setStatus(ACTIVE); // Outside of lock. } } @@ -419,7 +417,7 @@ void Primary::startTx(const boost::intrusive_ptr<broker::TxBuffer>& txBuffer) { } void Primary::startDtx(const boost::intrusive_ptr<broker::DtxBuffer>& ) { - QPID_LOG(notice, "DTX transactions in a HA cluster are not yet atomic"); + QPID_LOG(warning, "DTX transactions in a HA cluster are not yet atomic"); } }} // namespace qpid::ha |