From daabda5eff2a7e37a5669219d949f7ad646f6442 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Mon, 23 Dec 2013 16:57:56 +0000 Subject: QPID-5444: Recovering from qpid-txtest fails with "Inconsisntent TPL 2PC count" error message git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1553148 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/linearstore/MessageStoreImpl.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'cpp/src/qpid/linearstore/MessageStoreImpl.cpp') diff --git a/cpp/src/qpid/linearstore/MessageStoreImpl.cpp b/cpp/src/qpid/linearstore/MessageStoreImpl.cpp index dd4198c6fd..ca71d1b780 100644 --- a/cpp/src/qpid/linearstore/MessageStoreImpl.cpp +++ b/cpp/src/qpid/linearstore/MessageStoreImpl.cpp @@ -641,7 +641,7 @@ void MessageStoreImpl::recover(qpid::broker::RecoveryManager& registry_) ++tpcCnt; } } - if (tpcCnt > 0 && tpcCnt != tdl.size()) THROW_STORE_EXCEPTION("Inconsistent TPL 2PC count"); + if (tpcCnt > 0 && tpcCnt != tdl.size()) THROW_STORE_EXCEPTION("MessageStoreImpl::recover(): Inconsistent TPL 2PC count"); bool commitFlag = abortCnt == 0; // If a record is found that is dequeued but not committed/aborted from tplStore, then a complete() call @@ -963,7 +963,7 @@ void MessageStoreImpl::recoverMessages(TxnCtxt& /*txn*/, ++tpcCnt; } } - if (tpcCnt > 0 && tpcCnt != tdl.size()) THROW_STORE_EXCEPTION("Inconsistent TPL 2PC count"); + if (tpcCnt > 0 && tpcCnt != tdl.size()) THROW_STORE_EXCEPTION("MessageStoreImpl::recoverMessages(): Inconsistent TPL 2PC count"); if (deqCnt > 0 || tpcCnt == 0) { if (jc->is_enqueued(rid, true)) { // Enqueue is non-tx, dequeue tx @@ -1120,7 +1120,7 @@ void MessageStoreImpl::collectPreparedXids(std::set& xids) } } if (tpcCnt > 0) { - if (tpcCnt != tdl.size()) THROW_STORE_EXCEPTION("Inconsistent TPL 2PC count"); + if (tpcCnt != tdl.size()) THROW_STORE_EXCEPTION("MessageStoreImpl::collectPreparedXids: Inconsistent TPL 2PC count"); if (enqCnt - deqCnt > 0) { xids.insert(*i); } -- cgit v1.2.1