From 96c053c6cf6b022bdb52fe302f1f41b5e4b84d17 Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Wed, 29 Dec 2021 12:27:41 +0000
Subject: [PATCH] more

---
 source/common/src/tmsg.c | 23 +++++++++++++++++------
 1 file changed, 17 insertions(+), 6 deletions(-)

diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index ed96384219..b81143ee62 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -55,12 +55,23 @@ void tmsgInitMsgDecoder(SMsgDecoder *pMD, td_endian_t endian, uint8_t *data, int
 }
 
 void tmsgClearMsgDecoder(SMsgDecoder *pMD) {
-  struct SMDFreeListNode *pNode;
-  for (;;) {
-    pNode = TD_SLIST_HEAD(&(pMD->freeList));
-    if (TD_IS_NULL(pNode)) break;
-    TD_SLIST_POP(&(pMD->freeList));
-    free(pNode);
+  {
+    struct SMDFreeListNode *pNode;
+    for (;;) {
+      pNode = TD_SLIST_HEAD(&(pMD->freeList));
+      if (TD_IS_NULL(pNode)) break;
+      TD_SLIST_POP(&(pMD->freeList));
+      free(pNode);
+    }
+  }
+  {
+    struct SMDListNode *pNode;
+    for (;;) {
+      pNode = TD_SLIST_HEAD(&(pMD->dStack));
+      if (TD_IS_NULL(pNode)) break;
+      TD_SLIST_POP(&(pMD->dStack));
+      free(pNode);
+    }
   }
 }