From a3241613d7f3a2a7eec4dcb4f9ccadfd2802f706 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Thu, 27 Jan 2022 13:29:53 +0800 Subject: [PATCH] fix destroy connection issue --- source/client/src/clientHb.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/source/client/src/clientHb.c b/source/client/src/clientHb.c index f8957f6fd8..f6c473333c 100644 --- a/source/client/src/clientHb.c +++ b/source/client/src/clientHb.c @@ -528,8 +528,12 @@ int hbRegisterConn(SAppHbMgr* pAppHbMgr, int32_t connId, int64_t clusterId, int3 } void hbDeregisterConn(SAppHbMgr* pAppHbMgr, SClientHbKey connKey) { - taosHashRemove(pAppHbMgr->activeInfo, &connKey, sizeof(SClientHbKey)); - taosHashRemove(pAppHbMgr->connInfo, &connKey, sizeof(SClientHbKey)); + int32_t code = 0; + code = taosHashRemove(pAppHbMgr->activeInfo, &connKey, sizeof(SClientHbKey)); + code = taosHashRemove(pAppHbMgr->connInfo, &connKey, sizeof(SClientHbKey)); + if (code) { + return; + } atomic_sub_fetch_32(&pAppHbMgr->connKeyCnt, 1); if (atomic_load_32(&pAppHbMgr->connKeyCnt) <= 0) { appHbMgrCleanup(pAppHbMgr);