From 1e1612a5fa0dba18b6ead946e14105e0c5f0cc06 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Mon, 15 Jul 2024 10:19:03 +0800 Subject: [PATCH] opti:[TS-4593] transform offset from file to tdb in tmq --- source/dnode/vnode/src/tq/tq.c | 2 +- source/dnode/vnode/src/tq/tqMeta.c | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index bb64a0ccf6..ca1527d5e7 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -655,7 +655,7 @@ int32_t tqProcessSubscribeReq(STQ* pTq, int64_t sversion, char* msg, int32_t msg taosRLockLatch(&pTq->lock); STqHandle* pHandle = NULL; - ret = tqMetaGetHandle(pTq, req.subKey, &pHandle); + (void)tqMetaGetHandle(pTq, req.subKey, &pHandle); //ignore return code taosRUnLockLatch(&pTq->lock); if (pHandle == NULL) { if (req.oldConsumerId != -1) { diff --git a/source/dnode/vnode/src/tq/tqMeta.c b/source/dnode/vnode/src/tq/tqMeta.c index 4b30e79d44..3ddd7d953f 100644 --- a/source/dnode/vnode/src/tq/tqMeta.c +++ b/source/dnode/vnode/src/tq/tqMeta.c @@ -391,7 +391,7 @@ int32_t tqMetaGetHandle(STQ* pTq, const char* key, STqHandle** pHandle) { int vLen = 0; if (tdbTbGet(pTq->pExecStore, key, (int)strlen(key), &data, &vLen) < 0) { tdbFree(data); - return TSDB_CODE_OUT_OF_MEMORY; + return TSDB_CODE_MND_SUBSCRIBE_NOT_EXIST; } STqHandle handle = {0}; if (tqMetaRestoreHandle(pTq, data, vLen, &handle) != 0){ @@ -404,7 +404,7 @@ int32_t tqMetaGetHandle(STQ* pTq, const char* key, STqHandle** pHandle) { tqDestroyTqHandle(&handle); return TSDB_CODE_OUT_OF_MEMORY; } - *pHandle = taosHashGet(pTq->pCheckInfo, key, strlen(key)); + *pHandle = taosHashGet(pTq->pHandle, key, strlen(key)); if(*pHandle == NULL){ return TSDB_CODE_OUT_OF_MEMORY; }