From 1c8a2d696dd038ba213926b2252170b2d0d89f79 Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Tue, 8 Nov 2022 22:59:05 +0800
Subject: [PATCH] fix: send response on enqueue msg failed

---
 source/libs/sync/src/syncMain.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c
index 0d7306e4fd..c6dc62415e 100644
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -719,8 +719,11 @@ int32_t syncNodePropose(SSyncNode* pSyncNode, SRpcMsg* pMsg, bool isWeak) {
     sNTrace(pSyncNode, "propose message, type:%s", TMSG_INFO(pMsg->msgType));
     ret = (*pSyncNode->syncEqMsg)(pSyncNode->msgcb, &rpcMsg);
     if (ret != 0) {
-      terrno = TSDB_CODE_SYN_INTERNAL_ERROR;
+      if (terrno != 0) ret = terrno;
       sError("vgId:%d, failed to enqueue msg since %s", pSyncNode->vgId, terrstr());
+      syncRespMgrDel(pSyncNode->pSyncRespMgr, seqNum);
+      SRpcMsg rsp = {.code = ret, .info = pMsg->info};
+      tmsgSendRsp(&rsp);
     }
   }