summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/ha/TxReplicator.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2013-08-01 20:56:29 +0000
committerAlan Conway <aconway@apache.org>2013-08-01 20:56:29 +0000
commit29cbd266bec2d0ae08c2995c921c474306218ffd (patch)
tree5f76adbe5bbcecbf3002f519d9e400aa16f843a4 /cpp/src/qpid/ha/TxReplicator.cpp
parent112503593af21b7b06522195404c68fd4e5d4861 (diff)
downloadqpid-python-29cbd266bec2d0ae08c2995c921c474306218ffd.tar.gz
QPID-4327: HA logging fixes.
- Removed "FIXME" log statements inadvertently left in code. - Changed some trace statements to debug to faclilitate debugging. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1509428 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/ha/TxReplicator.cpp')
-rw-r--r--cpp/src/qpid/ha/TxReplicator.cpp12
1 files changed, 4 insertions, 8 deletions
diff --git a/cpp/src/qpid/ha/TxReplicator.cpp b/cpp/src/qpid/ha/TxReplicator.cpp
index 58963149fc..0a524c8ced 100644
--- a/cpp/src/qpid/ha/TxReplicator.cpp
+++ b/cpp/src/qpid/ha/TxReplicator.cpp
@@ -199,30 +199,26 @@ boost::shared_ptr<TxAccept> TxReplicator::DequeueState::makeAccept() {
}
void TxReplicator::prepare(const string&, sys::Mutex::ScopedLock& l) {
- QPID_LOG(trace, logPrefix << "Prepare");
txBuffer->enlist(dequeueState.makeAccept());
context = store->begin();
if (txBuffer->prepare(context.get())) {
- QPID_LOG(trace, logPrefix << "Prepared OK");
- QPID_LOG(critical, logPrefix << "FIXME Prepared OK " << haBroker.getSystemId());
- QPID_LOG(critical, logPrefix << "FIXME Prepared ok "<<
- encodeStr(TxPrepareOkEvent(haBroker.getSystemId())));
+ QPID_LOG(debug, logPrefix << "Prepared OK");
sendMessage(TxPrepareOkEvent(haBroker.getSystemId()).message(queue->getName()), l);
} else {
- QPID_LOG(trace, logPrefix << "Prepare failed");
+ QPID_LOG(debug, logPrefix << "Prepare failed");
sendMessage(TxPrepareFailEvent(haBroker.getSystemId()).message(queue->getName()), l);
}
}
void TxReplicator::commit(const string&, sys::Mutex::ScopedLock& l) {
- QPID_LOG(trace, logPrefix << "Commit");
+ QPID_LOG(debug, logPrefix << "Commit");
if (context.get()) store->commit(*context);
txBuffer->commit();
end(l);
}
void TxReplicator::rollback(const string&, sys::Mutex::ScopedLock& l) {
- QPID_LOG(trace, logPrefix << "Rollback");
+ QPID_LOG(debug, logPrefix << "Rollback");
if (context.get()) store->abort(*context);
txBuffer->rollback();
end(l);