From e91ca30b19a21589cc78393350c957623fa56c91 Mon Sep 17 00:00:00 2001
From: Minghao Li <castermode@gmail.com>
Date: Tue, 12 Jul 2022 20:23:31 +0800
Subject: [PATCH] refactor(sync): add resp ttl clean

---
 source/libs/sync/src/syncRespMgr.c | 2 ++
 source/libs/sync/src/syncTimeout.c | 5 ++++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/source/libs/sync/src/syncRespMgr.c b/source/libs/sync/src/syncRespMgr.c
index 2aaa98b299..8e477a5159 100644
--- a/source/libs/sync/src/syncRespMgr.c
+++ b/source/libs/sync/src/syncRespMgr.c
@@ -146,6 +146,8 @@ void syncRespCleanByTTL(SSyncRespMgr *pObj, int64_t ttl) {
       cbMeta.currentTerm = pSyncNode->pRaftStore->currentTerm;
       cbMeta.flag = 0;
 
+      pStub->rpcMsg.pCont = NULL;
+      pStub->rpcMsg.contLen = 0;
       pSyncNode->pFsm->FpCommitCb(pSyncNode->pFsm, &(pStub->rpcMsg), cbMeta);
     }
 
diff --git a/source/libs/sync/src/syncTimeout.c b/source/libs/sync/src/syncTimeout.c
index 97de75c108..ad5f82900c 100644
--- a/source/libs/sync/src/syncTimeout.c
+++ b/source/libs/sync/src/syncTimeout.c
@@ -20,7 +20,10 @@
 
 int32_t syncNodeTimerRoutine(SSyncNode* ths) {
   syncNodeEventLog(ths, "timer routines ... ");
-  syncRespClean(ths->pSyncRespMgr);
+
+  if (ths->vgId != 1) {
+    syncRespClean(ths->pSyncRespMgr);
+  }
   return 0;
 }