diff options
Diffstat (limited to 'cpp/src/qpid/broker/DtxBuffer.cpp')
-rw-r--r-- | cpp/src/qpid/broker/DtxBuffer.cpp | 22 |
1 files changed, 7 insertions, 15 deletions
diff --git a/cpp/src/qpid/broker/DtxBuffer.cpp b/cpp/src/qpid/broker/DtxBuffer.cpp index 13177d3b72..f1b8169cf7 100644 --- a/cpp/src/qpid/broker/DtxBuffer.cpp +++ b/cpp/src/qpid/broker/DtxBuffer.cpp @@ -23,11 +23,8 @@ using namespace qpid::broker; using qpid::sys::Mutex; -DtxBuffer::DtxBuffer( - const std::string& _xid, - bool ended_, bool suspended_, bool failed_, bool expired_) - : xid(_xid), ended(ended_), suspended(suspended_), failed(failed_), expired(expired_) -{} +DtxBuffer::DtxBuffer(const std::string& _xid) + : xid(_xid), ended(false), suspended(false), failed(false), expired(false) {} DtxBuffer::~DtxBuffer() {} @@ -37,7 +34,7 @@ void DtxBuffer::markEnded() ended = true; } -bool DtxBuffer::isEnded() const +bool DtxBuffer::isEnded() { Mutex::ScopedLock locker(lock); return ended; @@ -48,7 +45,7 @@ void DtxBuffer::setSuspended(bool isSuspended) suspended = isSuspended; } -bool DtxBuffer::isSuspended() const +bool DtxBuffer::isSuspended() { return suspended; } @@ -61,13 +58,13 @@ void DtxBuffer::fail() ended = true; } -bool DtxBuffer::isRollbackOnly() const +bool DtxBuffer::isRollbackOnly() { Mutex::ScopedLock locker(lock); return failed; } -std::string DtxBuffer::getXid() const +const std::string& DtxBuffer::getXid() { return xid; } @@ -79,13 +76,8 @@ void DtxBuffer::timedout() fail(); } -bool DtxBuffer::isExpired() const +bool DtxBuffer::isExpired() { Mutex::ScopedLock locker(lock); return expired; } - -bool DtxBuffer::isFailed() const -{ - return failed; -} |