diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-06-15 19:21:07 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-06-15 19:21:07 +0000 |
| commit | 58337ca40df3a57a16cdee9b7f6b4fe0361b0018 (patch) | |
| tree | 391ad7ad1ea8cd42a7e9d4890c724b186e00f38b /cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h | |
| parent | 01174a9e568f11cd5aa4f22aaa914e00ab9fe163 (diff) | |
| download | qpid-python-58337ca40df3a57a16cdee9b7f6b4fe0361b0018.tar.gz | |
QPID-3858: WIP - async txns for msg publish pathway, but there are some race/thread issues to sort out.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1350745 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h index df45117fe4..b4d16fe615 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h +++ b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.h @@ -26,6 +26,7 @@ #include "qpid/asyncStore/AsyncOperation.h" #include "qpid/broker/AsyncStore.h" +#include "qpid/broker/TxnHandle.h" #include <boost/intrusive_ptr.hpp> #include <boost/shared_ptr.hpp> @@ -42,11 +43,13 @@ class QueueAsyncContext: public qpid::broker::BrokerAsyncContext { public: QueueAsyncContext(boost::shared_ptr<SimplePersistableQueue> q, + qpid::broker::TxnHandle& th, const qpid::asyncStore::AsyncOperation::opCode op, qpid::broker::AsyncResultCallback rcb, qpid::broker::AsyncResultQueue* const arq); QueueAsyncContext(boost::shared_ptr<SimplePersistableQueue> q, boost::intrusive_ptr<SimplePersistableMessage> msg, + qpid::broker::TxnHandle& th, const qpid::asyncStore::AsyncOperation::opCode op, qpid::broker::AsyncResultCallback rcb, qpid::broker::AsyncResultQueue* const arq); @@ -55,6 +58,7 @@ public: const char* getOpStr() const; boost::shared_ptr<SimplePersistableQueue> getQueue() const; boost::intrusive_ptr<SimplePersistableMessage> getMessage() const; + qpid::broker::TxnHandle getTxnHandle() const; qpid::broker::AsyncResultQueue* getAsyncResultQueue() const; qpid::broker::AsyncResultCallback getAsyncResultCallback() const; void invokeCallback(const qpid::broker::AsyncResultHandle* const arh) const; @@ -63,6 +67,7 @@ public: private: boost::shared_ptr<SimplePersistableQueue> m_q; boost::intrusive_ptr<SimplePersistableMessage> m_msg; + qpid::broker::TxnHandle m_th; const qpid::asyncStore::AsyncOperation::opCode m_op; qpid::broker::AsyncResultCallback m_rcb; qpid::broker::AsyncResultQueue* const m_arq; |