From dd86a8562275d411ba6af54b6651154b6abc08ef Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 5 Jun 2007 15:54:22 +0000 Subject: Some tests and fixes for dtx preview. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@544522 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/DtxBuffer.cpp | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/DtxBuffer.cpp') diff --git a/cpp/src/qpid/broker/DtxBuffer.cpp b/cpp/src/qpid/broker/DtxBuffer.cpp index 2ffe744293..7f816ebcf4 100644 --- a/cpp/src/qpid/broker/DtxBuffer.cpp +++ b/cpp/src/qpid/broker/DtxBuffer.cpp @@ -23,7 +23,7 @@ using namespace qpid::broker; using qpid::sys::Mutex; -DtxBuffer::DtxBuffer(const std::string& _xid) : xid(_xid), ended(false), suspended(false) {} +DtxBuffer::DtxBuffer(const std::string& _xid) : xid(_xid), ended(false), suspended(false), failed(false) {} DtxBuffer::~DtxBuffer() {} @@ -49,6 +49,20 @@ bool DtxBuffer::isSuspended() return suspended; } +void DtxBuffer::fail() +{ + Mutex::ScopedLock locker(lock); + rollback(); + failed = true; + ended = true; +} + +bool DtxBuffer::isRollbackOnly() +{ + Mutex::ScopedLock locker(lock); + return failed; +} + const std::string& DtxBuffer::getXid() { return xid; -- cgit v1.2.1