summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/ha/Primary.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2014-01-27 20:35:02 +0000
committerAlan Conway <aconway@apache.org>2014-01-27 20:35:02 +0000
commit344fe63e0f7628420cc639cd44e4c315a9ec370b (patch)
treee41913f8778b00eb65553efe4adbbcc52d02ae30 /qpid/cpp/src/qpid/ha/Primary.cpp
parentb710193d135c55357d3333bd55a733a49c361632 (diff)
downloadqpid-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.cpp12
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