From 5083cef28cd7d1f594a7632ffec109567f5a3b2b Mon Sep 17 00:00:00 2001
From: Kim van der Riet <kpvdr@apache.org>
Date: Tue, 19 Jun 2012 12:57:15 +0000
Subject: 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
---
 .../storePerftools/asyncPerf/SimplePersistableQueue.cpp      | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

(limited to 'cpp/src/tests/storePerftools')

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;
 }
 
-- 
cgit v1.2.1