fix(sync) if FpEqMsg return error, do not enqueue msg

a2039d8b · Minghao Li · 97942080 · a2039d8b
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

source/libs/sync/src/syncMain.c source/libs/sync/src/syncMain.c +4 -0

未找到文件。
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -1670,8 +1670,12 @@ static void syncNodeEqHeartbeatTimer(void* param, void* tmrId) {
    }
    syncTimeoutDestroy(pSyncMsg);

+    if (gSyncEnv != NULL) {
    taosTmrReset(syncNodeEqHeartbeatTimer, pSyncNode->heartbeatTimerMS, pSyncNode, gSyncEnv->pTimerManager,
                 &pSyncNode->pHeartbeatTimer);
+    } else {
+      sError("sync env is already stop");
+    }
  } else {
    sTrace("==syncNodeEqHeartbeatTimer== heartbeatTimerLogicClock:%" PRIu64 ", heartbeatTimerLogicClockUser:%" PRIu64
           "",