summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/asyncStore/TxnHandleImpl.h
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2012-07-31 13:35:53 +0000
committerKim van der Riet <kpvdr@apache.org>2012-07-31 13:35:53 +0000
commit63c6598f401ac6406e5a31c602c7892b798536fc (patch)
tree73b3c1a519ada213c9e117244aab99d2e64d4f2a /cpp/src/qpid/asyncStore/TxnHandleImpl.h
parentb435b07eb8fa9db484f85b39daaf43642dd623ca (diff)
downloadqpid-python-63c6598f401ac6406e5a31c602c7892b798536fc.tar.gz
QPID-3858: WIP: Durable transactions fixed
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1367535 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/asyncStore/TxnHandleImpl.h')
-rw-r--r--cpp/src/qpid/asyncStore/TxnHandleImpl.h14
1 files changed, 2 insertions, 12 deletions
diff --git a/cpp/src/qpid/asyncStore/TxnHandleImpl.h b/cpp/src/qpid/asyncStore/TxnHandleImpl.h
index 9452044d66..e1f8afff3e 100644
--- a/cpp/src/qpid/asyncStore/TxnHandleImpl.h
+++ b/cpp/src/qpid/asyncStore/TxnHandleImpl.h
@@ -43,26 +43,16 @@ class TxnHandleImpl : public virtual qpid::RefCounted
public:
TxnHandleImpl();
TxnHandleImpl(qpid::broker::TxnBuffer* tb);
- TxnHandleImpl(const std::string& xid);
- TxnHandleImpl(const std::string& xid, qpid::broker::TxnBuffer* tb);
+ TxnHandleImpl(const std::string& xid, const bool tpcFlag);
+ TxnHandleImpl(const std::string& xid, const bool tpcFlag, qpid::broker::TxnBuffer* tb);
virtual ~TxnHandleImpl();
const std::string& getXid() const;
bool is2pc() const;
- void submitPrepare();
- void submitCommit();
- void submitAbort();
-
- void incrOpCnt();
- void decrOpCnt();
private:
std::string m_xid;
bool m_tpcFlag;
- uint32_t m_asyncOpCnt;
- qpid::sys::Mutex m_asyncOpCntMutex;
qpid::broker::TxnBuffer* const m_txnBuffer;
-
- void createLocalXid();
};
}} // namespace qpid::asyncStore