diff options
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp | 26 |
1 files changed, 22 insertions, 4 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp index 281fc03e2c..be0c087390 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp @@ -23,17 +23,29 @@ #include "QueueAsyncContext.h" +#include <cassert> + namespace tests { namespace storePerftools { namespace asyncPerf { -QueueAsyncContext::QueueAsyncContext(MockPersistableQueue::intrusive_ptr q, - const qpid::asyncStore::AsyncOperation::opCode op) : - qpid::broker::BrokerAsyncContext(), +QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<MockPersistableQueue> q, + const qpid::asyncStore::AsyncOperation::opCode op) : + m_q(q), + m_op(op) +{ + assert(m_q.get() != 0); +} + +QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<MockPersistableQueue> q, + boost::shared_ptr<MockPersistableMessage> msg, + const qpid::asyncStore::AsyncOperation::opCode op) : m_q(q), + m_msg(msg), m_op(op) { assert(m_q.get() != 0); + assert(m_msg.get() != 0); } QueueAsyncContext::~QueueAsyncContext() @@ -51,12 +63,18 @@ QueueAsyncContext::getOpStr() const return qpid::asyncStore::AsyncOperation::getOpStr(m_op); } -MockPersistableQueue::intrusive_ptr +boost::shared_ptr<MockPersistableQueue> QueueAsyncContext::getQueue() const { return m_q; } +boost::shared_ptr<MockPersistableMessage> +QueueAsyncContext::getMessage() const +{ + return m_msg; +} + void QueueAsyncContext::destroy() { |