/* Miranda NG: the free IM client for Microsoft* Windows* Copyright (ñ) 2012-17 Miranda NG project (https://miranda-ng.org) all portions of this codebase are copyrighted to the people listed in contributors.txt. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program 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 this program; if not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "lmdb/lmdb.h" #ifndef thread_local # define thread_local __declspec(thread) #endif class txn_ptr { MDB_txn *m_txn; public: __forceinline txn_ptr(MDB_env *pEnv) { mdb_txn_begin(pEnv, NULL, 0, &m_txn); } __forceinline ~txn_ptr() { if (m_txn) mdb_txn_abort(m_txn); } __forceinline operator MDB_txn*() const { return m_txn; } __forceinline int commit() { MDB_txn *tmp = m_txn; m_txn = nullptr; return mdb_txn_commit(tmp); } __forceinline void abort() { mdb_txn_abort(m_txn); m_txn = NULL; } }; struct CMDB_txn_ro { MDB_txn *m_txn; bool bIsActive; mir_cs cs; __forceinline CMDB_txn_ro() : m_txn(nullptr), bIsActive(false) {} __forceinline operator MDB_txn* () { return m_txn; } __forceinline MDB_txn** operator &() { return &m_txn; } }; class txn_ptr_ro { CMDB_txn_ro &m_txn; bool bNeedReset; mir_cslock lock; public: __forceinline txn_ptr_ro(CMDB_txn_ro &txn) : m_txn(txn), bNeedReset(!txn.bIsActive), lock(m_txn.cs) { if (bNeedReset) { mdb_txn_renew(m_txn); m_txn.bIsActive = true; } } __forceinline ~txn_ptr_ro() { if (bNeedReset) { mdb_txn_reset(m_txn); m_txn.bIsActive = false; } } __forceinline operator MDB_txn*() const { return m_txn; } }; class cursor_ptr { MDB_cursor *m_cursor; public: __forceinline cursor_ptr(MDB_txn *_txn, MDB_dbi _dbi) { if (mdb_cursor_open(_txn, _dbi, &m_cursor) != MDB_SUCCESS) m_cursor = NULL; } __forceinline ~cursor_ptr() { if (m_cursor) mdb_cursor_close(m_cursor); } __forceinline operator MDB_cursor*() const { return m_cursor; } }; class cursor_ptr_ro { MDB_cursor *m_cursor; public: __forceinline cursor_ptr_ro(MDB_cursor *cursor) : m_cursor(cursor) { mdb_cursor_renew(mdb_cursor_txn(m_cursor), m_cursor); } __forceinline operator MDB_cursor*() const { return m_cursor; } }; #define MDB_CHECK(A,B) \ switch (A) { \ case MDB_SUCCESS: break; \ case MDB_MAP_FULL: continue; \ default: return (B); } #include "dbintf.h" #include "resource.h" #include "version.h" extern HINSTANCE g_hInst; extern LIST g_Dbs; #include "ui.h"