summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2012-07-20 12:55:20 +0000
committerKim van der Riet <kpvdr@apache.org>2012-07-20 12:55:20 +0000
commit2e437e1569009d8e8ed3ed896d751994e2e85d74 (patch)
tree28459e48638bfcd3a7e565c37165b3fab714d484 /cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h
parentc94c9b5333c06c03deb6a6dcb1a91ecdf111b481 (diff)
downloadqpid-python-2e437e1569009d8e8ed3ed896d751994e2e85d74.tar.gz
QPID-3858: WIP: Created many async operation classes for each op instead of a single class with op codes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1363759 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h')
-rw-r--r--cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h7
1 files changed, 1 insertions, 6 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h
index e3e87b8ad8..4e3d9fe2db 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h
@@ -49,18 +49,14 @@ class QueueAsyncContext: public qpid::broker::BrokerAsyncContext
public:
QueueAsyncContext(boost::shared_ptr<SimpleQueue> q,
qpid::broker::TxnHandle& th,
- const qpid::asyncStore::AsyncOperation::opCode op,
qpid::broker::AsyncResultCallback rcb,
qpid::broker::AsyncResultQueue* const arq);
QueueAsyncContext(boost::shared_ptr<SimpleQueue> q,
boost::intrusive_ptr<SimpleMessage> msg,
qpid::broker::TxnHandle& th,
- const qpid::asyncStore::AsyncOperation::opCode op,
qpid::broker::AsyncResultCallback rcb,
qpid::broker::AsyncResultQueue* const arq);
virtual ~QueueAsyncContext();
- qpid::asyncStore::AsyncOperation::opCode getOpCode() const;
- const char* getOpStr() const;
boost::shared_ptr<SimpleQueue> getQueue() const;
boost::intrusive_ptr<SimpleMessage> getMessage() const;
qpid::broker::TxnHandle getTxnHandle() const;
@@ -72,8 +68,7 @@ public:
private:
boost::shared_ptr<SimpleQueue> m_q;
boost::intrusive_ptr<SimpleMessage> m_msg;
- qpid::broker::TxnHandle m_th;
- const qpid::asyncStore::AsyncOperation::opCode m_op;
+ qpid::broker::TxnHandle m_th; // TODO: get rid of this
qpid::broker::AsyncResultCallback m_rcb;
qpid::broker::AsyncResultQueue* const m_arq;
};