From 63c6598f401ac6406e5a31c602c7892b798536fc Mon Sep 17 00:00:00 2001
From: Kim van der Riet <kpvdr@apache.org>
Date: Tue, 31 Jul 2012 13:35:53 +0000
Subject: QPID-3858: WIP: Durable transactions fixed

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1367535 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/broker/QueueAsyncContext.cpp | 32 +++++++++++++++++++++++--------
 1 file changed, 24 insertions(+), 8 deletions(-)

(limited to 'cpp/src/qpid/broker/QueueAsyncContext.cpp')

diff --git a/cpp/src/qpid/broker/QueueAsyncContext.cpp b/cpp/src/qpid/broker/QueueAsyncContext.cpp
index 54a10c9c0e..4bd2d271eb 100644
--- a/cpp/src/qpid/broker/QueueAsyncContext.cpp
+++ b/cpp/src/qpid/broker/QueueAsyncContext.cpp
@@ -29,13 +29,30 @@
 
 namespace qpid {
 namespace broker {
+QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<PersistableQueue> q,
+                                     AsyncResultCallback rcb,
+                                     AsyncResultQueue* const arq) :
+        m_q(q),
+        m_rcb(rcb),
+        m_arq(arq)
+{}
+
+QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<PersistableQueue> q,
+                                     boost::intrusive_ptr<PersistableMessage> msg,
+                                     AsyncResultCallback rcb,
+                                     AsyncResultQueue* const arq) :
+        m_q(q),
+        m_msg(msg),
+        m_rcb(rcb),
+        m_arq(arq)
+{}
 
 QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<PersistableQueue> q,
-                                     TxnHandle& th,
+                                     TxnBuffer* tb,
                                      AsyncResultCallback rcb,
                                      AsyncResultQueue* const arq) :
         m_q(q),
-        m_th(th),
+        m_tb(tb),
         m_rcb(rcb),
         m_arq(arq)
 {
@@ -44,12 +61,12 @@ QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<PersistableQueue> q,
 
 QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<PersistableQueue> q,
                                      boost::intrusive_ptr<PersistableMessage> msg,
-                                     TxnHandle& th,
+                                     TxnBuffer* tb,
                                      AsyncResultCallback rcb,
                                      AsyncResultQueue* const arq) :
         m_q(q),
         m_msg(msg),
-        m_th(th),
+        m_tb(tb),
         m_rcb(rcb),
         m_arq(arq)
 {
@@ -72,10 +89,9 @@ QueueAsyncContext::getMessage() const
     return m_msg;
 }
 
-TxnHandle
-QueueAsyncContext::getTxnHandle() const
-{
-    return m_th;
+TxnBuffer*
+QueueAsyncContext::getTxnBuffer() const {
+    return m_tb;
 }
 
 AsyncResultQueue*
-- 
cgit v1.2.1