From 5e581cdfbc7a00f165efbb2db8bfe7bee36ea2a9 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Wed, 6 Jul 2022 10:29:44 +0800
Subject: [PATCH] fix index mem leak

---
 include/libs/index/index.h               | 2 +-
 source/dnode/mgmt/node_mgmt/src/dmMgmt.c | 2 ++
 source/libs/index/src/index.c            | 3 ++-
 3 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/include/libs/index/index.h b/include/libs/index/index.h
index 9e71c941d3..5a3c4cfee7 100644
--- a/include/libs/index/index.h
+++ b/include/libs/index/index.h
@@ -208,7 +208,7 @@ int32_t doFilterTag(const SNode* pFilterNode, SIndexMetaArg* metaArg, SArray* re
  * destory index env
  *
  */
-void indexCleanUp();
+void indexCleanup();
 
 #ifdef __cplusplus
 }
diff --git a/source/dnode/mgmt/node_mgmt/src/dmMgmt.c b/source/dnode/mgmt/node_mgmt/src/dmMgmt.c
index d70ed09920..436282d9fe 100644
--- a/source/dnode/mgmt/node_mgmt/src/dmMgmt.c
+++ b/source/dnode/mgmt/node_mgmt/src/dmMgmt.c
@@ -16,6 +16,7 @@
 #define _DEFAULT_SOURCE
 #include "dmMgmt.h"
 #include "dmNodes.h"
+#include "index.h"
 #include "qworker.h"
 
 static bool dmRequireNode(SDnode *pDnode, SMgmtWrapper *pWrapper) {
@@ -213,6 +214,7 @@ void dmCleanupDnode(SDnode *pDnode) {
   dmCleanupServer(pDnode);
   dmClearVars(pDnode);
   rpcCleanup();
+  indexCleanup();
   dDebug("dnode is closed, ptr:%p", pDnode);
 }
 
diff --git a/source/libs/index/src/index.c b/source/libs/index/src/index.c
index f6424ee8a5..7f5cfc7767 100644
--- a/source/libs/index/src/index.c
+++ b/source/libs/index/src/index.c
@@ -65,9 +65,10 @@ void indexInit() {
   indexQhandle = taosInitScheduler(INDEX_QUEUE_SIZE, INDEX_NUM_OF_THREADS, "index");
   indexRefMgt = taosOpenRef(10, indexDestroy);
 }
-void indexCleanUp() {
+void indexCleanup() {
   // refacto later
   taosCleanUpScheduler(indexQhandle);
+  taosCloseRef(indexRefMgt);
 }
 
 typedef struct SIdxColInfo {