diff options
author | Kim van der Riet <kpvdr@apache.org> | 2012-05-11 12:19:07 +0000 |
---|---|---|
committer | Kim van der Riet <kpvdr@apache.org> | 2012-05-11 12:19:07 +0000 |
commit | a3861c46a7151a250fd06f54a60b9c1fe4bd6a1e (patch) | |
tree | 05da4567a96e4e3461f7aae7c76494d8111cd3b4 /cpp/src/tests/storePerfTools/asyncPerf/PerfTest.h | |
parent | 7ed6d96613a02d53a34a5c8e8d524a0b3c19d83d (diff) | |
download | qpid-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.h | 11 |
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(); }; |