From 56253aedc9994ff729ce95303cbf22f3b23c53a6 Mon Sep 17 00:00:00 2001
From: Minghao Li <castermode@gmail.com>
Date: Wed, 1 Jun 2022 13:40:43 +0800
Subject: [PATCH] refactor: snapshotReSend

---
 source/libs/sync/src/syncSnapshot.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c
index 38d3dc4995..9b099767c7 100644
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -116,6 +116,7 @@ void snapshotSenderStart(SSyncSnapshotSender *pSender) {
 
       // start again
       snapshotSenderDoStart(pSender);
+      pSender->start = true;
     } else {
       // current term, do nothing
       ASSERT(pSender->pSyncNode->pRaftStore->currentTerm == pSender->term);
@@ -297,6 +298,7 @@ void snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) {
   if (!(pReceiver->start)) {
     // start
     snapshotReceiverDoStart(pReceiver);
+    pReceiver->start = true;
 
   } else {
     // already start
@@ -309,6 +311,7 @@ void snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) {
 
     // start again
     snapshotReceiverDoStart(pReceiver);
+    pReceiver->start = true;
 
     ASSERT(0);
   }
-- 
GitLab