[+] libmdbx

libmdbx @ b98895b8

+Subproject commit b98895b8c700f741f24468d061ab24e1fa6963bb

CMakeLists.txt

@@ -32,6 +32,7 @@ endif()
 add_subdirectory(dap-sdk)
 add_subdirectory(3rdparty/monero_crypto)
 add_subdirectory(3rdparty/cuttdb)
+add_subdirectory(3rdparty/libmdbx)
 if (ANDROID)
     add_subdirectory(3rdparty/libmagic)
     add_subdirectory(3rdparty/json-c)

modules/global-db/CMakeLists.txt

@@ -2,11 +2,15 @@ cmake_minimum_required(VERSION 3.1)
 project (dap_chain_global_db C)
   
 file(GLOB DAP_CHAIN_GLOBAL_DB_SRC *.c)
+
+
 file(GLOB DAP_CHAIN_GLOBAL_DB_HDR include/*.h)
 
+
 add_library(${PROJECT_NAME} STATIC ${DAP_CHAIN_GLOBAL_DB_SRC} ${DAP_CHAIN_GLOBAL_DB_HDR})
 
-target_link_libraries(${PROJECT_NAME} dap_core dap_crypto dap_chain sqlite3 dap_cuttdb json-c)
+target_link_libraries(${PROJECT_NAME} dap_core dap_crypto dap_chain sqlite3 dap_cuttdb json-c mdbx-static)
+add_definitions ("-DDAP_CHAIN_GDB_ENGINE_MDBX")
 
 target_include_directories(dap_chain_global_db INTERFACE .)
 target_include_directories(${PROJECT_NAME} PUBLIC include)

modules/global-db/dap_chain_global_db_driver.c

@@ -36,6 +36,7 @@
 
 #include "dap_chain_global_db_driver_sqlite.h"
 #include "dap_chain_global_db_driver_cdb.h"
+#include "dap_chain_global_db_driver_mdbx.h"
 #include "dap_chain_global_db_driver.h"
 
 #define LOG_TAG "db_driver"
@@ -87,6 +88,8 @@ int dap_db_driver_init(const char *a_driver_name, const char *a_filename_db)
         l_ret = dap_db_driver_sqlite_init(a_filename_db, &s_drv_callback);
     else if(!dap_strcmp(s_used_driver, "cdb"))
         l_ret = dap_db_driver_cdb_init(a_filename_db, &s_drv_callback);
+    else if(!dap_strcmp(s_used_driver, "mdbx"))
+        l_ret = dap_db_driver_mdbx_init(a_filename_db, &s_drv_callback);
     else
         log_it(L_ERROR, "Unknown global_db driver \"%s\"", a_driver_name);
 #ifdef USE_WRITE_BUFFER

modules/global-db/dap_chain_global_db_driver_mdbx.c

+/*
+ * Authors:
+ * Gerasimov Dmitriy <gerasimov.dmitriy@demlabs.net>
+ * DeM Labs Ltd.   https://demlabs.net
+ * Copyright  (c) 2021
+ * All rights reserved.
+
+ This file is part of DAP SDK the open source project
+
+ DAP SDK 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 3 of the License, or
+ (at your option) any later version.
+
+ DAP 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 any DAP based project.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <stddef.h>
+#include <string.h>
+#include <dirent.h>
+#include <pthread.h>
+#include <sys/stat.h>
+#include <uthash.h>
+#define _GNU_SOURCE
+
+#include "dap_common.h"
+#include "dap_hash.h"
+#include "dap_strfuncs.h"
+#include "dap_file_utils.h"
+
+#include "dap_chain_global_db_driver_mdbx.h"
+
+#define LOG_TAG "dap_chain_global_db_mdbx"
+
+static char *s_cdb_path = NULL;
+static int s_driver_callback_deinit();
+static int s_driver_callback_flush(void);
+static int s_driver_callback_apply_store_obj(pdap_store_obj_t a_store_obj);
+static dap_store_obj_t *s_driver_callback_read_last_store_obj(const char* a_group);
+static bool s_driver_callback_is_obj(const char *a_group, const char *a_key);
+static dap_store_obj_t *s_driver_callback_read_store_obj(const char *a_group, const char *a_key, size_t *a_count_out);
+static dap_store_obj_t* s_driver_callback_read_cond_store_obj(const char *a_group, uint64_t a_id, size_t *a_count_out);
+static size_t s_driver_callback_read_count_store(const char *a_group, uint64_t a_id);
+static dap_list_t* s_driver_callback_get_groups_by_mask(const char *a_group_mask);
+
+/**
+ * @brief dap_db_driver_mdbx_init
+ * @param a_cdb_path
+ * @param a_drv_callback
+ * @return
+ */
+int dap_db_driver_mdbx_init(const char *a_cdb_path, dap_db_driver_callbacks_t *a_drv_callback)
+{
+    s_cdb_path = dap_strdup(a_cdb_path);
+    if(s_cdb_path[strlen(s_cdb_path)] == '/') {
+        s_cdb_path[strlen(s_cdb_path)] = '\0';
+    }
+    dap_mkdir_with_parents(s_cdb_path);
+    struct dirent *d;
+    DIR *dir = opendir(s_cdb_path);
+    if (!dir) {
+        log_it(L_ERROR, "Couldn't open db directory");
+        return -1;
+    }
+    for (d = readdir(dir); d; d = readdir(dir)) {
+#ifdef _DIRENT_HAVE_D_TYPE
+        if (d->d_type != DT_DIR)
+            continue;
+#else
+        struct _stat buf;
+        int res = _stat(d->d_name, &buf);
+        if (!S_ISDIR(buf.st_mode) || !res) {
+            continue;
+        }
+#endif
+        if (!dap_strcmp(d->d_name, ".") || !dap_strcmp(d->d_name, "..")) {
+            continue;
+        }
+        if (0) {
+            s_driver_callback_deinit();
+            closedir(dir);
+            return -2;
+        }
+    }
+    a_drv_callback->read_last_store_obj = s_driver_callback_read_last_store_obj;
+    a_drv_callback->apply_store_obj     = s_driver_callback_apply_store_obj;
+    a_drv_callback->read_store_obj      = s_driver_callback_read_store_obj;
+    a_drv_callback->read_cond_store_obj = s_driver_callback_read_cond_store_obj;
+    a_drv_callback->read_count_store    = s_driver_callback_read_count_store;
+    a_drv_callback->get_groups_by_mask  = s_driver_callback_get_groups_by_mask;
+    a_drv_callback->is_obj              = s_driver_callback_is_obj;
+    a_drv_callback->deinit              = s_driver_callback_deinit;
+    a_drv_callback->flush               = s_driver_callback_flush;
+
+    closedir(dir);
+    return 0;
+}
+
+/**
+ * @brief s_driver_callback_deinit
+ * @return
+ */
+static int s_driver_callback_deinit()
+{
+    return 0;
+}
+
+/**
+ * @brief s_driver_callback_flush
+ * @return
+ */
+static int s_driver_callback_flush(void)
+{
+    int ret = 0;
+    log_it(L_DEBUG, "Flushing MDBX on the disk");
+    return ret;
+}
+
+/**
+ * @brief s_driver_callback_read_last_store_obj
+ * @param a_group
+ * @return
+ */
+static dap_store_obj_t *s_driver_callback_read_last_store_obj(const char* a_group)
+{
+    return NULL;
+}
+
+/**
+ * @brief s_driver_callback_is_obj
+ * @param a_group
+ * @param a_key
+ * @return
+ */
+static bool s_driver_callback_is_obj(const char *a_group, const char *a_key)
+{
+    return false;
+}
+
+/**
+ * @brief s_driver_callback_read_store_obj
+ * @param a_group
+ * @param a_key
+ * @param a_count_out
+ * @return
+ */
+static dap_store_obj_t *s_driver_callback_read_store_obj(const char *a_group, const char *a_key, size_t *a_count_out)
+{
+    return NULL;
+}
+
+/**
+ * @brief s_driver_callback_read_cond_store_obj
+ * @param a_group
+ * @param a_id
+ * @param a_count_out
+ * @return
+ */
+static dap_store_obj_t* s_driver_callback_read_cond_store_obj(const char *a_group, uint64_t a_id, size_t *a_count_out)
+{
+    return NULL;
+}
+
+/**
+ * @brief s_driver_callback_read_count_store
+ * @param a_group
+ * @param a_id
+ * @return
+ */
+static size_t s_driver_callback_read_count_store(const char *a_group, uint64_t a_id)
+{
+    return 0;
+}
+
+/**
+ * @brief s_driver_callback_get_groups_by_mask
+ * @details Check whether the groups match the pattern a_group_mask, which is a shell wildcard pattern
+ * @param a_group_mask
+ * @return
+ */
+static dap_list_t* s_driver_callback_get_groups_by_mask(const char *a_group_mask)
+{
+    return NULL;
+}
+
+/**
+ * @brief s_driver_callback_apply_store_obj
+ * @param a_store_obj
+ * @return
+ */
+static int s_driver_callback_apply_store_obj(pdap_store_obj_t a_store_obj)
+{
+    if(!a_store_obj || !a_store_obj->group) {
+        return -1;
+    }
+    int ret = 0;
+}
+

modules/global-db/include/dap_chain_global_db_driver_mdbx.h

+/*
+ * Authors:
+ * Gerasimov Dmitriy <gerasimov.dmitriy@demlabs.net>
+ * DeM Labs Ltd.   https://demlabs.net
+ * Copyright  (c) 2021
+ * All rights reserved.
+
+ This file is part of DAP SDK the open source project
+
+ DAP SDK 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 3 of the License, or
+ (at your option) any later version.
+
+ DAP 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 any DAP based project.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include "dap_chain_global_db_driver.h"
+
+int dap_db_driver_mdbx_init(const char*, dap_db_driver_callbacks_t*);