From 96506f3f502bfc1c13ed60e55a143ddc0cea5c64 Mon Sep 17 00:00:00 2001
From: "roman.khlopkov" <roman.khlopkov@demlabs.net>
Date: Thu, 4 Apr 2024 13:06:51 +0300
Subject: [PATCH] [*] GOSSIP adding callback assertion failed
---
modules/chain/dap_chain_ch.c | 5 ++---
modules/net/dap_chain_net_balancer.c | 4 ++--
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/modules/chain/dap_chain_ch.c b/modules/chain/dap_chain_ch.c
index f4cfcde1a2..6991ce70c4 100644
--- a/modules/chain/dap_chain_ch.c
+++ b/modules/chain/dap_chain_ch.c
@@ -194,7 +194,7 @@ static const char *s_error_type_to_string(dap_chain_ch_error_type_t a_error)
*/
int dap_chain_ch_init()
{
- log_it(L_NOTICE, "Chains and global db exchange channel initialized");
+ log_it(L_NOTICE, "Chains exchange channel initialized");
dap_stream_ch_proc_add(DAP_CHAIN_CH_ID, s_stream_ch_new, s_stream_ch_delete, s_stream_ch_packet_in,
s_stream_ch_packet_out);
s_sync_timeout = dap_config_get_item_uint32_default(g_config, "chain", "sync_timeout", s_sync_timeout);
@@ -205,8 +205,7 @@ int dap_chain_ch_init()
for (int i = 0; i < MEMSTAT$K_NR; i++)
dap_memstat_reg(&s_memstat[i]);
#endif
- assert(!dap_stream_ch_gossip_callback_add(DAP_CHAIN_CH_ID, s_gossip_payload_callback));
- return 0;
+ return dap_stream_ch_gossip_callback_add(DAP_CHAIN_CH_ID, s_gossip_payload_callback);
}
/**
diff --git a/modules/net/dap_chain_net_balancer.c b/modules/net/dap_chain_net_balancer.c
index b6e8c1195c..5f664784d2 100644
--- a/modules/net/dap_chain_net_balancer.c
+++ b/modules/net/dap_chain_net_balancer.c
@@ -152,7 +152,7 @@ dap_chain_net_links_t *dap_chain_net_balancer_get_node(const char *a_net_name, u
size_t l_node_num_prep = a_links_need;
dap_link_info_t *l_links_info = s_get_links_info_list(l_net, &l_node_num_prep, true);
if (!l_links_info || !l_node_num_prep){
- log_it(L_ERROR, "Active node list in net %s is empty", a_net_name);
+ log_it(L_WARNING, "Active node list in net %s is empty", a_net_name);
return NULL;
}
size_t l_node_num_send = dap_min(s_max_links_response_count, l_node_num_prep);
@@ -187,7 +187,7 @@ dap_chain_net_links_t *dap_chain_net_balancer_get_node_old(const char *a_net_nam
size_t l_node_num_prep = a_links_need;
dap_link_info_t *l_links_info = s_get_links_info_list(l_net, &l_node_num_prep, true);
if (!l_links_info || !l_node_num_prep){
- log_it(L_ERROR, "Active node list in net %s is empty", a_net_name);
+ log_it(L_WARNING, "Active node list in net %s is empty", a_net_name);
return NULL;
}
size_t l_node_num_send = dap_min(s_max_links_response_count, l_node_num_prep);
--
GitLab