summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2012-05-11 12:19:07 +0000
committerKim van der Riet <kpvdr@apache.org>2012-05-11 12:19:07 +0000
commita3861c46a7151a250fd06f54a60b9c1fe4bd6a1e (patch)
tree05da4567a96e4e3461f7aae7c76494d8111cd3b4 /cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h
parent7ed6d96613a02d53a34a5c8e8d524a0b3c19d83d (diff)
downloadqpid-python-a3861c46a7151a250fd06f54a60b9c1fe4bd6a1e.tar.gz
QPID-3858: Added async queue deletion and mechanism to correctly wait for async completion of store deletion before destroying queue objects
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1337126 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h')
-rw-r--r--cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h11
1 files changed, 6 insertions, 5 deletions
diff --git a/cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h b/cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h
index 1eb11a51fa..544cd6b3ae 100644
--- a/cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h
+++ b/cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h
@@ -48,7 +48,7 @@ namespace asyncPerf {
class MockPersistableQueue;
class TestOptions;
-typedef boost::shared_ptr<qpid::asyncStore::AsyncStoreImpl> AsyncStoreImplPtr;
+//typedef boost::shared_ptr<qpid::asyncStore::AsyncStoreImpl> AsyncStoreImplPtr;
typedef boost::shared_ptr<MockPersistableQueue> MockPersistableQueuePtr;
class PerfTest : public tests::storePerftools::common::Streamable
@@ -68,11 +68,12 @@ protected:
const char* m_msgData;
boost::shared_ptr<qpid::sys::Poller> m_poller;
qpid::sys::Thread m_pollingThread;
+ qpid::asyncStore::AsyncStoreImpl* m_store;
+ std::deque<MockPersistableQueuePtr> m_queueList;
- AsyncStoreImplPtr prepareStore();
- void prepareQueues(std::deque<MockPersistableQueuePtr>& jrnlList,
- AsyncStoreImplPtr store);
- void destroyQueues(std::deque<MockPersistableQueuePtr>& jrnlList);
+ void prepareStore();
+ void prepareQueues();
+ void destroyQueues();
};