1 files changed, 127 insertions, 0 deletions
diff --git a/storage/tokudb/PerconaFT/ftcxx/db_txn.hpp b/storage/tokudb/PerconaFT/ftcxx/db_txn.hpp
new file mode 100644
index 00000000..adcdc8f5
--- /dev/null
+++ b/storage/tokudb/PerconaFT/ftcxx/db_txn.hpp
@@ -0,0 +1,127 @@
+/* -*- mode: C++; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+#ident "$Id$"
+/*======
+This file is part of PerconaFT.
+
+
+Copyright (c) 2006, 2015, Percona and/or its affiliates. All rights reserved.
+
+    PerconaFT is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License, version 2,
+    as published by the Free Software Foundation.
+
+    PerconaFT is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with PerconaFT.  If not, see <http://www.gnu.org/licenses/>.
+
+----------------------------------------
+
+    PerconaFT is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Affero General Public License, version 3,
+    as published by the Free Software Foundation.
+
+    PerconaFT is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Affero General Public License for more details.
+
+    You should have received a copy of the GNU Affero General Public License
+    along with PerconaFT.  If not, see <http://www.gnu.org/licenses/>.
+======= */
+
+#ident "Copyright (c) 2006, 2015, Percona and/or its affiliates. All rights reserved."
+
+#pragma once
+
+#include <db.h>
+
+#include "db_env.hpp"
+#include "exceptions.hpp"
+
+namespace ftcxx {
+
+    class DBTxn {
+    public:
+        DBTxn()
+            : _flags(0),
+              _txn(nullptr)
+        {}
+
+        explicit DBTxn(const DBEnv &env, int flags=0)
+            : _flags(flags),
+              _txn(nullptr)
+        {
+            DB_TXN *t;
+            int r = env.env()->txn_begin(env.env(), nullptr, &t, _flags);
+            handle_ft_retval(r);
+            _txn = t;
+        }
+
+        DBTxn(const DBEnv &env, const DBTxn &parent, int flags=0)
+            : _flags(flags),
+              _txn(nullptr)
+        {
+            DB_TXN *t;
+            int r = env.env()->txn_begin(env.env(), parent.txn(), &t, _flags);
+            handle_ft_retval(r);
+            _txn = t;
+        }
+
+        ~DBTxn() {
+            if (_txn) {
+                abort();
+            }
+        }
+
+        DBTxn(const DBTxn &) = delete;
+        DBTxn& operator=(const DBTxn &) = delete;
+
+        DBTxn(DBTxn &&o)
+            : _flags(0),
+              _txn(nullptr)
+        {
+            std::swap(_flags, o._flags);
+            std::swap(_txn, o._txn);
+        }
+
+        DBTxn& operator=(DBTxn &&o) {
+            std::swap(_flags, o._flags);
+            std::swap(_txn, o._txn);
+            return *this;
+        }
+
+        DB_TXN *txn() const { return _txn; }
+
+        void commit(int flags=0) {
+            int r = _txn->commit(_txn, flags);
+            handle_ft_retval(r);
+            _txn = nullptr;
+        }
+
+        void abort() {
+            int r = _txn->abort(_txn);
+            handle_ft_retval(r);
+            _txn = nullptr;
+        }
+
+        bool is_read_only() const {
+            return _flags & DB_TXN_READ_ONLY;
+        }
+
+        uint64_t id() const {
+            if (!_txn) {
+                return 0;
+            }
+            return _txn->id64(_txn);
+        }
+
+    private:
+        int _flags;
+        DB_TXN *_txn;
+    };
+
+} // namespace ftcxx