summaryrefslogtreecommitdiff
path: root/cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2012-12-19 21:23:07 +0000
committerAlan Conway <aconway@apache.org>2012-12-19 21:23:07 +0000
commitd60658d124e1a74627f451b4fa0772a119f183ca (patch)
tree53325137464e86451ae561eed5888ce8d3b19e61 /cpp
parent90cdec5bc8060ebddaee4bbbb934b861e6bf749e (diff)
downloadqpid-python-d60658d124e1a74627f451b4fa0772a119f183ca.tar.gz
QPID-4514: Remove obsolete cluster code: DtxWorkRecord
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1424127 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
-rw-r--r--cpp/src/qpid/broker/DtxWorkRecord.cpp14
-rw-r--r--cpp/src/qpid/broker/DtxWorkRecord.h6
2 files changed, 0 insertions, 20 deletions
diff --git a/cpp/src/qpid/broker/DtxWorkRecord.cpp b/cpp/src/qpid/broker/DtxWorkRecord.cpp
index 2c26fec49f..2c7df95fc6 100644
--- a/cpp/src/qpid/broker/DtxWorkRecord.cpp
+++ b/cpp/src/qpid/broker/DtxWorkRecord.cpp
@@ -176,17 +176,3 @@ void DtxWorkRecord::timedout()
}
abort();
}
-
-size_t DtxWorkRecord::indexOf(const DtxBuffer::shared_ptr& buf) {
- Work::iterator i = std::find(work.begin(), work.end(), buf);
- if (i == work.end()) throw NotFoundException(
- QPID_MSG("Can't find DTX buffer for xid: " << buf->getXid()));
- return i - work.begin();
-}
-
-DtxBuffer::shared_ptr DtxWorkRecord::operator[](size_t i) const {
- if (i > work.size())
- throw NotFoundException(
- QPID_MSG("Can't find DTX buffer " << i << " for xid: " << xid));
- return work[i];
-}
diff --git a/cpp/src/qpid/broker/DtxWorkRecord.h b/cpp/src/qpid/broker/DtxWorkRecord.h
index 331e42fefd..4a34c079dd 100644
--- a/cpp/src/qpid/broker/DtxWorkRecord.h
+++ b/cpp/src/qpid/broker/DtxWorkRecord.h
@@ -78,12 +78,6 @@ public:
bool isRolledback() const { return rolledback; }
bool isPrepared() const { return prepared; }
bool isExpired() const { return expired; }
-
- // Used by cluster update;
- size_t size() const { return work.size(); }
- DtxBuffer::shared_ptr operator[](size_t i) const;
- uint32_t getTimeout() const { return timeout? timeout->timeout : 0; }
- size_t indexOf(const DtxBuffer::shared_ptr&);
};
}} // qpid::broker