diff options
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/MessageAsyncContext.cpp')
-rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/MessageAsyncContext.cpp | 26 |
1 files changed, 14 insertions, 12 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageAsyncContext.cpp b/cpp/src/tests/storePerftools/asyncPerf/MessageAsyncContext.cpp index d88b6570a1..ad67bdd32f 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/MessageAsyncContext.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/MessageAsyncContext.cpp @@ -23,50 +23,52 @@ #include "MessageAsyncContext.h" +#include <cassert> + namespace tests { namespace storePerftools { namespace asyncPerf { -MessageContext::MessageContext(MockPersistableMessage::shared_ptr msg, - const qpid::asyncStore::AsyncOperation::opCode op, - MockPersistableQueue* q) : +MessageAsyncContext::MessageAsyncContext(boost::shared_ptr<MockPersistableMessage> msg, + const qpid::asyncStore::AsyncOperation::opCode op, + boost::shared_ptr<MockPersistableQueue> q) : m_msg(msg), m_op(op), m_q(q) { assert(m_msg.get() != 0); - assert(m_q != 0); + assert(m_q.get() != 0); } -MessageContext::~MessageContext() +MessageAsyncContext::~MessageAsyncContext() {} qpid::asyncStore::AsyncOperation::opCode -MessageContext::getOpCode() const +MessageAsyncContext::getOpCode() const { return m_op; } const char* -MessageContext::getOpStr() const +MessageAsyncContext::getOpStr() const { return qpid::asyncStore::AsyncOperation::getOpStr(m_op); } -MockPersistableMessage::shared_ptr -MessageContext::getMessage() const +boost::shared_ptr<MockPersistableMessage> +MessageAsyncContext::getMessage() const { return m_msg; } -MockPersistableQueue* -MessageContext::getQueue() const +boost::shared_ptr<MockPersistableQueue> +MessageAsyncContext::getQueue() const { return m_q; } void -MessageContext::destroy() +MessageAsyncContext::destroy() { delete this; } |