summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/TxnBuffer.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/TxnBuffer.h')
-rw-r--r--cpp/src/qpid/broker/TxnBuffer.h14
1 files changed, 6 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/TxnBuffer.h b/cpp/src/qpid/broker/TxnBuffer.h
index ea8b73407f..cd78846b71 100644
--- a/cpp/src/qpid/broker/TxnBuffer.h
+++ b/cpp/src/qpid/broker/TxnBuffer.h
@@ -26,7 +26,8 @@
#include "TxnHandle.h"
-//#include <boost/enable_shared_from_this.hpp>
+#include "qpid/sys/Mutex.h"
+
#include <boost/shared_ptr.hpp>
#include <vector>
@@ -35,10 +36,10 @@ namespace broker {
class AsyncResultHandle;
class AsyncResultQueue;
-class AsyncTransactionalStore;
+class AsyncTransaction;
class TxnOp;
-class TxnBuffer /*: public boost::enable_shared_from_this<TxnBuffer>*/ {
+class TxnBuffer {
public:
TxnBuffer(AsyncResultQueue& arq);
virtual ~TxnBuffer();
@@ -47,21 +48,18 @@ public:
bool prepare(TxnHandle& th);
void commit();
void rollback();
- bool commitLocal(AsyncTransactionalStore* const store);
+ bool commitLocal(AsyncTransaction* const store);
// --- Async operations ---
static void handleAsyncResult(const AsyncResultHandle* const arh);
void asyncLocalCommit();
void asyncLocalAbort();
- // --- Debug ---
- //void printState(std::ostream& os);
-
private:
std::vector<boost::shared_ptr<TxnOp> > m_ops;
qpid::sys::Mutex m_opsMutex;
TxnHandle m_txnHandle;
- AsyncTransactionalStore* m_store;
+ AsyncTransaction* m_store;
AsyncResultQueue& m_resultQueue;
typedef enum {NONE = 0, PREPARE, COMMIT, ROLLBACK, COMPLETE} e_txnState;