dap_chain_global_db.c

@@ -48,7 +48,6 @@
 
 #define LOG_TAG "dap_global_db"
 
-#define DAP_APP_NAME NODE_NETNAME "-node"
 
 // for access from several streams
 //static pthread_mutex_t ldb_mutex_ = PTHREAD_MUTEX_INITIALIZER;
@@ -76,6 +75,7 @@ typedef struct history_group_item
 
 // Tacked group callbacks
 static history_group_item_t * s_history_group_items = NULL;
+static char *s_storage_path = NULL;
 
 char * extract_group_prefix(const char * a_group);
 
@@ -177,16 +177,12 @@ void dap_chain_global_db_objs_delete(dap_global_db_obj_t *objs, size_t a_count)
  */
 int dap_chain_global_db_init(dap_config_t * g_config)
 {
-    char l_storage_path[MAX_PATH];
-#ifdef WIN32
-    memcpy(l_storage_path, s_sys_dir_path, l_sys_dir_path_len);
-#endif
-    dap_sprintf(l_storage_path + l_sys_dir_path_len, "%s",
-                dap_config_get_item_str(g_config, "resources", "dap_global_db_path"));
+    s_storage_path= dap_strdup(
+                dap_config_get_item_str(g_config, "resources", "dap_global_db_path") );
     //const char *l_driver_name = dap_config_get_item_str_default(g_config, "resources", "dap_global_db_driver", "sqlite");
     const char *l_driver_name = dap_config_get_item_str_default(g_config, "resources", "dap_global_db_driver", "cdb");
     lock();
-    int res = dap_db_driver_init(l_driver_name, l_storage_path);
+    int res = dap_db_driver_init(l_driver_name, s_storage_path);
     unlock();
     return res;
 }

dap_chain_global_db_driver_cdb.c

@@ -402,7 +402,7 @@ dap_store_obj_t* dap_db_driver_cdb_read_cond_store_obj(const char *a_group, uint
     if (l_arg.q > 0) {
         l_count_out = l_arg.n - l_arg.q;
         void *tmp = DAP_REALLOC(l_arg.o, l_count_out * sizeof(dap_store_obj_t));
-        if (!tmp) {
+        if (!tmp && l_count_out) {
             log_it(L_CRITICAL, "Couldn't re-allocate memory for portion of store objects!");
             DAP_DELETE(l_arg.o);
             return NULL;

dap_chain_global_db_hist.c

@@ -1164,6 +1164,7 @@ dap_list_t* dap_db_log_get_list(uint64_t first_id)
 {
     dap_list_t *l_list = NULL;
     size_t l_data_size_out = 0;
+    log_it(L_DEBUG,"loading db list...");
     dap_store_obj_t *l_objs = dap_chain_global_db_cond_load(GROUP_LOCAL_HISTORY, first_id, &l_data_size_out);
     //dap_global_db_obj_t *l_objs = dap_chain_global_db_gr_load(GROUP_LOCAL_HISTORY, first_timestamp, &l_data_size_out);
     for(size_t i = 0; i < l_data_size_out; i++) {
@@ -1174,6 +1175,7 @@ dap_list_t* dap_db_log_get_list(uint64_t first_id)
         l_item->value = (uint8_t*) dap_strdup((char*) l_obj_cur->value);
         l_list = dap_list_append(l_list, l_item);
     }
+    log_it(L_DEBUG,"loaded db list n=%d", l_data_size_out);
     dap_store_obj_free(l_objs, l_data_size_out);
 
     return l_list;