enh: send rsp on duplicate msgs in syncSnapBufferRecv

2023-11-02 18:36:01 +08:00 · 2023-11-02 18:36:01 +08:00 · 995a1e1f8e
parent 3221aef1a3
commit 995a1e1f8e
1 changed files with 1 additions and 1 deletions
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@ -862,7 +862,7 @@ static int32_t syncSnapBufferRecv(SSyncSnapshotReceiver *pReceiver, SyncSnapshot
    pRcvBuf->entries[pMsg->seq % pRcvBuf->size] = pMsg;
    ppMsg[0] = NULL;
    pRcvBuf->end = TMAX(pMsg->seq + 1, pRcvBuf->end);
-  } else {
+  } else if (pMsg->seq < pRcvBuf->start) {
    syncSnapSendRsp(pReceiver, pMsg, code);
    goto _out;
  }