diff options
Diffstat (limited to 'cpp/src/tests')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp b/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp index 1a3eae4b43..be2b4c891b 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp @@ -354,13 +354,13 @@ SimplePersistableQueue::asyncEnqueue(qpid::broker::TxnHandle& th, qpid::asyncStore::AsyncOperation::MSG_ENQUEUE, &handleAsyncResult, &m_resultQueue)); + if (th.isValid()) { + th.incrOpCnt(); + } m_store->submitEnqueue(qm.enqHandle(), th, qac); ++m_asyncOpCounter; - if (th.isValid()) { - th.incrOpCnt(); - } return true; } @@ -376,13 +376,13 @@ SimplePersistableQueue::asyncDequeue(qpid::broker::TxnHandle& th, qpid::asyncStore::AsyncOperation::MSG_DEQUEUE, &handleAsyncResult, &m_resultQueue)); + if (th.isValid()) { + th.incrOpCnt(); + } m_store->submitDequeue(qm.enqHandle(), th, qac); ++m_asyncOpCounter; - if (th.isValid()) { - th.incrOpCnt(); - } return true; } |