diff options
| author | Alan Conway <aconway@apache.org> | 2013-08-01 20:56:29 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2013-08-01 20:56:29 +0000 |
| commit | 29cbd266bec2d0ae08c2995c921c474306218ffd (patch) | |
| tree | 5f76adbe5bbcecbf3002f519d9e400aa16f843a4 /cpp/src/qpid/ha/TxReplicator.cpp | |
| parent | 112503593af21b7b06522195404c68fd4e5d4861 (diff) | |
| download | qpid-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.cpp | 12 |
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); |
