fix: send snapshot

1ff40068 · Minghao Li · d04c1271 · 1ff40068
隐藏空白更改
内联并排

Showing with 9 addition and 7 deletion

source/libs/sync/src/syncReplication.c source/libs/sync/src/syncReplication.c +9 -7

未找到文件。
--- a/source/libs/sync/src/syncReplication.c
+++ b/source/libs/sync/src/syncReplication.c
@@ -178,15 +178,17 @@ int32_t syncNodeAppendEntriesPeersSnapshot(SSyncNode* pSyncNode) {
      syncNodeAppendEntries(pSyncNode, pDestId, pMsg);
      syncAppendEntriesDestroy(pMsg);

-      SSyncSnapshotSender* pSender = NULL;
-      for (int i = 0; i < pSyncNode->replicaNum; ++i) {
-        if (syncUtilSameId(&((pSyncNode->replicasId)[i]), pDestId)) {
-          pSender = (pSyncNode->senders)[i];
-          break;
+      if (!snapshotSendingFinish) {
+        SSyncSnapshotSender* pSender = NULL;
+        for (int i = 0; i < pSyncNode->replicaNum; ++i) {
+          if (syncUtilSameId(&((pSyncNode->replicasId)[i]), pDestId)) {
+            pSender = (pSyncNode->senders)[i];
+            break;
+          }
        }
+        ASSERT(pSender != NULL);
+        snapshotSenderStart(pSender);
      }
-      ASSERT(pSender != NULL);
-      snapshotSenderStart(pSender);

    } else {
      ret = syncNodeGetPreIndexTerm(pSyncNode, nextIndex, &preLogIndex, &preLogTerm);