From 6591b982450eaf34a4ee767bf693e4fcde470da0 Mon Sep 17 00:00:00 2001
From: Minglei Jin <mljin@taosdata.com>
Date: Tue, 3 Jan 2023 18:30:50 +0800
Subject: [PATCH] fix(tsdb): comment qlist out to please CI

---
 source/dnode/vnode/src/tsdb/tsdbMemTable.c | 8 ++++----
 source/dnode/vnode/src/tsdb/tsdbRead.c     | 3 +++
 source/libs/executor/src/scanoperator.c    | 2 ++
 3 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/source/dnode/vnode/src/tsdb/tsdbMemTable.c b/source/dnode/vnode/src/tsdb/tsdbMemTable.c
index 26fb39f523..8d75661857 100644
--- a/source/dnode/vnode/src/tsdb/tsdbMemTable.c
+++ b/source/dnode/vnode/src/tsdb/tsdbMemTable.c
@@ -750,7 +750,7 @@ int32_t tsdbRefMemTable(SMemTable *pMemTable, void *pQHandle, _tsdb_reseek_func_
 
   int32_t nRef = atomic_fetch_add_32(&pMemTable->nRef, 1);
   ASSERT(nRef > 0);
-
+  /*
   // register handle (todo: take concurrency in consideration)
   *ppNode = taosMemoryMalloc(sizeof(SQueryNode));
   if (*ppNode == NULL) {
@@ -763,21 +763,21 @@ int32_t tsdbRefMemTable(SMemTable *pMemTable, void *pQHandle, _tsdb_reseek_func_
   (*ppNode)->ppNext = &pMemTable->qList.pNext;
   pMemTable->qList.pNext->ppNext = &(*ppNode)->pNext;
   pMemTable->qList.pNext = *ppNode;
-
+  */
 _exit:
   return code;
 }
 
 int32_t tsdbUnrefMemTable(SMemTable *pMemTable, SQueryNode *pNode) {
   int32_t code = 0;
-
+  /*
   // unregister handle (todo: take concurrency in consideration)
   if (pNode) {
     pNode->pNext->ppNext = pNode->ppNext;
     *pNode->ppNext = pNode->pNext;
     taosMemoryFree(pNode);
   }
-
+  */
   int32_t nRef = atomic_sub_fetch_32(&pMemTable->nRef, 1);
   if (nRef == 0) {
     tsdbMemTableDestroy(pMemTable);
diff --git a/source/dnode/vnode/src/tsdb/tsdbRead.c b/source/dnode/vnode/src/tsdb/tsdbRead.c
index 841396c515..d8ecaf9832 100644
--- a/source/dnode/vnode/src/tsdb/tsdbRead.c
+++ b/source/dnode/vnode/src/tsdb/tsdbRead.c
@@ -3927,6 +3927,7 @@ void tsdbReaderClose(STsdbReader* pReader) {
     pReader->pDelIdx = NULL;
   }
 
+  qTrace("tsdb/reader: %p, untake snapshot", pReader);
   tsdbUntakeReadSnap(pReader, pReader->pReadSnap);
 
   taosThreadMutexDestroy(&pReader->readerMutex);
@@ -4065,6 +4066,7 @@ int32_t tsdbReaderResume(STsdbReader* pReader) {
   //  task snapshot
   int32_t numOfTables = taosHashGetSize(pReader->status.pTableMap);
   if (numOfTables > 0) {
+    qTrace("tsdb/reader: %p, take snapshot", pReader);
     code = tsdbTakeReadSnap(pReader, tsdbSetQueryReseek, &pReader->pReadSnap);
     if (code != TSDB_CODE_SUCCESS) {
       goto _err;
@@ -4392,6 +4394,7 @@ SSDataBlock* tsdbRetrieveDataBlock(STsdbReader* pReader, SArray* pIdList) {
 
   SSDataBlock* ret = doRetrieveDataBlock(pTReader);
 
+  qTrace("tsdb/read-retrieve: %p, unlock read mutex", pReader);
   taosThreadMutexUnlock(&pReader->readerMutex);
 
   return ret;
diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 923b535e63..6dd5341b2e 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2554,6 +2554,7 @@ static SSDataBlock* getTableDataBlockImpl(void* param) {
   }
 
   STsdbReader* reader = pInfo->base.dataReader;
+  qTrace("tsdb/read-table-data: %p, enter next reader", reader);
   while (tsdbNextDataBlock(reader)) {
     if (isTaskKilled(pTaskInfo)) {
       T_LONG_JMP(pTaskInfo->env, pTaskInfo->code);
@@ -2588,6 +2589,7 @@ static SSDataBlock* getTableDataBlockImpl(void* param) {
     pOperator->resultInfo.totalRows += pBlock->info.rows;
     pInfo->base.readRecorder.elapsedTime += (taosGetTimestampUs() - st) / 1000.0;
 
+    qTrace("tsdb/read-table-data: %p, close reader", reader);
     tsdbReaderClose(pInfo->base.dataReader);
     pInfo->base.dataReader = NULL;
     return pBlock;
-- 
GitLab