summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authoryangwei <[email protected]>2024-11-27 14:46:53 +0800
committeryangwei <[email protected]>2024-11-27 14:46:53 +0800
commite455954656e770010a561c45cbd12fed6027e231 (patch)
treeee98939ccfac277db5528656db19c750bc2f3147
parentbdc706280d42c9dfafca477e154a497d7486ec23 (diff)
✨ feat(register packet node logic): when register fail, continue
-rw-r--r--infra/stellar_core.c11
1 files changed, 7 insertions, 4 deletions
diff --git a/infra/stellar_core.c b/infra/stellar_core.c
index efdb541..e6189e7 100644
--- a/infra/stellar_core.c
+++ b/infra/stellar_core.c
@@ -170,8 +170,8 @@ static int register_packet_node_for_module(struct module_manager *mod_mgr, struc
mod= module_manager_get_module(mod_mgr, specs[i].module_name);
if(mod == NULL)
{
- CORE_LOG_ERROR("unable to get module %s", specs[i].module_name);
- return -1;
+ CORE_LOG_FATAL("%s unable to get module %s", __FUNCTION__, specs[i].module_name);
+ continue;
}
if(packet_manager_register_node(pkt_mgr,
specs[i].node_name,
@@ -181,8 +181,11 @@ static int register_packet_node_for_module(struct module_manager *mod_mgr, struc
specs[i].cb,
mod)<0)
{
- CORE_LOG_ERROR("failed to subscribe PACKET_STAGE_FORWARD");
- return -1;
+ CORE_LOG_FATAL("%s failed to register node:%s for module:%s in stage:%d", __FUNCTION__, specs[i].node_name, specs[i].module_name, specs[i].stage);
+ }
+ else
+ {
+ CORE_LOG_FATAL("%s success to register node:%s for module:%s in stage:%d", __FUNCTION__, specs[i].node_name, specs[i].module_name, specs[i].stage);
}
}
return 0;