diff --git a/modules/channel/chain/dap_stream_ch_chain.c b/modules/channel/chain/dap_stream_ch_chain.c
index e29ee4b6c42d2efc144527b7505dc8e26c4baa3a..51f8c5d0784f966a3580f74df1f5bbe1b5ec9696 100644
--- a/modules/channel/chain/dap_stream_ch_chain.c
+++ b/modules/channel/chain/dap_stream_ch_chain.c
@@ -710,8 +710,11 @@ static void s_gdb_in_pkt_proc_callback_apply(dap_global_db_context_t *a_global_d
}
}
// Do not overwrite pinned records
- if (l_is_pinned_cur)
+ if (l_is_pinned_cur) {
+ debug_if(s_debug_more, L_WARNING, "Can't %s record from group %s key %s - current record is pinned",
+ l_obj->type != DAP_DB$K_OPTYPE_DEL ? "remove" : "rewrite", l_obj->group, l_obj->key);
goto ret;
+ }
// Deleted time
dap_nanotime_t l_timestamp_del = dap_global_db_get_del_ts_unsafe(a_global_db_context, l_obj->group, l_obj->key);
// Limit time
diff --git a/modules/mempool/dap_chain_mempool.c b/modules/mempool/dap_chain_mempool.c
index 3bf6fcba0106e4bba35506aafb306570d9e8c2e5..f761fb8c23b48107f610817d93d385de568e20c0 100644
--- a/modules/mempool/dap_chain_mempool.c
+++ b/modules/mempool/dap_chain_mempool.c
@@ -115,7 +115,7 @@ char *dap_chain_mempool_datum_add(const dap_chain_datum_t *a_datum, dap_chain_t
}
char *l_gdb_group = dap_chain_net_get_gdb_group_mempool_new(a_chain);
- int l_res = dap_global_db_set(l_gdb_group, l_key_str, a_datum, dap_chain_datum_size(a_datum), true, NULL, NULL);
+ int l_res = dap_global_db_set(l_gdb_group, l_key_str, a_datum, dap_chain_datum_size(a_datum), false, NULL, NULL);
if (l_res == DAP_GLOBAL_DB_RC_SUCCESS)
log_it(L_NOTICE, "Datum %s with hash %s was placed in mempool group %s", l_type_str, l_key_str, l_gdb_group);
else
@@ -1164,7 +1164,7 @@ void chain_mempool_proc(struct dap_http_simple *cl_st, void * arg)
case DAP_DATUM_MEMPOOL_ADD: // add datum in base
//a_value = DAP_NEW_Z_SIZE(char, request_size * 2);
//bin2hex((char*) a_value, (const unsigned char*) request_str, request_size);
- if ( dap_global_db_set_sync(l_gdb_datum_pool, a_key, l_request_data, l_request_size,true )==0 ) {
+ if ( dap_global_db_set_sync(l_gdb_datum_pool, a_key, l_request_data, l_request_size, false) == 0 ) {
*return_code = Http_Status_OK;
}
log_it(L_INFO, "Insert hash: key=%s result:%s", a_key,
diff --git a/modules/net/dap_chain_node.c b/modules/net/dap_chain_node.c
index 9ca79342b1ae4e7d4fe02f9d4c0b4b8bf667b32d..bd2a1250e054626f3dd7dfc3bade4eb1ba2ffc43 100644
--- a/modules/net/dap_chain_node.c
+++ b/modules/net/dap_chain_node.c
@@ -84,7 +84,7 @@ bool dap_chain_node_check_addr(dap_chain_net_t *a_net, dap_chain_node_addr_t *a_
*/
bool dap_chain_node_alias_register(dap_chain_net_t *a_net, const char *a_alias, dap_chain_node_addr_t *a_addr)
{
- return dap_global_db_set_sync(a_net->pub.gdb_nodes_aliases, a_alias, a_addr, sizeof(dap_chain_node_addr_t),true)==0;
+ return dap_global_db_set_sync(a_net->pub.gdb_nodes_aliases, a_alias, a_addr, sizeof(dap_chain_node_addr_t), false) == 0;
}
/**
@@ -158,7 +158,7 @@ int dap_chain_node_info_save(dap_chain_net_t * a_net, dap_chain_node_info_t *a_n
}
//char *a_value = dap_chain_node_info_serialize(node_info, NULL);
size_t l_node_info_size = dap_chain_node_info_get_size(a_node_info);
- int l_res = dap_global_db_set_sync( a_net->pub.gdb_nodes, l_key, a_node_info, l_node_info_size, true);
+ int l_res = dap_global_db_set_sync( a_net->pub.gdb_nodes, l_key, a_node_info, l_node_info_size, false);
DAP_DELETE(l_key);
diff --git a/modules/net/dap_chain_node_cli_cmd.c b/modules/net/dap_chain_node_cli_cmd.c
index db32f159abced3df15295bc187906792556254fc..725bbcb994f649a23cdc924c9bf1824f75e3573a 100644
--- a/modules/net/dap_chain_node_cli_cmd.c
+++ b/modules/net/dap_chain_node_cli_cmd.c
@@ -264,7 +264,7 @@ static bool node_info_save_and_reply(dap_chain_net_t * a_net, dap_chain_node_inf
//dap_chain_node_info_t *a_node_info1 = dap_global_db_gr_get(a_key, &data_len_out, a_net->pub.gdb_nodes);
bool res = dap_global_db_set_sync(a_net->pub.gdb_nodes, a_key, (uint8_t *) a_node_info, l_node_info_size,
- true) == 0;
+ false) == 0;
//data_len_out = 0;
//dap_chain_node_info_t *a_node_info2 = dap_global_db_gr_get(a_key, &data_len_out, a_net->pub.gdb_nodes);
@@ -2361,7 +2361,7 @@ int com_token_decl_sign(int a_argc, char **a_argv, char ** a_str_reply)
const char *l_key_out_str = dap_strcmp(l_hash_out_type,"hex")
? l_key_str_base58 : l_key_str;
// Add datum to mempool with datum_token hash as a key
- if( dap_global_db_set_sync(l_gdb_group_mempool, l_key_str, l_datum, dap_chain_datum_size(l_datum), true) == 0) {
+ if( dap_global_db_set_sync(l_gdb_group_mempool, l_key_str, l_datum, dap_chain_datum_size(l_datum), false) == 0) {
char* l_hash_str = l_datum_hash_hex_str;
// Remove old datum from pool
@@ -3699,7 +3699,7 @@ int com_token_decl(int a_argc, char ** a_argv, char ** a_str_reply)
DAP_DELETE(l_datum);
return -10;
}
- bool l_placed = dap_global_db_set_sync(l_gdb_group_mempool, l_key_str, l_datum, l_datum_size, true) == 0;
+ bool l_placed = dap_global_db_set_sync(l_gdb_group_mempool, l_key_str, l_datum, l_datum_size, false) == 0;
dap_cli_server_cmd_set_reply_text(a_str_reply, "Datum %s with token %s is%s placed in datum pool",
l_key_str, l_ticker, l_placed ? "" : " not");
DAP_DEL_Z(l_key_str);
@@ -4948,7 +4948,7 @@ int com_tx_create_json(int a_argc, char ** a_argv, char **a_str_reply)
char *l_gdb_group_mempool_base_tx = dap_chain_net_get_gdb_group_mempool_new(l_chain);// get group name for mempool
char *l_tx_hash_str;
dap_get_data_hash_str_static(l_datum_tx->data, l_datum_tx->header.data_size, l_tx_hash_str);
- bool l_placed = !dap_global_db_set(l_gdb_group_mempool_base_tx,l_tx_hash_str, l_datum_tx, l_datum_tx_size, true, NULL, NULL);
+ bool l_placed = !dap_global_db_set(l_gdb_group_mempool_base_tx,l_tx_hash_str, l_datum_tx, l_datum_tx_size, false, NULL, NULL);
DAP_DELETE(l_datum_tx);
DAP_DELETE(l_gdb_group_mempool_base_tx);
@@ -5818,12 +5818,12 @@ int cmd_remove(int a_argc, char **a_argv, char ** a_str_reply)
_pvt_net_aliases_list_t *l_tmp = (_pvt_net_aliases_list_t*)ptr->data;
for (size_t i = 0; i < l_tmp->count_aliases; i++) {
dap_global_db_obj_t l_obj = l_tmp->group_aliases[i];
- dap_global_db_set_sync(l_tmp->net->pub.gdb_nodes_aliases, l_obj.key, l_obj.value, l_obj.value_len, true);
+ dap_global_db_set_sync(l_tmp->net->pub.gdb_nodes_aliases, l_obj.key, l_obj.value, l_obj.value_len, false);
}
dap_global_db_objs_delete(l_tmp->group_aliases, l_tmp->count_aliases);
for (size_t i = 0; i < l_tmp->count_nodes; i++) {
dap_global_db_obj_t l_obj = l_tmp->group_nodes[i];
- dap_global_db_set_sync(l_tmp->net->pub.gdb_nodes, l_obj.key, l_obj.value, l_obj.value_len, true);
+ dap_global_db_set_sync(l_tmp->net->pub.gdb_nodes, l_obj.key, l_obj.value, l_obj.value_len, false);
}
dap_global_db_objs_delete(l_tmp->group_nodes, l_tmp->count_nodes);
}
diff --git a/modules/net/srv/dap_chain_net_srv_order.c b/modules/net/srv/dap_chain_net_srv_order.c
index 332a1dd85d1e2611330fdea2b5961748ed46d564..70db61508aae488471954b22b57e94b69b1c2edc 100644
--- a/modules/net/srv/dap_chain_net_srv_order.c
+++ b/modules/net/srv/dap_chain_net_srv_order.c
@@ -346,7 +346,7 @@ char *dap_chain_net_srv_order_save(dap_chain_net_t *a_net, dap_chain_net_srv_ord
dap_hash_fast(a_order, l_order_size, &l_order_hash);
char *l_order_hash_str = dap_chain_hash_fast_to_str_new(&l_order_hash);
char *l_gdb_group_str = dap_chain_net_srv_order_get_gdb_group(a_net);
- if ( dap_global_db_set_sync( l_gdb_group_str,l_order_hash_str, a_order, l_order_size, true ) != 0) {
+ if ( dap_global_db_set_sync( l_gdb_group_str,l_order_hash_str, a_order, l_order_size, false ) != 0) {
DAP_DELETE(l_gdb_group_str);
return NULL;
}
diff --git a/modules/service/stake/dap_chain_net_srv_stake_pos_delegate.c b/modules/service/stake/dap_chain_net_srv_stake_pos_delegate.c
index c64ecf391a5cf917db4316b43d85c114199ebf47..8efae77b3b4ffda46bda72692dd1c81edd56ce50 100644
--- a/modules/service/stake/dap_chain_net_srv_stake_pos_delegate.c
+++ b/modules/service/stake/dap_chain_net_srv_stake_pos_delegate.c
@@ -1940,6 +1940,6 @@ static void s_cache_data(dap_ledger_t *a_ledger, dap_chain_datum_tx_t *a_tx, dap
dap_chain_hash_fast_to_str(&l_cache_data.tx_hash, l_data_key, sizeof(l_data_key));
l_cache_data.signing_addr = *a_signing_addr;
char *l_gdb_group = dap_chain_ledger_get_gdb_group(a_ledger, DAP_CHAIN_NET_SRV_STAKE_POS_DELEGATE_GDB_GROUP);
- if (dap_global_db_set(l_gdb_group, l_data_key, &l_cache_data, sizeof(l_cache_data), true, NULL, NULL))
+ if (dap_global_db_set(l_gdb_group, l_data_key, &l_cache_data, sizeof(l_cache_data), false, NULL, NULL))
log_it(L_WARNING, "Stake service cache mismatch");
}
diff --git a/modules/service/vpn/dap_chain_net_vpn_client.c b/modules/service/vpn/dap_chain_net_vpn_client.c
index e70ab763c9b24ffe3344cf40a81bd467aafb375d..7e29d77e272360accfc236f863a74ef608cbf3fa 100644
--- a/modules/service/vpn/dap_chain_net_vpn_client.c
+++ b/modules/service/vpn/dap_chain_net_vpn_client.c
@@ -338,7 +338,7 @@ static dap_chain_hash_fast_t* dap_chain_net_vpn_client_tx_cond_hash(dap_chain_ne
dap_chain_hash_fast_from_str(l_tx_cond_hash_str, l_tx_cond_hash);
DAP_DELETE(l_tx_cond_hash_str);
// save transaction for login
- dap_global_db_set_sync(l_gdb_group, "client_tx_cond_hash", l_tx_cond_hash, sizeof(dap_chain_hash_fast_t), true);
+ dap_global_db_set_sync(l_gdb_group, "client_tx_cond_hash", l_tx_cond_hash, sizeof(dap_chain_hash_fast_t), false);
}
DAP_DELETE(l_client_key);
}
@@ -362,11 +362,11 @@ int dap_chain_net_vpn_client_update(dap_chain_net_t *a_net, const char *a_wallet
}
char *l_gdb_group = dap_strdup_printf("local.%s", DAP_CHAIN_NET_SRV_VPN_CDB_GDB_PREFIX);
- if(dap_global_db_set_sync(l_gdb_group, "wallet_name", a_wallet_name, -1,true))
+ if(dap_global_db_set_sync(l_gdb_group, "wallet_name", a_wallet_name, -1, false))
return -2;
- if(dap_global_db_set_sync(l_gdb_group, "token_name", a_str_token, -1, true))
+ if(dap_global_db_set_sync(l_gdb_group, "token_name", a_str_token, -1, false))
return -2;
- if(dap_global_db_set_sync(l_gdb_group, "value_datoshi", &a_value_datoshi, sizeof(a_value_datoshi), true))
+ if(dap_global_db_set_sync(l_gdb_group, "value_datoshi", &a_value_datoshi, sizeof(a_value_datoshi), false))
return -2;
DAP_DELETE(l_gdb_group);
dap_chain_hash_fast_t *l_hash = dap_chain_net_vpn_client_tx_cond_hash(a_net, l_wallet, a_str_token,
diff --git a/modules/type/blocks/dap_chain_block_chunk.c b/modules/type/blocks/dap_chain_block_chunk.c
index b79ce22ac96814a1000354dd0ef926f2cb9cbb69..b3ce37868d7c311c8f5b65f1eec2c821ee6ee151 100644
--- a/modules/type/blocks/dap_chain_block_chunk.c
+++ b/modules/type/blocks/dap_chain_block_chunk.c
@@ -99,7 +99,7 @@ void dap_chain_block_chunks_add(dap_chain_block_chunks_t * a_chunks,dap_chain_bl
}
// Save to GDB
//dap_global_db_set(a_chunks->gdb_group, a_block_cache->block_hash_str, a_block_cache->block, a_block_cache->block_size,
- // true, NULL, NULL );
+ // false, NULL, NULL );
// And here we select chunk for the new block cache
bool l_is_chunk_found = false;
diff --git a/modules/type/dag/dap_chain_cs_dag_event.c b/modules/type/dag/dap_chain_cs_dag_event.c
index cddbc4bdd5ef1dfdb11605e3d4e3b72647481902..c1600428d4bf37a469bbe5f7c8f6f1c7b2231f7b 100644
--- a/modules/type/dag/dap_chain_cs_dag_event.c
+++ b/modules/type/dag/dap_chain_cs_dag_event.c
@@ -277,7 +277,7 @@ bool dap_chain_cs_dag_event_gdb_set(dap_chain_cs_dag_t *a_dag, char *a_event_has
size_t l_round_item_size = dap_chain_cs_dag_event_round_item_get_size(l_round_item);
bool ret = dap_global_db_set(a_dag->gdb_group_events_round_new, a_event_hash_str, l_round_item,
- l_round_item_size,true, NULL, NULL) == 0;
+ l_round_item_size, false, NULL, NULL) == 0;
DAP_DELETE(l_round_item);
return ret;
}