From 80c4e77b0bc3986910417575747bf3a8c7c55bce Mon Sep 17 00:00:00 2001
From: Minghao Li <castermode@gmail.com>
Date: Wed, 1 Jun 2022 17:07:14 +0800
Subject: [PATCH] refactor: modify syncNodeAppendEntriesPeersSnapshot

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

diff --git a/source/libs/sync/src/syncReplication.c b/source/libs/sync/src/syncReplication.c
index 7f2968e2d7..bb7036788e 100644
--- a/source/libs/sync/src/syncReplication.c
+++ b/source/libs/sync/src/syncReplication.c
@@ -144,6 +144,14 @@ int32_t syncNodeAppendEntriesPeersSnapshot(SSyncNode* pSyncNode) {
       sInfo("nextIndex:%ld in snapshot: <lastApplyIndex:%ld, lastApplyTerm:%lu>, begin snapshot", nextIndex,
             snapshot.lastApplyIndex, snapshot.lastApplyTerm);
 
+      SyncIndex lastIndex;
+      SyncTerm  lastTerm;
+      ret = syncNodeGetLastIndexTerm(pSyncNode, &lastIndex, &lastTerm);
+      ASSERT(ret == 0);
+
+      ret = syncNodeGetPreIndexTerm(pSyncNode, lastIndex + 1, &preLogIndex, &preLogTerm);
+      ASSERT(ret == 0);
+
       // to claim leader
       SyncAppendEntries* pMsg = syncAppendEntriesBuild(0, pSyncNode->vgId);
       assert(pMsg != NULL);