diff options
Diffstat (limited to 'cpp/src/qpid/asyncStore/TxnHandleImpl.cpp')
| -rw-r--r-- | cpp/src/qpid/asyncStore/TxnHandleImpl.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/asyncStore/TxnHandleImpl.cpp b/cpp/src/qpid/asyncStore/TxnHandleImpl.cpp index 945b50861d..af3a8f01cf 100644 --- a/cpp/src/qpid/asyncStore/TxnHandleImpl.cpp +++ b/cpp/src/qpid/asyncStore/TxnHandleImpl.cpp @@ -89,12 +89,14 @@ TxnHandleImpl::is2pc() const void TxnHandleImpl::incrOpCnt() { + qpid::sys::ScopedLock<qpid::sys::Mutex> l(m_asyncOpCntMutex); ++m_asyncOpCnt; } void TxnHandleImpl::decrOpCnt() { + qpid::sys::ScopedLock<qpid::sys::Mutex> l(m_asyncOpCntMutex); if (m_asyncOpCnt == 0UL) { throw qpid::Exception("Transaction async operation count underflow"); } |