GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-26 03:40:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Log optimization

Browse Source
This commit is contained in:
hxy7yx
2023-07-26 17:21:22 +08:00
parent d7f1ae1d9b
commit ba03318f04
2 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/storage.c
+1 -1
View File
@@ -125,7 +125,7 @@ int adapter_load_setting(const char *node, char **setting)
{
int rv = neu_persister_load_node_setting(node, (const char **) setting);
if (0 != rv) {
nlog_error("load %s setting fail", node);
nlog_warn("load %s setting fail", node);
return -1;
}
src/persist/persist.c
+14 -5
View File
@@ -599,11 +599,20 @@ void neu_persister_destroy()
int neu_persister_store_node(neu_persist_node_info_t *info)
{
int rv =
execute_sql(global_db,
"INSERT INTO nodes (name, type, state, plugin_name) "
"VALUES (%Q, %i, %i, %Q)",
info->name, info->type, info->state, info->plugin_name);
int rv = 0;
if (strcmp(info->plugin_name, "Monitor") == 0) {
rv = execute_sql(
global_db,
"INSERT OR IGNORE INTO nodes (name, type, state, plugin_name) "
"VALUES (%Q, %i, %i, %Q)",
info->name, info->type, info->state, info->plugin_name);
} else {
rv =
execute_sql(global_db,
"INSERT INTO nodes (name, type, state, plugin_name) "
"VALUES (%Q, %i, %i, %Q)",
info->name, info->type, info->state, info->plugin_name);
}
if (0 == rv) {
node_count_add(1);
}