Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found

Target

Select target project
  • cellframe/libdap-chain-global-db
1 result
Show changes
Commits on Source (1)
......@@ -1169,7 +1169,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...");
//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++) {
......@@ -1180,7 +1180,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);
//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;
......@@ -1275,7 +1275,7 @@ static void *s_list_thread_proc(void *arg)
// l_dap_db_log_list->item_start += l_data_size_out;
pthread_mutex_unlock(&l_dap_db_log_list->list_mutex);
l_items_number += l_data_size_out;
log_it(L_DEBUG, "loaded items n=%u/%u", l_data_size_out, l_items_number);
//log_it(L_DEBUG, "loaded items n=%u/%u", l_data_size_out, l_items_number);
dap_store_obj_free(l_objs, l_data_size_out);
}
......@@ -1292,7 +1292,7 @@ static void *s_list_thread_proc(void *arg)
dap_db_log_list_t* dap_db_log_list_start(uint64_t first_id)
{
log_it(L_DEBUG, "Start loading db list_write...");
//log_it(L_DEBUG, "Start loading db list_write...");
dap_db_log_list_t *l_dap_db_log_list = DAP_NEW_Z(dap_db_log_list_t);
size_t l_data_size_out = dap_chain_global_db_driver_count(GROUP_LOCAL_HISTORY, first_id);
......@@ -1320,7 +1320,7 @@ dap_db_log_list_t* dap_db_log_list_start(uint64_t first_id)
}
l_dap_db_log_list->list_write = l_list;
l_dap_db_log_list->list_read = l_list;
log_it(L_DEBUG, "loaded items n=%d", l_data_size_out);
//log_it(L_DEBUG, "loaded items n=%d", l_data_size_out);
dap_store_obj_free(l_objs, l_data_size_out);
}
// start thread for items loading
......@@ -1386,7 +1386,7 @@ dap_global_db_obj_t* dap_db_log_list_get(dap_db_log_list_t *a_db_log_list)
else
break;
}
log_it(L_DEBUG, "get item n=%d", a_db_log_list->items_number - a_db_log_list->items_rest);
//log_it(L_DEBUG, "get item n=%d", a_db_log_list->items_number - a_db_log_list->items_rest);
return (dap_global_db_obj_t*) l_list ? l_list->data : NULL;
//return l_list;
}
......