refactor: modify syncNodeAppendEntriesPeersSnapshot

2022-06-01 17:08:03 +08:00 · 2022-06-01 17:08:03 +08:00 · df4787eff1
parent 80c4e77b0b
commit df4787eff1
1 changed files with 2 additions and 0 deletions
--- a/source/libs/sync/src/syncReplication.c
+++ b/source/libs/sync/src/syncReplication.c
@ -144,6 +144,8 @@ int32_t syncNodeAppendEntriesPeersSnapshot(SSyncNode* pSyncNode) {
      sInfo("nextIndex:%ld in snapshot: <lastApplyIndex:%ld, lastApplyTerm:%lu>, begin snapshot", nextIndex,
            snapshot.lastApplyIndex, snapshot.lastApplyTerm);

+      // do not use next index
+      // always send from new last index + 1
      SyncIndex lastIndex;
      SyncTerm  lastTerm;
      ret = syncNodeGetLastIndexTerm(pSyncNode, &lastIndex, &lastTerm);