summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/DtxBuffer.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-04-20 17:11:23 +0000
committerGordon Sim <gsim@apache.org>2007-04-20 17:11:23 +0000
commit53605c52439daacf4a0d96a6bf4e9c95a7425b76 (patch)
tree7c57c4153a463439a8488968eee14415c6d55253 /cpp/src/qpid/broker/DtxBuffer.cpp
parent0a7a787a38f2761e21219bf99a8a2467dfac5eef (diff)
downloadqpid-python-53605c52439daacf4a0d96a6bf4e9c95a7425b76.tar.gz
Added some dtx related unit tests
Added support for suspend and resume git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@530853 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/DtxBuffer.cpp')
-rw-r--r--cpp/src/qpid/broker/DtxBuffer.cpp18
1 files changed, 17 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/DtxBuffer.cpp b/cpp/src/qpid/broker/DtxBuffer.cpp
index bdc326593a..2ffe744293 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() : ended(false) {}
+DtxBuffer::DtxBuffer(const std::string& _xid) : xid(_xid), ended(false), suspended(false) {}
DtxBuffer::~DtxBuffer() {}
@@ -38,3 +38,19 @@ bool DtxBuffer::isEnded()
Mutex::ScopedLock locker(lock);
return ended;
}
+
+void DtxBuffer::setSuspended(bool isSuspended)
+{
+ suspended = isSuspended;
+}
+
+bool DtxBuffer::isSuspended()
+{
+ return suspended;
+}
+
+const std::string& DtxBuffer::getXid()
+{
+ return xid;
+}
+