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

fix(ekuiper): memory leak

Browse Source
This commit is contained in:
eeff
2023-01-04 11:48:38 +08:00
parent fc3df296cd
commit 68faa67742
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/plugin_ekuiper.c
+3
View File
@@ -82,6 +82,8 @@ static int ekuiper_plugin_init(neu_plugin_t *plugin)
rv = nng_aio_alloc(&recv_aio, recv_data_callback, plugin);
if (rv < 0) {
plog_error(plugin, "cannot allocate recv_aio: %s", nng_strerror(rv));
nng_mtx_free(plugin->mtx);
plugin->mtx = NULL;
return rv;
}
@@ -119,6 +121,7 @@ static int ekuiper_plugin_start(neu_plugin_t *plugin)
if ((rv = nng_listen(plugin->sock, EKUIPER_PLUGIN_URL, NULL, 0)) != 0) {
plog_error(plugin, "nng_listen: %s", nng_strerror(rv));
nng_close(plugin->sock);
return NEU_ERR_EINTERNAL;
}