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

fix(ekuiper): memory leak on NEU_REQ_SUBSCRIBE_GROUP

Browse Source
This commit is contained in:
eeff
2023-03-01 00:28:33 +08:00
parent 9feb204f3d
commit bc94a94aab
2 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/plugin_ekuiper.c
+11 -5
View File
@@ -236,11 +236,6 @@ static int ekuiper_plugin_request(neu_plugin_t * plugin,
NEU_NODE_LINK_STATE_DISCONNECTED == plugin->common.link_state;
nng_mtx_unlock(plugin->mtx);
if (disconnected) {
plog_debug(plugin, "not connected");
return -1;
}
switch (header->type) {
case NEU_RESP_ERROR: {
neu_resp_error_t *error = (neu_resp_error_t *) data;
@@ -248,10 +243,21 @@ static int ekuiper_plugin_request(neu_plugin_t * plugin,
break;
}
case NEU_REQRESP_TRANS_DATA: {
if (disconnected) {
plog_debug(plugin, "not connected");
return -1;
}
neu_reqresp_trans_data_t *trans_data = data;
send_data(plugin, trans_data);
break;
}
case NEU_REQ_SUBSCRIBE_GROUP: {
neu_req_subscribe_t *sub_info = data;
free(sub_info->params);
break;
}
case NEU_REQ_UNSUBSCRIBE_GROUP:
break;
default:
plog_notice(plugin, "unsupported request type: %d", header->type);
break;
src/core/manager_internal.c
+1
View File
@@ -199,6 +199,7 @@ int neu_manager_send_subscribe(neu_manager_t *manager, const char *app,
if (nng_sendmsg(manager->socket, out_msg, 0) == 0) {
nlog_info("send %s to %s", neu_reqresp_type_string(header.type), app);
} else {
free(cmd.params);
nng_msg_free(out_msg);
}