From b66583bd02d20eb5de5d8600e6e2de6f2a7f832d Mon Sep 17 00:00:00 2001 From: kailixu Date: Thu, 21 Sep 2023 19:32:54 +0800 Subject: [PATCH] fix: release tsc obj --- source/client/src/clientHb.c | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/source/client/src/clientHb.c b/source/client/src/clientHb.c index 70382f7683..47b4e2aefa 100644 --- a/source/client/src/clientHb.c +++ b/source/client/src/clientHb.c @@ -785,10 +785,13 @@ int32_t hbQueryHbReqHandle(SClientHbKey *connKey, void *param, SClientHbReq *req if (!pTscObj) { tscWarn("tscObj rid %" PRIx64 " not exist", connKey->tscRid); return TSDB_CODE_APP_ERROR; - } else if (atomic_load_8(&pTscObj->dropped) == 1) { - tscDebug("tscObj rid %" PRIx64 " user:%s dropped", connKey->tscRid, pTscObj->user); + } else { + if (atomic_load_8(&pTscObj->dropped) == 1) { + tscDebug("tscObj rid %" PRIx64 " user:%s dropped", connKey->tscRid, pTscObj->user); + releaseTscObj(connKey->tscRid); + return TSDB_CODE_SUCCESS; + } releaseTscObj(connKey->tscRid); - return TSDB_CODE_SUCCESS; } if (hbParam->reqCnt == 0) {