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

fix: ekuiper plugin send json data without terminating null byte

Browse Source
This commit is contained in:
eeff
2022-04-14 12:58:11 +08:00
parent 7bf2394ed5
commit 809a22d449
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/read_write.c
+2 -2
View File
@@ -46,7 +46,7 @@ void send_data(neu_plugin_t *plugin, neu_request_t *req)
}
nng_msg *msg = NULL;
size_t json_len = strlen(json_str) + 1; // for terminating null byte
size_t json_len = strlen(json_str);
rv = nng_msg_alloc(&msg, json_len);
if (0 != rv) {
log_error("nng cannot allocate msg");
@@ -54,7 +54,7 @@ void send_data(neu_plugin_t *plugin, neu_request_t *req)
return;
}
memcpy(nng_msg_body(msg), json_str, json_len);
memcpy(nng_msg_body(msg), json_str, json_len); // no null byte
rv = nng_sendmsg(plugin->sock, msg, 0); // TODO: use aio to send message
if (0 != rv) {
log_error("nng cannot send msg");