GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-23 18:37:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #677 from eeff/eeff/dev

Browse Source 
fix(persistence): correct sqlite type substitution
This commit is contained in:
fengzeroz
2022-07-29 14:18:23 +08:00
committed by GitHub
parent 7847de63b0 d6bc7ca0f5
commit ca0b7a9664
3 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/storage.c
+2 -3
View File
@@ -119,9 +119,8 @@ int manager_load_node(neu_manager_t *manager)
rv = neu_manager_add_node(manager, node_info->name,
node_info->plugin_name);
const char *ok_or_err = (0 == rv) ? "success" : "fail";
nlog_info("load adapter %s type:%" PRId64 ", name:%s plugin:%s",
ok_or_err, node_info->type, node_info->name,
node_info->plugin_name);
nlog_info("load adapter %s type:%d, name:%s plugin:%s", ok_or_err,
node_info->type, node_info->name, node_info->plugin_name);
}
utarray_free(node_infos);
src/persist/persist.c
+2 -2
View File
@@ -1006,8 +1006,8 @@ int neu_persister_store_group(neu_persister_t * persister,
{
return execute_sql(
persister->db,
"INSERT INTO groups (driver_name, name, interval) VALUES (%Q, %Q, %i)",
driver_name, group_info->name, group_info->interval);
"INSERT INTO groups (driver_name, name, interval) VALUES (%Q, %Q, %u)",
driver_name, group_info->name, (unsigned) group_info->interval);
}
static UT_icd group_info_icd = {
src/persist/persist.h
+4 -4
View File
@@ -30,10 +30,10 @@ extern "C" {
typedef neu_json_plugin_req_plugin_t neu_persist_plugin_info_t;
typedef struct {
char * name;
int64_t type;
char * plugin_name;
int64_t state;
char *name;
int type;
char *plugin_name;
int state;
} neu_persist_node_info_t;
typedef struct {