From b6608ec641da0bc39e2b2a7021a93744882196c5 Mon Sep 17 00:00:00 2001 From: kailixu Date: Fri, 22 Sep 2023 05:06:16 +0800 Subject: [PATCH] chore: code optimization for tsc release --- source/client/src/clientHb.c | 16 ++-------------- 1 file changed, 2 insertions(+), 14 deletions(-) diff --git a/source/client/src/clientHb.c b/source/client/src/clientHb.c index 47b4e2aefa..dfcca2f36e 100644 --- a/source/client/src/clientHb.c +++ b/source/client/src/clientHb.c @@ -781,19 +781,6 @@ int32_t hbQueryHbReqHandle(SClientHbKey *connKey, void *param, SClientHbReq *req SHbParam *hbParam = (SHbParam *)param; SCatalog *pCatalog = NULL; - STscObj *pTscObj = (STscObj *)acquireTscObj(connKey->tscRid); - 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); - releaseTscObj(connKey->tscRid); - return TSDB_CODE_SUCCESS; - } - releaseTscObj(connKey->tscRid); - } - if (hbParam->reqCnt == 0) { code = catalogGetHandle(hbParam->clusterId, &pCatalog); if (code != TSDB_CODE_SUCCESS) { @@ -868,7 +855,8 @@ SClientHbBatchReq *hbGatherAllInfo(SAppHbMgr *pAppHbMgr) { SClientHbKey *connKey = &pOneReq->connKey; STscObj *pTscObj = (STscObj *)acquireTscObj(connKey->tscRid); - if (!pTscObj) { + if (!pTscObj || atomic_load_8(&pTscObj->dropped) == 1) { + if (pTscObj) releaseTscObj(connKey->tscRid); continue; }