From 41548ceaf59b832eea355182030207df569e1acb Mon Sep 17 00:00:00 2001
From: dmchen <cademfly@hotmail.com>
Date: Fri, 27 Dec 2024 17:30:09 +0800
Subject: [PATCH] add lock

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

diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c
index 1720935e9e..33cc543b09 100644
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -601,8 +601,10 @@ static int32_t snapshotReceiverFinish(SSyncSnapshotReceiver *pReceiver, SyncSnap
     // write data
     sRInfo(pReceiver, "snapshot receiver write about to finish, blockLen:%d seq:%d", pMsg->dataLen, pMsg->seq);
     if (pMsg->dataLen > 0) {
+      (void)taosThreadMutexLock(&pReceiver->writerMutex);
       code = pReceiver->pSyncNode->pFsm->FpSnapshotDoWrite(pReceiver->pSyncNode->pFsm, pReceiver->pWriter, pMsg->data,
                                                            pMsg->dataLen);
+      (void)taosThreadMutexUnlock(&pReceiver->writerMutex);
       if (code != 0) {
         sRError(pReceiver, "failed to finish snapshot receiver write since %s", tstrerror(code));
         TAOS_RETURN(code);