QPID-3858: WIP: Solved race conditions affecting transactional publishing.

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1351689 13f79535-47bb-0310-9956-ffa450edef68

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;
 }