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 {