GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-29 15:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #576 from eeff/eeff/dev

Browse Source 
fix(ekuiper): read signed number
This commit is contained in:
fengzeroz
2022-06-22 14:10:12 +08:00
committed by GitHub
parent 805fc5569b 5264a42546
commit 44b9d622e6
2 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/json_rw.c
+12
View File
@@ -37,21 +37,33 @@ int wrap_tag_data(neu_json_read_resp_tag_t *json_tag,
switch (tag_value->value.type) {
case NEU_TYPE_INT8:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.i8;
break;
case NEU_TYPE_UINT8:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.u8;
break;
case NEU_TYPE_INT16:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.i16;
break;
case NEU_TYPE_UINT16:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.u16;
break;
case NEU_TYPE_INT32:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.i32;
break;
case NEU_TYPE_UINT32:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.u32;
break;
case NEU_TYPE_INT64:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.i64;
break;
case NEU_TYPE_UINT64:
json_tag->t = NEU_JSON_INT;
json_tag->value.val_int = tag_value->value.value.u64;
plugins/ekuiper/plugin_ekuiper.c
+2
View File
@@ -121,6 +121,7 @@ static int ekuiper_plugin_start(neu_plugin_t *plugin)
}
nng_recv_aio(plugin->sock, plugin->recv_aio);
plog_info(plugin, "start successfully");
return NEU_ERR_SUCCESS;
}
@@ -128,6 +129,7 @@ static int ekuiper_plugin_start(neu_plugin_t *plugin)
static int ekuiper_plugin_stop(neu_plugin_t *plugin)
{
nng_close(plugin->sock);
plog_info(plugin, "stop successfully");
return NEU_ERR_SUCCESS;
}