From 5d453ae329762e43f6d023b77a99bc198c83d2e8 Mon Sep 17 00:00:00 2001
From: Jeff Tao <jhtao@taosdata.com>
Date: Fri, 30 Oct 2020 00:03:36 +0000
Subject: [PATCH] add acquire/release for brokenlink processing

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

diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c
index a538b4db87..6f5e3be8ab 100644
--- a/src/sync/src/syncMain.c
+++ b/src/sync/src/syncMain.c
@@ -1105,6 +1105,7 @@ static void syncProcessBrokenLink(void *param) {
   SSyncPeer *pPeer = param;
   SSyncNode *pNode = pPeer->pSyncNode;
 
+  if (taosAcquireRef(tsSyncRefId, pNode) < 0) return;
   pthread_mutex_lock(&(pNode->mutex));
 
   sDebug("%s, TCP link is broken(%s)", pPeer->id, strerror(errno));
@@ -1115,6 +1116,7 @@ static void syncProcessBrokenLink(void *param) {
   }
 
   pthread_mutex_unlock(&(pNode->mutex));
+  taosReleaseRef(tsSyncRefId, pNode);
 }
 
 static void syncSaveFwdInfo(SSyncNode *pNode, uint64_t version, void *mhandle) {
-- 
GitLab