diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-05-14 15:50:27 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-05-14 15:50:27 +0000 |
| commit | 22c507ad66f2101c6d3f46207344746ec3b6e36c (patch) | |
| tree | 46b3a7c916e26ca55c6aa6cc15873661ce8b1002 /cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp | |
| parent | 1416b27f148e334d2751ff9a7cf59d6b0f022a14 (diff) | |
| download | qpid-python-22c507ad66f2101c6d3f46207344746ec3b6e36c.tar.gz | |
QPID-3858: More restructuring: extracted MessageContext from MockPersistableMessage, also TransactionAsyncContext from MockTransactionContext. Further name changes will be needed to resolve some bad naming.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1338262 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp b/cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp index aa55ee5a7e..e607649cc7 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/MockPersistableQueue.cpp @@ -23,6 +23,7 @@ #include "MockPersistableQueue.h" +#include "MessageContext.h" #include "MockPersistableMessage.h" #include "MockTransactionContext.h" #include "QueueContext.h" @@ -129,12 +130,12 @@ MockPersistableQueue::runEnqueues() if (useTxn && txnCnt == 0) { txn.reset(new MockTransactionContext(m_store)); // equivalent to begin() } - MockPersistableMessagePtr msg(new MockPersistableMessage(m_msgData, m_perfTestOpts.m_msgSize, m_store, true)); + MockPersistableMessage::shared_ptr msg(new MockPersistableMessage(m_msgData, m_perfTestOpts.m_msgSize, m_store, true)); msg->setPersistenceId(m_store->getNextRid()); qpid::broker::EnqueueHandle enqHandle = m_store->createEnqueueHandle(msg->getHandle(), m_queueHandle); - MockPersistableMessage::MessageContext* msgCtxt = new MockPersistableMessage::MessageContext(msg, - qpid::asyncStore::AsyncOperation::MSG_ENQUEUE, - this); + MessageContext* msgCtxt = new MessageContext(msg, + qpid::asyncStore::AsyncOperation::MSG_ENQUEUE, + this); if (useTxn) { m_store->submitEnqueue(enqHandle, txn->getHandle(), @@ -176,9 +177,9 @@ MockPersistableQueue::runDequeues() pop(qm); if (qm.get()) { qpid::broker::EnqueueHandle enqHandle = qm->getEnqueueHandle(); - qpid::broker::BrokerContext* bc = new MockPersistableMessage::MessageContext(qm->getMessage(), - qpid::asyncStore::AsyncOperation::MSG_DEQUEUE, - this); + qpid::broker::BrokerContext* bc = new MessageContext(qm->getMessage(), + qpid::asyncStore::AsyncOperation::MSG_DEQUEUE, + this); if (useTxn) { m_store->submitDequeue(enqHandle, txn->getHandle(), |