From 68faa67742f43d6299583bf7aade2c2831bc9e88 Mon Sep 17 00:00:00 2001
From: eeff <33566201+eeff@users.noreply.github.com>
Date: Tue, 3 Jan 2023 16:36:26 +0800
Subject: [PATCH] fix(ekuiper): memory leak

---
 plugins/ekuiper/plugin_ekuiper.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/plugins/ekuiper/plugin_ekuiper.c b/plugins/ekuiper/plugin_ekuiper.c
index 895f0928..20dd9662 100644
--- a/plugins/ekuiper/plugin_ekuiper.c
+++ b/plugins/ekuiper/plugin_ekuiper.c
@@ -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;
     }