• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

taosdata / TDengine / #4937

23 Jan 2026 09:40AM UTC coverage: 66.794% (+0.05%) from 66.746%
#4937

push

travis-ci

web-flow
fix: case failuer caused by the modification of the error description (#34391)

204171 of 305671 relevant lines covered (66.79%)

127025939.33 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

86.35
/source/dnode/vnode/src/tsdb/tsdbMergeTree.c
1
/*
2
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
3
 *
4
 * This program is free software: you can use, redistribute, and/or modify
5
 * it under the terms of the GNU Affero General Public License, version 3
6
 * or later ("AGPL"), as published by the Free Software Foundation.
7
 *
8
 * This program is distributed in the hope that it will be useful, but WITHOUT
9
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10
 * FITNESS FOR A PARTICULAR PURPOSE.
11
 *
12
 * You should have received a copy of the GNU Affero General Public License
13
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
14
 */
15

16
#include "tlrucache.h"
17
#include "tsdb.h"
18
#include "tsdbFSet2.h"
19
#include "tsdbMerge.h"
20
#include "tsdbReadUtil.h"
21
#include "tsdbSttFileRW.h"
22
#include "ttypes.h"
23

24
typedef struct SSttStatisCacheKey {
25
  int64_t suid;
26
  int32_t vgId;
27
  int32_t fid;
28
} SSttStatisCacheKey;
29

30
typedef struct SSttStatisCacheValue {
31
  int64_t commitTs;
32
  SArray *pLevel;  // SArray<SArray<SSttTableRowsInfo>>
33
} SSttStatisCacheValue;
34

35
typedef struct SSttStatisFileCacheInfo {
36
  SLRUCache *    pStatisFileCache;
37
  TdThreadMutex  lock;
38
} SSttStatisFileCacheInfo;
39

40
static SSttStatisFileCacheInfo statisCacheInfo;
41
static TdThreadOnce tsCacheInit = PTHREAD_ONCE_INIT;
42

43
static int32_t getSttTableRowsInfo(SSttStatisCacheValue *pValue, int32_t numOfPKs, int32_t levelIdx, int32_t fileIdx,
44
                                   SSttTableRowsInfo *pSttTableRowsInfo);
45
static int32_t buildSttTableRowsInfoKV(SMergeTreeConf *pConf, int32_t vgId, SSttStatisCacheKey *pKey,
46
                                       SSttStatisCacheValue **pValue);
47
static void    clearStatisInfoCache(SLRUCache *pStatisCache, SSttStatisCacheKey *pKey, LRUHandle **pHandle);
48
static int32_t putStatisInfoIntoCache(SLRUCache *pCache, SSttStatisCacheKey *pKey, SSttStatisCacheValue *pValue,
49
                                      const char *id);
50
static int32_t getStatisInfoFromCache(SLRUCache *pCache, SSttStatisCacheKey *pKey, SSttStatisCacheValue **pValue,
51
                                      LRUHandle **pHandle, const char *id);
52
static void    releaseCacheHandle(SLRUCache *pCache, LRUHandle **pHandle, bool lock);
53
static void    freeStatisFileItems(const void *key, size_t keyLen, void *value, void *ud);
54
static int32_t getCacheValueSize(const SSttStatisCacheValue* pValue);
55

56
static void tLDataIterClose2(SLDataIter *pIter);
57

58
// SLDataIter =================================================
59
int32_t tCreateSttBlockLoadInfo(STSchema *pSchema, int16_t *colList, int32_t numOfCols, SSttBlockLoadInfo **pInfo) {
528,303,547✔
60
  *pInfo = NULL;
528,303,547✔
61

62
  SSttBlockLoadInfo *pLoadInfo = taosMemoryCalloc(1, sizeof(SSttBlockLoadInfo));
528,625,352✔
63
  if (pLoadInfo == NULL) {
528,205,779✔
64
    return terrno;
×
65
  }
66

67
  pLoadInfo->blockData[0].sttBlockIndex = -1;
528,205,779✔
68
  pLoadInfo->blockData[1].sttBlockIndex = -1;
528,219,067✔
69

70
  pLoadInfo->currentLoadBlockIndex = 1;
528,285,213✔
71

72
  int32_t code = tBlockDataCreate(&pLoadInfo->blockData[0].data);
528,437,351✔
73
  if (code) {
528,858,006✔
74
    taosMemoryFreeClear(pLoadInfo);
×
75
    return code;
×
76
  }
77

78
  code = tBlockDataCreate(&pLoadInfo->blockData[1].data);
528,858,006✔
79
  if (code) {
528,829,387✔
80
    taosMemoryFreeClear(pLoadInfo);
×
81
    return code;
×
82
  }
83

84
  pLoadInfo->aSttBlk = taosArrayInit(4, sizeof(SSttBlk));
528,829,387✔
85
  if (pLoadInfo->aSttBlk == NULL) {
528,825,348✔
86
    taosMemoryFreeClear(pLoadInfo);
×
87
    return terrno;
×
88
  }
89

90
  pLoadInfo->pSchema = pSchema;
528,876,721✔
91
  pLoadInfo->colIds = colList;
528,898,705✔
92
  pLoadInfo->numOfCols = numOfCols;
528,874,659✔
93

94
  *pInfo = pLoadInfo;
528,979,803✔
95
  return code;
528,934,120✔
96
}
97

98
static void freeItem(void *pValue) {
2,147,483,647✔
99
  SValue *p = (SValue *)pValue;
2,147,483,647✔
100
  if (IS_VAR_DATA_TYPE(p->type) || p->type == TSDB_DATA_TYPE_DECIMAL) {
2,147,483,647✔
101
    taosMemoryFree(p->pData);
107,266,649✔
102
  }
103
}
2,147,483,647✔
104

105
void destroySttBlockLoadInfo(SSttBlockLoadInfo *pLoadInfo) {
528,693,262✔
106
  if (pLoadInfo == NULL) {
528,693,262✔
107
    return;
×
108
  }
109

110
  pLoadInfo->currentLoadBlockIndex = 1;
528,693,262✔
111

112
  SBlockDataInfo *pInfo = &pLoadInfo->blockData[0];
528,921,191✔
113
  tBlockDataDestroy(&pInfo->data);
528,817,906✔
114
  pInfo->sttBlockIndex = -1;
528,768,417✔
115
  pInfo->pin = false;
528,614,371✔
116

117
  pInfo = &pLoadInfo->blockData[1];
528,874,183✔
118
  tBlockDataDestroy(&pInfo->data);
528,928,881✔
119
  pInfo->sttBlockIndex = -1;
528,990,615✔
120
  pInfo->pin = false;
528,776,761✔
121

122
  taosArrayDestroy(pLoadInfo->info.pUid);
528,995,388✔
123
  taosArrayDestroy(pLoadInfo->info.pCount);
528,878,985✔
124
  taosArrayDestroy(pLoadInfo->info.pFirstTs);
528,771,029✔
125
  taosArrayDestroy(pLoadInfo->info.pLastTs);
528,921,685✔
126

127
  taosArrayDestroyEx(pLoadInfo->info.pFirstKey, freeItem);
528,948,622✔
128
  taosArrayDestroyEx(pLoadInfo->info.pLastKey, freeItem);
528,770,616✔
129

130
  pLoadInfo->info.pUid = NULL;
528,960,237✔
131
  pLoadInfo->info.pFirstKey = NULL;
528,954,844✔
132
  pLoadInfo->info.pLastKey = NULL;
528,805,433✔
133
  pLoadInfo->info.pCount = NULL;
528,974,265✔
134
  pLoadInfo->info.pFirstTs = NULL;
528,929,881✔
135
  pLoadInfo->info.pLastTs = NULL;
528,900,453✔
136

137
  taosArrayDestroy(pLoadInfo->aSttBlk);
528,714,536✔
138
  taosMemoryFree(pLoadInfo);
528,919,076✔
139
}
140

141
void destroyLDataIter(SLDataIter *pIter) {
528,954,931✔
142
  tLDataIterClose2(pIter);
528,954,931✔
143
  destroySttBlockLoadInfo(pIter->pBlockLoadInfo);
528,878,162✔
144
  taosMemoryFree(pIter);
528,896,550✔
145
}
528,760,394✔
146

147
void destroySttBlockReader(SArray *pLDataIterArray, SSttBlockLoadCostInfo *pLoadCost) {
754,781,714✔
148
  if (pLDataIterArray == NULL) {
754,781,714✔
149
    return;
3,633,559✔
150
  }
151

152
  int32_t numOfLevel = taosArrayGetSize(pLDataIterArray);
751,148,155✔
153
  for (int32_t i = 0; i < numOfLevel; ++i) {
1,280,097,309✔
154
    SArray *pList = taosArrayGetP(pLDataIterArray, i);
528,812,049✔
155
    for (int32_t j = 0; j < taosArrayGetSize(pList); ++j) {
1,057,708,561✔
156
      SLDataIter *pIter = taosArrayGetP(pList, j);
529,009,652✔
157
      if (pIter->pBlockLoadInfo != NULL) {
529,002,367✔
158
        SSttBlockLoadCostInfo *pCost = &pIter->pBlockLoadInfo->cost;
529,034,217✔
159
        if (pLoadCost != NULL) {
529,038,285✔
160
          pLoadCost->loadBlocks += pCost->loadBlocks;
528,576,330✔
161
          pLoadCost->loadStatisBlocks += pCost->loadStatisBlocks;
528,625,506✔
162
          pLoadCost->blockElapsedTime += pCost->blockElapsedTime;
528,610,706✔
163
          pLoadCost->statisElapsedTime += pCost->statisElapsedTime;
528,616,462✔
164
        }
165
      }
166

167
      destroyLDataIter(pIter);
529,074,878✔
168
    }
169

170
    taosArrayDestroy(pList);
528,659,692✔
171
  }
172

173
  taosArrayDestroy(pLDataIterArray);
751,285,260✔
174
}
175

176
// choose the unpinned slot to load next data block
177
static void updateBlockLoadSlot(SSttBlockLoadInfo *pLoadInfo) {
220,082,060✔
178
  int32_t nextSlotIndex = pLoadInfo->currentLoadBlockIndex ^ 1;
220,082,060✔
179
  if (pLoadInfo->blockData[nextSlotIndex].pin) {
220,215,960✔
180
    nextSlotIndex = nextSlotIndex ^ 1;
×
181
  }
182

183
  pLoadInfo->currentLoadBlockIndex = nextSlotIndex;
220,139,610✔
184
}
220,167,627✔
185

186
static int32_t loadLastBlock(SLDataIter *pIter, const char *idStr, SBlockData **pResBlock) {
2,147,483,647✔
187
  if (pResBlock != NULL) {
2,147,483,647✔
188
    *pResBlock = NULL;
2,147,483,647✔
189
  }
190

191
  int32_t            code = 0;
2,147,483,647✔
192
  SSttBlockLoadInfo *pInfo = pIter->pBlockLoadInfo;
2,147,483,647✔
193

194
  if (pInfo->blockData[0].sttBlockIndex == pIter->iSttBlk) {
2,147,483,647✔
195
    if (pInfo->currentLoadBlockIndex != 0) {
2,147,483,647✔
196
      tsdbDebug("current load index is set to 0, block index:%d, fileVer:%" PRId64 ", due to uid:%" PRIu64
67,819✔
197
                ", load data, %s",
198
                pIter->iSttBlk, pIter->cid, pIter->uid, idStr);
199
      pInfo->currentLoadBlockIndex = 0;
67,819✔
200
    }
201

202
    *pResBlock = &pInfo->blockData[0].data;
2,147,483,647✔
203
    return code;
2,147,483,647✔
204
  }
205

206
  if (pInfo->blockData[1].sttBlockIndex == pIter->iSttBlk) {
2,147,483,647✔
207
    if (pInfo->currentLoadBlockIndex != 1) {
2,147,483,647✔
208
      tsdbDebug("current load index is set to 1, block index:%d, fileVer:%" PRId64 ", due to uid:%" PRIu64
91,537✔
209
                ", load data, %s",
210
                pIter->iSttBlk, pIter->cid, pIter->uid, idStr);
211
      pInfo->currentLoadBlockIndex = 1;
91,537✔
212
    }
213

214
    *pResBlock = &pInfo->blockData[1].data;
2,147,483,647✔
215
    return code;
2,147,483,647✔
216
  }
217

218
  if (pIter->pSttBlk == NULL || pInfo->pSchema == NULL) {
220,052,741✔
219
    return code;
×
220
  }
221

222
  updateBlockLoadSlot(pInfo);
220,120,039✔
223
  int64_t st = taosGetTimestampUs();
220,238,046✔
224

225
  SBlockData *pBlock = &pInfo->blockData[pInfo->currentLoadBlockIndex].data;
220,238,046✔
226
  code = tsdbSttFileReadBlockDataByColumn(pIter->pReader, pIter->pSttBlk, pBlock, pInfo->pSchema, &pInfo->colIds[1],
220,046,589✔
227
                                          pInfo->numOfCols - 1);
220,129,631✔
228
  if (code != TSDB_CODE_SUCCESS) {
220,184,793✔
229
    return code;
×
230
  }
231

232
  double el = (taosGetTimestampUs() - st) / 1000.0;
220,163,235✔
233
  pInfo->cost.blockElapsedTime += el;
220,163,235✔
234
  pInfo->cost.loadBlocks += 1;
220,188,763✔
235

236
  tsdbDebug("read stt block, total load:%" PRId64 ", trigger by uid:%" PRIu64 ", stt-fileVer:%" PRId64
220,175,132✔
237
            ", last block index:%d, entry:%d, rows:%d, uidRange:%" PRId64 "-%" PRId64 " tsRange:%" PRId64 "-%" PRId64
238
            " %p, elapsed time:%.2f ms, %s",
239
            pInfo->cost.loadBlocks, pIter->uid, pIter->cid, pIter->iSttBlk, pInfo->currentLoadBlockIndex, pBlock->nRow,
240
            pIter->pSttBlk->minUid, pIter->pSttBlk->maxUid, pIter->pSttBlk->minKey, pIter->pSttBlk->maxKey, pBlock, el,
241
            idStr);
242

243
  pInfo->blockData[pInfo->currentLoadBlockIndex].sttBlockIndex = pIter->iSttBlk;
220,175,132✔
244
  pIter->iRow = (pIter->backward) ? pInfo->blockData[pInfo->currentLoadBlockIndex].data.nRow : -1;
220,165,757✔
245

246
  tsdbDebug("last block index list:%d, %d, rowIndex:%d %s", pInfo->blockData[0].sttBlockIndex,
220,220,223✔
247
            pInfo->blockData[1].sttBlockIndex, pIter->iRow, idStr);
248

249
  *pResBlock = &pInfo->blockData[pInfo->currentLoadBlockIndex].data;
220,220,223✔
250
  return code;
220,116,800✔
251
}
252

253
// find the earliest block that contains the required records
254
static FORCE_INLINE int32_t findEarliestIndex(int32_t index, uint64_t uid, const SSttBlk *pBlockList, int32_t num,
255
                                              int32_t backward) {
256
  int32_t i = index;
298,431,522✔
257
  int32_t step = backward ? 1 : -1;
298,431,522✔
258
  while (i >= 0 && i < num && uid >= pBlockList[i].minUid && uid <= pBlockList[i].maxUid) {
600,363,957✔
259
    i += step;
301,932,435✔
260
  }
261
  return i - step;
298,369,369✔
262
}
263

264
static int32_t binarySearchForStartBlock(SSttBlk *pBlockList, int32_t num, uint64_t uid, int32_t backward) {
780,288,473✔
265
  int32_t midPos = -1;
780,288,473✔
266
  if (num <= 0) {
780,288,473✔
267
    return -1;
401,346,953✔
268
  }
269

270
  int32_t firstPos = 0;
378,941,520✔
271
  int32_t lastPos = num - 1;
378,941,520✔
272

273
  // find the first position which is bigger than the key
274
  if ((uid > pBlockList[lastPos].maxUid) || (uid < pBlockList[firstPos].minUid)) {
378,941,520✔
275
    return -1;
80,757,709✔
276
  }
277

278
  while (1) {
20,160,566✔
279
    if (uid >= pBlockList[firstPos].minUid && uid <= pBlockList[firstPos].maxUid) {
318,506,166✔
280
      return findEarliestIndex(firstPos, uid, pBlockList, num, backward);
285,399,774✔
281
    }
282

283
    if (uid > pBlockList[lastPos].maxUid || uid < pBlockList[firstPos].minUid) {
33,104,285✔
284
      return -1;
46,203✔
285
    }
286

287
    int32_t numOfRows = lastPos - firstPos + 1;
33,132,321✔
288
    midPos = (numOfRows >> 1u) + firstPos;
33,132,321✔
289

290
    if (uid < pBlockList[midPos].minUid) {
33,132,321✔
291
      lastPos = midPos - 1;
9,432,389✔
292
    } else if (uid > pBlockList[midPos].maxUid) {
23,697,858✔
293
      firstPos = midPos + 1;
10,728,177✔
294
    } else {
295
      return findEarliestIndex(midPos, uid, pBlockList, num, backward);
12,969,595✔
296
    }
297
  }
298
}
299

300
static FORCE_INLINE int32_t findEarliestRow(int32_t index, uint64_t uid, const uint64_t *uidList, int32_t num,
301
                                            int32_t backward) {
302
  int32_t i = index;
297,475,952✔
303
  int32_t step = backward ? 1 : -1;
297,475,952✔
304
  while (i >= 0 && i < num && uid == uidList[i]) {
2,147,483,647✔
305
    i += step;
2,147,483,647✔
306
  }
307
  return i - step;
297,552,911✔
308
}
309

310
static int32_t binarySearchForStartRowIndex(uint64_t *uidList, int32_t num, uint64_t uid, int32_t backward) {
297,491,349✔
311
  int32_t firstPos = 0;
297,491,349✔
312
  int32_t lastPos = num - 1;
297,491,349✔
313

314
  // find the first position which is bigger than the key
315
  if ((uid > uidList[lastPos]) || (uid < uidList[firstPos])) {
297,491,349✔
316
    return -1;
×
317
  }
318

319
  while (1) {
106,584,499✔
320
    if (uid == uidList[firstPos]) {
404,159,953✔
321
      return findEarliestRow(firstPos, uid, uidList, num, backward);
200,288,553✔
322
    }
323

324
    if (uid > uidList[lastPos] || uid < uidList[firstPos]) {
203,873,473✔
325
      return -1;
33,280✔
326
    }
327

328
    int32_t numOfRows = lastPos - firstPos + 1;
203,836,746✔
329
    int32_t midPos = (numOfRows >> 1u) + firstPos;
203,836,746✔
330

331
    if (uid < uidList[midPos]) {
203,836,746✔
332
      lastPos = midPos - 1;
35,801,952✔
333
    } else if (uid > uidList[midPos]) {
168,043,083✔
334
      firstPos = midPos + 1;
70,782,547✔
335
    } else {
336
      return findEarliestRow(midPos, uid, uidList, num, backward);
97,264,358✔
337
    }
338
  }
339
}
340

341
static int32_t extractSttBlockInfo(SLDataIter *pIter, const TSttBlkArray *pArray, SSttBlockLoadInfo *pBlockLoadInfo,
528,474,300✔
342
                                   uint64_t suid) {
343
  void   *px = NULL;
528,474,300✔
344
  int32_t code = TSDB_CODE_SUCCESS;
528,474,300✔
345
  if (TARRAY2_SIZE(pArray) <= 0) {
528,474,300✔
346
    return code;
138,409✔
347
  }
348

349
  SSttBlk *pStart = &pArray->data[0];
528,610,414✔
350
  SSttBlk *pEnd = &pArray->data[TARRAY2_SIZE(pArray) - 1];
528,643,741✔
351

352
  // all identical
353
  if (pStart->suid == pEnd->suid) {
528,728,785✔
354
    if (pStart->suid != suid) {  // no qualified stt block existed
411,240,121✔
355
      taosArrayClear(pBlockLoadInfo->aSttBlk);
226,058,162✔
356
      pIter->iSttBlk = -1;
226,092,784✔
357
      return TSDB_CODE_SUCCESS;
226,117,410✔
358
    } else {  // all blocks are qualified
359
      taosArrayClear(pBlockLoadInfo->aSttBlk);
185,007,344✔
360
      px = taosArrayAddBatch(pBlockLoadInfo->aSttBlk, pArray->data, pArray->size);
185,215,269✔
361
      if (px == NULL) {
185,282,905✔
362
        return terrno;
×
363
      }
364
    }
365
  } else {
366
    SArray *pTmp = taosArrayInit(TARRAY2_SIZE(pArray), sizeof(SSttBlk));
117,419,885✔
367
    if (pTmp == NULL) {
117,450,928✔
368
      return terrno;
×
369
    }
370

371
    for (int32_t i = 0; i < TARRAY2_SIZE(pArray); ++i) {
379,608,270✔
372
      SSttBlk *p = &pArray->data[i];
317,575,888✔
373
      if (p->suid < suid) {
317,569,432✔
374
        continue;
193,098,042✔
375
      }
376

377
      if (p->suid == suid) {
124,492,409✔
378
        void *px = taosArrayPush(pTmp, p);
69,058,782✔
379
        if (px == NULL) {
69,058,782✔
380
          code = terrno;
×
381
          break;
×
382
        }
383
      } else if (p->suid > suid) {
55,438,688✔
384
        break;
55,437,700✔
385
      }
386
    }
387

388
    taosArrayDestroy(pBlockLoadInfo->aSttBlk);
117,420,345✔
389
    pBlockLoadInfo->aSttBlk = pTmp;
117,440,715✔
390
  }
391

392
  return code;
302,597,229✔
393
}
394

395
static int32_t tValueDupPayload(SValue *pVal) {
277,340,524✔
396
  if (IS_VAR_DATA_TYPE(pVal->type) || pVal->type == TSDB_DATA_TYPE_DECIMAL) {
277,340,524✔
397
    char *p = (char *)pVal->pData;
107,253,178✔
398
    char *pBuf = taosMemoryMalloc(pVal->nData);
107,242,583✔
399
    if (pBuf == NULL) {
107,249,455✔
400
      return terrno;
×
401
    }
402

403
    memcpy(pBuf, p, pVal->nData);
107,249,455✔
404
    pVal->pData = (uint8_t *)pBuf;
107,251,147✔
405
  }
406

407
  return TSDB_CODE_SUCCESS;
277,368,974✔
408
}
409

410
static int32_t loadSttStatisticsBlockData(SSttFileReader *pSttFileReader, SSttBlockLoadInfo *pBlockLoadInfo,
528,583,202✔
411
                                          TStatisBlkArray *pStatisBlkArray, uint64_t suid, const char *id) {
412
  int32_t code = TSDB_CODE_SUCCESS;
528,583,202✔
413
  int32_t lino = 0;
528,583,202✔
414
  void   *px = NULL;
528,583,202✔
415
  int32_t startIndex = 0;
528,583,202✔
416
  int32_t ret = 0;
528,583,202✔
417

418
  int32_t numOfBlocks = TARRAY2_SIZE(pStatisBlkArray);
528,583,202✔
419
  if (numOfBlocks <= 0) {
528,722,062✔
420
    return code;
138,409✔
421
  }
422

423
  while ((startIndex < numOfBlocks) && (pStatisBlkArray->data[startIndex].maxTbid.suid < suid)) {
693,422,162✔
424
    ++startIndex;
164,838,509✔
425
  }
426

427
  if (startIndex >= numOfBlocks || pStatisBlkArray->data[startIndex].minTbid.suid > suid) {
528,605,815✔
428
    return 0;
262,461,591✔
429
  }
430

431
  int32_t endIndex = startIndex;
266,088,286✔
432
  while (endIndex < numOfBlocks && pStatisBlkArray->data[endIndex].minTbid.suid <= suid) {
535,756,199✔
433
    ++endIndex;
269,667,913✔
434
  }
435

436
  int32_t num = endIndex - startIndex;
266,029,737✔
437
  pBlockLoadInfo->cost.loadStatisBlocks += num;
266,029,737✔
438

439
  STbStatisBlock block;
266,165,203✔
440
  code = tStatisBlockInit(&block);
266,204,243✔
441
  QUERY_CHECK_CODE(code, lino, _end);
266,218,617✔
442

443
  int64_t st = taosGetTimestampUs();
266,216,193✔
444

445
  for (int32_t k = startIndex; k < endIndex; ++k) {
535,905,904✔
446
    code = tsdbSttFileReadStatisBlock(pSttFileReader, &pStatisBlkArray->data[k], &block);
269,599,473✔
447
    QUERY_CHECK_CODE(code, lino, _end);
269,720,328✔
448

449
    int32_t i = 0;
269,720,328✔
450
    int32_t rows = block.numOfRecords;
269,720,328✔
451
    while (i < rows && ((int64_t *)block.suids.data)[i] != suid) {
367,912,441✔
452
      ++i;
98,192,113✔
453
    }
454

455
    // existed
456
    if (i < rows) {
269,751,248✔
457
      SSttTableRowsInfo *pInfo = &pBlockLoadInfo->info;
251,642,486✔
458

459
      if (pInfo->pUid == NULL) {
251,636,508✔
460
        pInfo->pUid = taosArrayInit(rows, sizeof(int64_t));
248,113,492✔
461
        pInfo->pFirstTs = taosArrayInit(rows, sizeof(int64_t));
248,134,273✔
462
        pInfo->pLastTs = taosArrayInit(rows, sizeof(int64_t));
248,133,396✔
463
        pInfo->pCount = taosArrayInit(rows, sizeof(int64_t));
248,119,568✔
464

465
        pInfo->pFirstKey = taosArrayInit(rows, sizeof(SValue));
248,135,761✔
466
        pInfo->pLastKey = taosArrayInit(rows, sizeof(SValue));
248,073,830✔
467

468
        if (pInfo->pUid == NULL || pInfo->pFirstTs == NULL || pInfo->pLastTs == NULL || pInfo->pCount == NULL ||
248,127,164✔
469
            pInfo->pFirstKey == NULL || pInfo->pLastKey == NULL) {
248,123,178✔
470
          code = terrno;
×
471
          goto _end;
×
472
        }
473

474
        pInfo->memSize = sizeof(SSttTableRowsInfo) + sizeof(SArray) * 6;
248,133,084✔
475
      }
476

477
      if (pStatisBlkArray->data[k].maxTbid.suid == suid) {
251,606,030✔
478
        int32_t size = rows - i;
235,359,761✔
479
        int32_t offset = i * sizeof(int64_t);
235,359,761✔
480

481
        px = taosArrayAddBatch(pInfo->pUid, tBufferGetDataAt(&block.uids, offset), size);
235,359,761✔
482
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
235,352,400✔
483

484
        px = taosArrayAddBatch(pInfo->pFirstTs, tBufferGetDataAt(&block.firstKeyTimestamps, offset), size);
235,352,400✔
485
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
235,331,735✔
486

487
        px = taosArrayAddBatch(pInfo->pLastTs, tBufferGetDataAt(&block.lastKeyTimestamps, offset), size);
235,331,735✔
488
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
235,327,977✔
489

490
        px = taosArrayAddBatch(pInfo->pCount, tBufferGetDataAt(&block.counts, offset), size);
235,327,977✔
491
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
235,378,598✔
492

493
        pInfo->memSize += size * sizeof(int64_t) * 4;
235,378,598✔
494
        pInfo->memSize += size * sizeof(SValue) * 2;
235,326,430✔
495

496
        if (block.numOfPKs > 0) {
235,264,506✔
497
          SValue vFirst = {0}, vLast = {0};
82,718,836✔
498
          for (int32_t f = i; f < rows; ++f) {
207,676,237✔
499
            code = tValueColumnGet(&block.firstKeyPKs[0], f, &vFirst);
124,947,793✔
500
            TSDB_CHECK_CODE(code, lino, _end);
124,941,421✔
501

502
            code = tValueDupPayload(&vFirst);
124,941,421✔
503
            TSDB_CHECK_CODE(code, lino, _end);
124,958,654✔
504

505
            px = taosArrayPush(pInfo->pFirstKey, &vFirst);
124,958,654✔
506
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
124,981,030✔
507

508
            // todo add api to clone the original data
509
            code = tValueColumnGet(&block.lastKeyPKs[0], f, &vLast);
124,981,030✔
510
            TSDB_CHECK_CODE(code, lino, _end);
124,973,677✔
511

512
            code = tValueDupPayload(&vLast);
124,973,677✔
513
            TSDB_CHECK_CODE(code, lino, _end);
124,981,030✔
514

515
            px = taosArrayPush(pInfo->pLastKey, &vLast);
124,981,030✔
516
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
124,969,603✔
517

518
            pInfo->memSize += (IS_VAR_DATA_TYPE(vFirst.type) || vFirst.type == TSDB_DATA_TYPE_DECIMAL)? (vFirst.nData + vLast.nData):0;
124,969,603✔
519
          }
520
        } else {
521
          // SValue vFirst = {0}; is equal array init with zeroed data
522
          px = taosArrayReserve(pInfo->pFirstKey, size);
152,545,670✔
523
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
152,600,959✔
524
          px = taosArrayReserve(pInfo->pLastKey, size);
152,600,959✔
525
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
152,634,601✔
526
        }
527
      } else {
528
        STbStatisRecord record = {0};
16,255,045✔
529
        while (i < rows) {
41,072,997✔
530
          code = tStatisBlockGet(&block, i, &record);
41,071,588✔
531
          TSDB_CHECK_CODE(code, lino, _end);
41,082,387✔
532

533
          if (record.suid != suid) {
41,082,387✔
534
            break;
16,271,390✔
535
          }
536

537
          px = taosArrayPush(pInfo->pUid, &record.uid);
24,810,997✔
538
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
24,815,114✔
539

540
          px = taosArrayPush(pInfo->pCount, &record.count);
24,815,114✔
541
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
24,818,049✔
542

543
          px = taosArrayPush(pInfo->pFirstTs, &record.firstKey.ts);
24,818,049✔
544
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
24,821,042✔
545

546
          px = taosArrayPush(pInfo->pLastTs, &record.lastKey.ts);
24,821,042✔
547
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
24,811,937✔
548

549
          pInfo->memSize += (sizeof(int64_t) * 4 + sizeof(SValue) * 2);
24,811,937✔
550

551
          if (record.firstKey.numOfPKs > 0) {
24,796,789✔
552
            SValue first = record.firstKey.pks[0];
13,719,544✔
553
            code = tValueDupPayload(&first);
13,720,129✔
554
            TSDB_CHECK_CODE(code, lino, _end);
13,719,544✔
555

556
            px = taosArrayPush(pInfo->pFirstKey, &first);
13,719,544✔
557
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
13,720,129✔
558

559
            SValue last = record.lastKey.pks[0];
13,720,129✔
560
            code = tValueDupPayload(&last);
13,720,129✔
561
            TSDB_CHECK_CODE(code, lino, _end);
13,720,714✔
562

563
            px = taosArrayPush(pInfo->pLastKey, &last);
13,720,714✔
564
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
13,720,714✔
565

566
            pInfo->memSize += (IS_VAR_DATA_TYPE(first.type) || first.type == TSDB_DATA_TYPE_DECIMAL)? (first.nData + last.nData):0;
13,720,714✔
567
          } else {
568
            // append empty value, SValue v = {0}; 
569
            px = taosArrayReserve(pInfo->pFirstKey, 1);
11,077,245✔
570
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
11,091,236✔
571

572
            px = taosArrayReserve(pInfo->pLastKey, 1);
11,091,236✔
573
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
11,087,731✔
574
          }
575

576
          i += 1;
24,808,445✔
577
        }
578
      }
579
    }
580
  }
581

582
_end:
266,357,034✔
583
  tStatisBlockDestroy(&block);
266,177,425✔
584
  if (code != 0) {
266,162,149✔
585
    tsdbError("%s error happens at:%s line number: %d, code:%s", id, __func__, lino, tstrerror(code));
×
586
  } else {
587
    double el = (taosGetTimestampUs() - st) / 1000.0;
266,216,388✔
588
    pBlockLoadInfo->cost.statisElapsedTime += el;
266,216,388✔
589

590
    tsdbDebug("%s load %d statis blocks into buf, elapsed time:%.2fms", id, num, el);
266,163,749✔
591
  }
592
  return code;
266,159,042✔
593
}
594

595
static int32_t doLoadSttFilesBlk(SSttBlockLoadInfo *pBlockLoadInfo, SLDataIter *pIter, int64_t suid,
528,373,445✔
596
                                 _load_tomb_fn loadTombFn, void *pReader1, const char *idStr, bool loadFromDisk) {
597
  int64_t st = taosGetTimestampUs();
528,808,137✔
598

599
  const TSttBlkArray *pSttBlkArray = NULL;
528,808,137✔
600
  pBlockLoadInfo->sttBlockLoaded = true;
528,910,574✔
601

602
  // load the stt block info for each stt-block
603
  int32_t code = tsdbSttFileReadSttBlk(pIter->pReader, &pSttBlkArray);
528,836,685✔
604
  if (code != TSDB_CODE_SUCCESS) {
528,700,647✔
605
    tsdbError("load stt blk failed, code:%s, %s", tstrerror(code), idStr);
×
606
    return code;
×
607
  }
608

609
  // load the stt block info for each stt file block
610
  code = extractSttBlockInfo(pIter, pSttBlkArray, pBlockLoadInfo, suid);
528,700,647✔
611
  if (code != TSDB_CODE_SUCCESS) {
528,802,829✔
612
    tsdbError("load stt block info failed, code:%s, %s", tstrerror(code), idStr);
204,288✔
613
    return code;
×
614
  }
615

616
  if (loadFromDisk) {
528,598,647✔
617
    // load stt statistics block for all stt-blocks, to decide if the data of queried table exists in current stt file
618
    TStatisBlkArray *pStatisBlkArray = NULL;
528,553,884✔
619
    code = tsdbSttFileReadStatisBlk(pIter->pReader, (const TStatisBlkArray **)&pStatisBlkArray);
528,690,758✔
620
    if (code != TSDB_CODE_SUCCESS) {
528,710,351✔
621
      tsdbError("failed to load stt block statistics, code:%s, %s", tstrerror(code), idStr);
×
622
      return code;
×
623
    }
624

625
    // load statistics block for all tables in current stt file
626
    code = loadSttStatisticsBlockData(pIter->pReader, pIter->pBlockLoadInfo, pStatisBlkArray, suid, idStr);
528,710,351✔
627
    if (code != TSDB_CODE_SUCCESS) {
528,543,852✔
628
      tsdbError("failed to load stt statistics block data, code:%s, %s", tstrerror(code), idStr);
×
629
      return code;
×
630
    }
631
  } else {
632
    tsdbDebug("stt block statis info loaded from cache, %s", idStr);
44,763✔
633
  }
634

635
  code = loadTombFn(pReader1, pIter->pReader, pIter->pBlockLoadInfo);
528,832,720✔
636

637
  double el = (taosGetTimestampUs() - st) / 1000.0;
528,754,706✔
638
  tsdbDebug("load the stt file blk info completed, elapsed time:%.2fms, %s", el, idStr);
528,754,706✔
639
  return code;
528,880,129✔
640
}
641

642
static int32_t uidComparFn(const void *p1, const void *p2) {
608,198,496✔
643
  const uint64_t *pFirst = p1;
608,198,496✔
644
  const uint64_t *pVal = p2;
608,198,496✔
645

646
  if (*pFirst == *pVal) {
608,198,496✔
647
    return 0;
298,421,925✔
648
  } else {
649
    return *pFirst < *pVal ? -1 : 1;
309,938,624✔
650
  }
651
}
652

653
static void setSttInfoForCurrentTable(SSttBlockLoadInfo *pLoadInfo, uint64_t uid, SSttKeyRange *pRange,
780,440,220✔
654
                                      int64_t *numOfRows) {
655
  if (pRange == NULL || taosArrayGetSize(pLoadInfo->info.pUid) == 0) {
780,440,220✔
656
    return;
401,360,496✔
657
  }
658

659
  int32_t index = taosArraySearchIdx(pLoadInfo->info.pUid, &uid, uidComparFn, TD_EQ);
379,186,319✔
660
  if (index >= 0) {
379,146,225✔
661
    pRange->skey.ts = *(int64_t *)taosArrayGet(pLoadInfo->info.pFirstTs, index);
298,374,253✔
662
    pRange->ekey.ts = *(int64_t *)taosArrayGet(pLoadInfo->info.pLastTs, index);
298,436,712✔
663

664
    *numOfRows += *(int64_t *)taosArrayGet(pLoadInfo->info.pCount, index);
298,360,655✔
665

666
    if (pRange->skey.numOfPKs > 0) {
298,383,237✔
667
      memcpy(&pRange->skey.pks[0], taosArrayGet(pLoadInfo->info.pFirstKey, index), sizeof(SValue));
124,268,880✔
668
      memcpy(&pRange->ekey.pks[0], taosArrayGet(pLoadInfo->info.pLastKey, index), sizeof(SValue));
124,251,143✔
669
    }
670
  }
671
}
672

673
int32_t tLDataIterOpen2(SLDataIter *pIter, SSttFileReader *pSttFileReader, int32_t cid, int8_t backward,
780,513,977✔
674
                        SMergeTreeConf *pConf, SSttBlockLoadInfo *pBlockLoadInfo, SSttKeyRange *pKeyRange,
675
                        int64_t *numOfRows, const char *idStr, bool loadFromDisk) {
676
  int32_t code = TSDB_CODE_SUCCESS;
780,513,977✔
677

678
  pIter->uid = pConf->uid;
780,513,977✔
679
  pIter->cid = cid;
780,813,324✔
680
  pIter->backward = backward;
780,787,577✔
681
  pIter->verRange.minVer = pConf->verRange.minVer;
780,577,865✔
682
  pIter->verRange.maxVer = pConf->verRange.maxVer;
780,786,607✔
683
  pIter->timeWindow.skey = pConf->timewindow.skey;
780,397,232✔
684
  pIter->timeWindow.ekey = pConf->timewindow.ekey;
780,806,765✔
685

686
  pIter->pStartRowKey = pConf->pCurRowKey;
780,479,458✔
687
  pIter->pReader = pSttFileReader;
780,547,915✔
688
  pIter->pBlockLoadInfo = pBlockLoadInfo;
780,530,413✔
689

690
  // open stt file failed, ignore and continue
691
  if (pIter->pReader == NULL) {
780,284,787✔
692
    tsdbError("stt file reader is null, %s", idStr);
×
693
    pIter->pSttBlk = NULL;
×
694
    pIter->iSttBlk = -1;
×
695
    return TSDB_CODE_SUCCESS;
×
696
  }
697

698
  if (!pBlockLoadInfo->sttBlockLoaded) {
780,284,310✔
699
      code = doLoadSttFilesBlk(pBlockLoadInfo, pIter, pConf->suid, pConf->loadTombFn, pConf->pReader, idStr, loadFromDisk);
528,737,768✔
700
  }
701

702
  setSttInfoForCurrentTable(pBlockLoadInfo, pConf->uid, pKeyRange, numOfRows);
780,281,736✔
703

704
  // find the start block, actually we could load the position to avoid repeatly searching for the start position when
705
  // the skey is updated.
706
  size_t size = taosArrayGetSize(pBlockLoadInfo->aSttBlk);
780,470,894✔
707
  pIter->iSttBlk = binarySearchForStartBlock(pBlockLoadInfo->aSttBlk->pData, size, pConf->uid, backward);
780,671,795✔
708
  if (pIter->iSttBlk != -1) {
780,666,746✔
709
    pIter->pSttBlk = taosArrayGet(pBlockLoadInfo->aSttBlk, pIter->iSttBlk);
298,377,080✔
710
    pIter->iRow = (pIter->backward) ? pIter->pSttBlk->nRow : -1;
298,434,961✔
711

712
    if ((!backward) && ((pConf->strictTimeRange && pIter->pSttBlk->minKey >= pIter->timeWindow.ekey) ||
298,419,344✔
713
                        (!pConf->strictTimeRange && pIter->pSttBlk->minKey > pIter->timeWindow.ekey))) {
243,630,385✔
714
      pIter->pSttBlk = NULL;
108✔
715
    }
716

717
    if (backward && ((pConf->strictTimeRange && pIter->pSttBlk->maxKey <= pIter->timeWindow.skey) ||
298,380,566✔
718
                     (!pConf->strictTimeRange && pIter->pSttBlk->maxKey < pIter->timeWindow.skey))) {
54,778,653✔
719
      pIter->pSttBlk = NULL;
552,311✔
720
      pIter->ignoreEarlierTs = true;
165,901✔
721
    }
722
  }
723

724
  return code;
780,202,522✔
725
}
726

727
void tLDataIterClose2(SLDataIter *pIter) {
528,948,017✔
728
  tsdbSttFileReaderClose(&pIter->pReader);
528,948,017✔
729
  pIter->pReader = NULL;
528,847,330✔
730
}
528,854,822✔
731

732
void tLDataIterNextBlock(SLDataIter *pIter, const char *idStr) {
304,711,727✔
733
  int32_t step = pIter->backward ? -1 : 1;
304,711,727✔
734
  int32_t oldIndex = pIter->iSttBlk;
304,751,988✔
735

736
  pIter->iSttBlk += step;
304,791,999✔
737

738
  int32_t index = -1;
304,807,200✔
739
  size_t  size = pIter->pBlockLoadInfo->aSttBlk->size;
304,807,200✔
740
  for (int32_t i = pIter->iSttBlk; i < size && i >= 0; i += step) {
305,256,697✔
741
    SSttBlk *p = taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, i);
32,211,332✔
742
    if ((!pIter->backward) && p->minUid > pIter->uid) {
32,212,191✔
743
      break;
18,347,559✔
744
    }
745

746
    if (pIter->backward && p->maxUid < pIter->uid) {
13,845,722✔
747
      break;
2,059,647✔
748
    }
749

750
    // check uid firstly
751
    if (p->minUid <= pIter->uid && p->maxUid >= pIter->uid) {
11,805,620✔
752
      if ((!pIter->backward) && p->minKey > pIter->timeWindow.ekey) {
11,805,620✔
753
        break;
82,816✔
754
      }
755

756
      if (pIter->backward && p->maxKey < pIter->timeWindow.skey) {
11,722,804✔
757
        break;
590✔
758
      }
759

760
      // check time range secondly
761
      if (p->minKey <= pIter->timeWindow.ekey && p->maxKey >= pIter->timeWindow.skey) {
11,722,214✔
762
        if ((!pIter->backward) && p->minVer > pIter->verRange.maxVer) {
11,211,816✔
763
          break;
×
764
        }
765

766
        if (pIter->backward && p->maxVer < pIter->verRange.minVer) {
11,211,816✔
767
          break;
×
768
        }
769

770
        if (p->minVer <= pIter->verRange.maxVer && p->maxVer >= pIter->verRange.minVer) {
11,211,816✔
771
          index = i;
11,211,816✔
772
          break;
11,211,816✔
773
        }
774
      }
775
    }
776
  }
777

778
  pIter->pSttBlk = NULL;
304,840,297✔
779
  if (index != -1) {
304,753,636✔
780
    SSttBlk *p = taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, index);
11,211,816✔
781

782
    pIter->iSttBlk = index;
11,211,390✔
783
    pIter->pSttBlk = (SSttBlk *)taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, pIter->iSttBlk);
11,211,390✔
784
    tsdbDebug("try next stt-file block:%d from %d, trigger by uid:%" PRIu64 ", stt-fileVer:%" PRId64
11,211,816✔
785
              ", uidRange:%" PRId64 "-%" PRId64 " %s",
786
              pIter->iSttBlk, oldIndex, pIter->uid, pIter->cid, p->minUid, p->maxUid, idStr);
787
  } else {
788
    tsdbDebug("no more last block qualified, uid:%" PRIu64 ", stt-file block:%d, %s", pIter->uid, oldIndex, idStr);
293,541,820✔
789
  }
790
}
304,753,636✔
791

792
static int32_t findNextValidRow(SLDataIter *pIter, const char *idStr) {
2,147,483,647✔
793
  bool        hasVal = false;
2,147,483,647✔
794
  int32_t     step = pIter->backward ? -1 : 1;
2,147,483,647✔
795
  int32_t     i = pIter->iRow;
2,147,483,647✔
796
  SBlockData *pData = NULL;
2,147,483,647✔
797

798
  int32_t code = loadLastBlock(pIter, idStr, &pData);
2,147,483,647✔
799
  if (code) {
2,147,483,647✔
800
    tsdbError("failed to load stt block, code:%s, %s", tstrerror(code), idStr);
×
801
    return code;
×
802
  }
803

804
  // mostly we only need to find the start position for a given table
805
  if ((((i == 0) && (!pIter->backward)) || (i == pData->nRow - 1 && pIter->backward)) && pData->aUid != NULL) {
2,147,483,647✔
806
    i = binarySearchForStartRowIndex((uint64_t *)pData->aUid, pData->nRow, pIter->uid, pIter->backward);
297,576,819✔
807
    if (i == -1) {
297,495,535✔
808
      tsdbDebug("failed to find the data in pBlockData, uid:%" PRIu64 " , %s", pIter->uid, idStr);
33,280✔
809
      pIter->iRow = -1;
33,280✔
810
      return code;
33,280✔
811
    }
812
  }
813

814
  for (; i < pData->nRow && i >= 0; i += step) {
2,147,483,647✔
815
    if (pData->aUid != NULL) {
2,147,483,647✔
816
      if (!pIter->backward) {
2,147,483,647✔
817
        if (pData->aUid[i] > pIter->uid) {
2,147,483,647✔
818
          break;
77,300,116✔
819
        }
820
      } else {
821
        if (pData->aUid[i] < pIter->uid) {
2,147,483,647✔
822
          break;
19,648,532✔
823
        }
824
      }
825
    }
826

827
    int64_t ts = pData->aTSKEY[i];
2,147,483,647✔
828
    if (!pIter->backward) {               // asc
2,147,483,647✔
829
      if (ts > pIter->timeWindow.ekey) {  // no more data
2,147,483,647✔
830
        break;
857,548✔
831
      } else {
832
        if (ts < pIter->timeWindow.skey) {
2,147,483,647✔
833
          continue;
2,143,298,781✔
834
        }
835

836
        if (ts == pIter->timeWindow.skey && pIter->pStartRowKey->numOfPKs > 0) {
2,147,483,647✔
837
          SRowKey key;
28,552,279✔
838
          tColRowGetKey(pData, i, &key);
28,552,279✔
839
          int32_t ret = pkCompEx(&key, pIter->pStartRowKey);
28,552,279✔
840
          if (ret < 0) {
28,552,279✔
841
            continue;
×
842
          }
843
        }
844
      }
845
    } else {
846
      if (ts < pIter->timeWindow.skey) {
2,147,483,647✔
847
        break;
779,448✔
848
      } else {
849
        if (ts > pIter->timeWindow.ekey) {
2,147,483,647✔
850
          continue;
46,861,555✔
851
        }
852

853
        if (ts == pIter->timeWindow.ekey && pIter->pStartRowKey->numOfPKs > 0) {
2,147,483,647✔
854
          SRowKey key;
×
855
          tColRowGetKey(pData, i, &key);
×
856
          int32_t ret = pkCompEx(&key, pIter->pStartRowKey);
×
857
          if (ret > 0) {
×
858
            continue;
×
859
          }
860
        }
861
      }
862
    }
863

864
    int64_t ver = pData->aVersion[i];
2,147,483,647✔
865
    if (ver < pIter->verRange.minVer) {
2,147,483,647✔
866
      continue;
×
867
    }
868

869
    // todo opt handle desc case
870
    if (ver > pIter->verRange.maxVer) {
2,147,483,647✔
871
      continue;
1,136✔
872
    }
873

874
    hasVal = true;
2,147,483,647✔
875
    break;
2,147,483,647✔
876
  }
877

878
  pIter->iRow = (hasVal) ? i : -1;
2,147,483,647✔
879
  return code;
2,147,483,647✔
880
}
881

882
int32_t tLDataIterNextRow(SLDataIter *pIter, const char *idStr, bool *hasNext) {
2,147,483,647✔
883
  int32_t     step = pIter->backward ? -1 : 1;
2,147,483,647✔
884
  int32_t     code = 0;
2,147,483,647✔
885
  int32_t     iBlockL = pIter->iSttBlk;
2,147,483,647✔
886
  SBlockData *pBlockData = NULL;
2,147,483,647✔
887
  int32_t     lino = 0;
2,147,483,647✔
888

889
  *hasNext = false;
2,147,483,647✔
890

891
  // no qualified last file block in current file, no need to fetch row
892
  if (pIter->pSttBlk == NULL) {
2,147,483,647✔
893
    return code;
482,433,788✔
894
  }
895

896
  code = loadLastBlock(pIter, idStr, &pBlockData);
2,147,483,647✔
897
  if (pBlockData == NULL || code != TSDB_CODE_SUCCESS) {
2,147,483,647✔
898
    lino = __LINE__;
1,225,340✔
899
    goto _exit;
1,225,340✔
900
  }
901

902
  pIter->iRow += step;
2,147,483,647✔
903

904
  while (1) {
11,211,816✔
905
    bool skipBlock = false;
2,147,483,647✔
906
    code = findNextValidRow(pIter, idStr);
2,147,483,647✔
907
    TSDB_CHECK_CODE(code, lino, _exit);
2,147,483,647✔
908

909
    if (pIter->pBlockLoadInfo->checkRemainingRow) {
2,147,483,647✔
910
      skipBlock = true;
×
911
      int16_t *aCols = pIter->pBlockLoadInfo->colIds;
×
912
      int      nCols = pIter->pBlockLoadInfo->numOfCols;
×
913
      bool     isLast = pIter->pBlockLoadInfo->isLast;
×
914
      for (int inputColIndex = 0; inputColIndex < nCols; ++inputColIndex) {
×
915
        for (int colIndex = 0; colIndex < pBlockData->nColData; ++colIndex) {
×
916
          SColData *pColData = &pBlockData->aColData[colIndex];
×
917
          int16_t   cid = pColData->cid;
×
918

919
          if (cid == aCols[inputColIndex]) {
×
920
            if (isLast && (pColData->flag & HAS_VALUE)) {
×
921
              skipBlock = false;
×
922
              break;
×
923
            } else if (pColData->flag & (HAS_VALUE | HAS_NULL)) {
×
924
              skipBlock = false;
×
925
              break;
×
926
            }
927
          }
928
        }
929
      }
930
    }
931

932
    if (skipBlock || pIter->iRow >= pBlockData->nRow || pIter->iRow < 0) {
2,147,483,647✔
933
      tLDataIterNextBlock(pIter, idStr);
323,899,806✔
934
      if (pIter->pSttBlk == NULL) {  // no more data
304,733,163✔
935
        goto _exit;
293,571,662✔
936
      }
937
    } else {
938
      break;
939
    }
940

941
    if (iBlockL != pIter->iSttBlk) {
11,211,816✔
942
      code = loadLastBlock(pIter, idStr, &pBlockData);
11,211,390✔
943
      if ((pBlockData == NULL) || (code != 0)) {
11,211,816✔
944
        lino = __LINE__;
×
945
        goto _exit;
×
946
      }
947

948
      // set start row index
949
      pIter->iRow = pIter->backward ? pBlockData->nRow - 1 : 0;
11,211,816✔
950
    }
951
  }
952

953
  pIter->rInfo.suid = pBlockData->suid;
2,147,483,647✔
954
  pIter->rInfo.uid = pBlockData->uid;
2,147,483,647✔
955
  pIter->rInfo.row = tsdbRowFromBlockData(pBlockData, pIter->iRow);
2,147,483,647✔
956

957
_exit:
2,147,483,647✔
958
  if (code) {
2,147,483,647✔
959
    tsdbError("failed to exec stt-file nextIter, lino:%d, code:%s, %s", lino, tstrerror(code), idStr);
×
960
  }
961

962
  *hasNext = (code == TSDB_CODE_SUCCESS) && (pIter->pSttBlk != NULL) && (pBlockData != NULL);
2,147,483,647✔
963
  return code;
2,147,483,647✔
964
}
965

966
// SMergeTree =================================================
967
static FORCE_INLINE int32_t tLDataIterCmprFn(const SRBTreeNode *p1, const SRBTreeNode *p2) {
2,147,483,647✔
968
  SLDataIter *pIter1 = (SLDataIter *)(((uint8_t *)p1) - offsetof(SLDataIter, node));
2,147,483,647✔
969
  SLDataIter *pIter2 = (SLDataIter *)(((uint8_t *)p2) - offsetof(SLDataIter, node));
2,147,483,647✔
970

971
  SRowKey rkey1 = {0}, rkey2 = {0};
2,147,483,647✔
972
  tRowGetKeyEx(&pIter1->rInfo.row, &rkey1);
2,147,483,647✔
973
  tRowGetKeyEx(&pIter2->rInfo.row, &rkey2);
2,147,483,647✔
974

975
  int32_t ret = tRowKeyCompare(&rkey1, &rkey2);
2,147,483,647✔
976
  if (ret < 0) {
2,147,483,647✔
977
    return -1;
2,147,483,647✔
978
  } else if (ret > 0) {
2,147,483,647✔
979
    return 1;
2,147,483,647✔
980
  } else {
981
    int64_t ver1 = TSDBROW_VERSION(&pIter1->rInfo.row);
2,147,483,647✔
982
    int64_t ver2 = TSDBROW_VERSION(&pIter2->rInfo.row);
2,147,483,647✔
983

984
    if (ver1 < ver2) {
2,147,483,647✔
985
      return -1;
1,420,383,823✔
986
    } else if (ver1 > ver2) {
2,147,483,647✔
987
      return 1;
2,147,483,647✔
988
    } else {
989
      return 0;
×
990
    }
991
  }
992
}
993

994
static FORCE_INLINE int32_t tLDataIterDescCmprFn(const SRBTreeNode *p1, const SRBTreeNode *p2) {
23,532,823✔
995
  return -1 * tLDataIterCmprFn(p1, p2);
23,532,823✔
996
}
997

998
static void clearTableRowsInfoCache(void) {
126,349✔
999
  int32_t items = (statisCacheInfo.pStatisFileCache != NULL)? taosLRUCacheGetElems(statisCacheInfo.pStatisFileCache):0;
126,349✔
1000
  tsdbInfo("start to free %d items in statisCache", items);
126,349✔
1001

1002
  taosLRUCacheCleanup(statisCacheInfo.pStatisFileCache);
126,349✔
1003
  (void)taosThreadMutexDestroy(&statisCacheInfo.lock);
126,349✔
1004
}
126,349✔
1005

1006
// init the statis file cache, 10MiB by default
1007
static void initTableRowsInfoCache(void) {
126,349✔
1008
  statisCacheInfo.pStatisFileCache = taosLRUCacheInit(40 * 1024 * 1024, -1, 0.5);
126,349✔
1009
  (void)taosThreadMutexInit(&statisCacheInfo.lock, NULL);
126,349✔
1010
  (void) atexit(clearTableRowsInfoCache);
126,349✔
1011
}
126,349✔
1012

1013
int32_t tMergeTreeOpen2(SMergeTree *pMTree, SMergeTreeConf *pConf, SSttDataInfoForTable *pSttDataInfo) {
810,653,510✔
1014
  int32_t               code = TSDB_CODE_SUCCESS;
810,653,510✔
1015
  STFileSet *           pFset = (STFileSet *)pConf->pCurrentFileset;
810,653,510✔
1016
  bool                  loadStatisFromDisk = true;
810,878,486✔
1017
  int32_t               lino = 0;
810,878,486✔
1018
  int32_t               numOfLevels = pFset->lvlArr->size;
810,878,486✔
1019
  SSttStatisCacheValue* pValue = NULL;
810,755,372✔
1020
  LRUHandle*            pHandle = NULL;
810,925,143✔
1021
  SSttStatisCacheKey    key = {.suid = pConf->suid, .fid = pFset->fid, .vgId = TD_VID(pConf->pTsdb->pVnode)};
810,916,000✔
1022

1023
  (void)taosThreadOnce(&tsCacheInit, initTableRowsInfoCache);
810,894,328✔
1024

1025
  pMTree->pIter = NULL;
810,729,224✔
1026
  pMTree->backward = pConf->backward;
810,786,272✔
1027
  pMTree->idStr = pConf->idstr;
810,830,202✔
1028

1029
  if (!pMTree->backward) {  // asc
810,799,538✔
1030
    tRBTreeCreate(&pMTree->rbt, tLDataIterCmprFn);
628,179,165✔
1031
  } else {  // desc
1032
    tRBTreeCreate(&pMTree->rbt, tLDataIterDescCmprFn);
182,618,125✔
1033
  }
1034

1035
  pMTree->ignoreEarlierTs = false;
810,695,150✔
1036

1037
  // no data exists, go to end
1038
  if (numOfLevels == 0) {
810,614,435✔
1039
    goto _end;
59,607,091✔
1040
  }
1041

1042
  code = adjustSttDataIters(pConf->pSttFileBlockIterArray, pConf->pCurrentFileset);
751,007,344✔
1043
  if (code) {
751,060,147✔
1044
    goto _end;
×
1045
  }
1046

1047
  if (pConf->cacheStatis) {
751,060,147✔
1048
    int32_t ret = getStatisInfoFromCache(statisCacheInfo.pStatisFileCache, &key, &pValue, &pHandle, pConf->idstr);
134,160✔
1049
    if (ret == TSDB_CODE_SUCCESS) {  // use cached statis info
134,160✔
1050
      if (pValue->commitTs == pFset->lastCommit) {
133,904✔
1051
        loadStatisFromDisk = false;
133,904✔
1052
      } else {  // release the handle ref, and then remove it from lru cache
1053
        int64_t ts = pValue->commitTs;
×
1054
        clearStatisInfoCache(statisCacheInfo.pStatisFileCache, &key, &pHandle);
×
1055
        tsdbInfo(
×
1056
            "cache expired since new commit occurs, remove the cache and load from disk, vgId:%d, fid:%d, suid:%" PRId64
1057
            ", commitTs:%" PRId64 ", new commitTs:%" PRId64,
1058
            key.vgId, key.fid, key.suid, ts, pFset->lastCommit);
1059
      }
1060
    }
1061
  }
1062

1063
  for (int32_t j = 0; j < numOfLevels; ++j) {
1,531,227,566✔
1064
    SSttLvl *pSttLevel = ((STFileSet *)pConf->pCurrentFileset)->lvlArr->data[j];
780,078,347✔
1065
    SArray  *pList = taosArrayGetP(pConf->pSttFileBlockIterArray, j);
780,382,974✔
1066

1067
    for (int32_t i = 0; i < TARRAY2_SIZE(pSttLevel->fobjArr); ++i) {  // open all last file
1,561,006,180✔
1068
      SLDataIter *pIter = taosArrayGetP(pList, i);
780,702,025✔
1069

1070
      SSttFileReader    *pSttFileReader = pIter->pReader;
780,773,414✔
1071
      SSttBlockLoadInfo *pLoadInfo = pIter->pBlockLoadInfo;
780,783,956✔
1072

1073
      // open stt file reader if not opened yet
1074
      // if failed to open this stt file, ignore the error and try next one
1075
      if (pSttFileReader == NULL) {
780,744,916✔
1076
        int32_t pgSize = pConf->pTsdb->pVnode->config.tsdbPageSize;
528,786,643✔
1077

1078
        SSttFileReaderConfig conf = {
1,057,949,041✔
1079
            .tsdb = pConf->pTsdb, .szPage = pgSize, .file[0] = *pSttLevel->fobjArr->data[i]->f};
528,952,599✔
1080

1081
        code = tsdbSttFileReaderOpen(pSttLevel->fobjArr->data[i]->fname, &conf, &pSttFileReader);
529,015,893✔
1082
        if (code != TSDB_CODE_SUCCESS) {
528,515,639✔
1083
          tsdbError("open stt file reader error. file name %s, code %s, %s", pSttLevel->fobjArr->data[i]->fname,
×
1084
                    tstrerror(code), pMTree->idStr);
1085
        }
1086
      }
1087

1088
      if (pLoadInfo == NULL) {
780,181,400✔
1089
        code = tCreateSttBlockLoadInfo(pConf->pSchema, pConf->pCols, pConf->numOfCols, &pLoadInfo);
528,747,408✔
1090
        if (code != TSDB_CODE_SUCCESS) {
528,912,887✔
1091
          goto _end;
×
1092
        }
1093
      }
1094

1095
      if (!loadStatisFromDisk && (pLoadInfo->info.pCount == NULL)) {
780,346,879✔
1096
          code = getSttTableRowsInfo(pValue, pConf->pCurRowKey->numOfPKs, j, i, &pLoadInfo->info);
44,973✔
1097
          if (code != TSDB_CODE_SUCCESS) {
44,973✔
1098
            loadStatisFromDisk = true;  // failed to get statis info from cache, load it from stt file
×
1099
          }
1100
      }
1101

1102
      memset(pIter, 0, sizeof(SLDataIter));
780,346,879✔
1103

1104
      SSttKeyRange range = {.skey.numOfPKs = pConf->pCurRowKey->numOfPKs, .ekey.numOfPKs = pConf->pCurRowKey->numOfPKs};
780,346,879✔
1105
      int64_t      numOfRows = 0;
780,808,559✔
1106
      int64_t      cid = pSttLevel->fobjArr->data[i]->f->cid;
780,800,624✔
1107

1108
      code = tLDataIterOpen2(pIter, pSttFileReader, cid, pMTree->backward, pConf, pLoadInfo, &range, &numOfRows,
780,827,246✔
1109
                             pMTree->idStr, loadStatisFromDisk);
1110
      if (code != TSDB_CODE_SUCCESS) {
780,303,700✔
1111
        goto _end;
×
1112
      }
1113

1114
      bool hasVal = NULL;
780,303,700✔
1115
      code = tLDataIterNextRow(pIter, pMTree->idStr, &hasVal);
780,521,634✔
1116
      if (code) {
780,250,342✔
1117
        goto _end;
×
1118
      }
1119

1120
      if (hasVal) {
780,250,342✔
1121
        tMergeTreeAddIter(pMTree, pIter);
296,389,532✔
1122

1123
        // let's record the time window for current table of uid in the stt files
1124
        if (pSttDataInfo != NULL && numOfRows > 0) {
296,378,888✔
1125
          void *px = taosArrayPush(pSttDataInfo->pKeyRangeList, &range);
296,333,840✔
1126
          QUERY_CHECK_NULL(px, code, lino, _end, terrno);
296,437,688✔
1127

1128
          pSttDataInfo->numOfRows += numOfRows;
296,437,688✔
1129
        }
1130
      } else {
1131
        if (!pMTree->ignoreEarlierTs) {
483,860,810✔
1132
          pMTree->ignoreEarlierTs = pIter->ignoreEarlierTs;
483,949,454✔
1133
        }
1134
      }
1135
    }
1136
  }
1137

1138
  if (pConf->cacheStatis && loadStatisFromDisk) {
751,149,219✔
1139
    SSttStatisCacheKey    k = {0};
256✔
1140
    SSttStatisCacheValue *pVal = NULL;
256✔
1141

1142
    code = buildSttTableRowsInfoKV(pConf, TD_VID(pConf->pTsdb->pVnode), &k, &pVal);
256✔
1143
    if (code == TSDB_CODE_SUCCESS) {
256✔
1144
      code = putStatisInfoIntoCache(statisCacheInfo.pStatisFileCache, &k, pVal, pConf->idstr);
256✔
1145
    }
1146
  }
1147

1148
  if (pHandle != NULL && pConf->cacheStatis) {
750,851,108✔
1149
    releaseCacheHandle(statisCacheInfo.pStatisFileCache, &pHandle, true);
133,904✔
1150
  }
1151

1152
  return code;
750,669,483✔
1153

1154
_end:
59,594,009✔
1155
  if (pHandle != NULL && pConf->cacheStatis) {
59,611,401✔
1156
    releaseCacheHandle(statisCacheInfo.pStatisFileCache, &pHandle, true);
×
1157
  }
1158

1159
  tMergeTreeClose(pMTree);
59,611,401✔
1160
  return code;
59,607,091✔
1161
}
1162

1163
void tMergeTreeAddIter(SMergeTree *pMTree, SLDataIter *pIter) {
296,345,309✔
1164
  SRBTreeNode *node = tRBTreePut(&pMTree->rbt, (SRBTreeNode *)pIter);
296,345,309✔
1165
}
296,381,642✔
1166

1167
bool tMergeTreeIgnoreEarlierTs(SMergeTree *pMTree) { return pMTree->ignoreEarlierTs; }
×
1168

1169
static void tLDataIterPinSttBlock(SLDataIter *pIter, const char *id) {
2,147,483,647✔
1170
  SSttBlockLoadInfo *pInfo = pIter->pBlockLoadInfo;
2,147,483,647✔
1171

1172
  if (pInfo->blockData[0].sttBlockIndex == pIter->iSttBlk) {
2,147,483,647✔
1173
    pInfo->blockData[0].pin = true;
2,147,483,647✔
1174
    tsdbTrace("pin stt-block, blockIndex:%d, stt-fileVer:%" PRId64 " %s", pIter->iSttBlk, pIter->cid, id);
2,147,483,647✔
1175
    return;
2,147,483,647✔
1176
  }
1177

1178
  if (pInfo->blockData[1].sttBlockIndex == pIter->iSttBlk) {
2,147,483,647✔
1179
    pInfo->blockData[1].pin = true;
2,147,483,647✔
1180
    tsdbTrace("pin stt-block, blockIndex:%d, stt-fileVer:%" PRId64 " %s", pIter->iSttBlk, pIter->cid, id);
2,147,483,647✔
1181
    return;
2,147,483,647✔
1182
  }
1183

1184
  tsdbError("failed to pin any stt block, sttBlock:%d stt-fileVer:%" PRId64 " %s", pIter->iSttBlk, pIter->cid, id);
×
1185
}
1186

1187
static void tLDataIterUnpinSttBlock(SLDataIter *pIter, const char *id) {
2,147,483,647✔
1188
  SSttBlockLoadInfo *pInfo = pIter->pBlockLoadInfo;
2,147,483,647✔
1189
  if (pInfo->blockData[0].pin) {
2,147,483,647✔
1190
    pInfo->blockData[0].pin = false;
2,147,483,647✔
1191
    tsdbTrace("unpin stt-block:%d, stt-fileVer:%" PRId64 " %s", pInfo->blockData[0].sttBlockIndex, pIter->cid, id);
2,147,483,647✔
1192
    return;
2,147,483,647✔
1193
  }
1194

1195
  if (pInfo->blockData[1].pin) {
2,147,483,647✔
1196
    pInfo->blockData[1].pin = false;
2,147,483,647✔
1197
    tsdbTrace("unpin stt-block:%d, stt-fileVer:%" PRId64 " %s", pInfo->blockData[1].sttBlockIndex, pIter->cid, id);
2,147,483,647✔
1198
    return;
2,147,483,647✔
1199
  }
1200

1201
  tsdbError("failed to unpin any stt block, sttBlock:%d stt-fileVer:%" PRId64 " %s", pIter->iSttBlk, pIter->cid, id);
×
1202
}
1203

1204
void tMergeTreePinSttBlock(SMergeTree *pMTree) {
2,147,483,647✔
1205
  if (pMTree->pIter == NULL) {
2,147,483,647✔
1206
    return;
×
1207
  }
1208

1209
  SLDataIter *pIter = pMTree->pIter;
2,147,483,647✔
1210
  pMTree->pPinnedBlockIter = pIter;
2,147,483,647✔
1211
  tLDataIterPinSttBlock(pIter, pMTree->idStr);
2,147,483,647✔
1212
}
1213

1214
void tMergeTreeUnpinSttBlock(SMergeTree *pMTree) {
2,147,483,647✔
1215
  if (pMTree->pPinnedBlockIter == NULL) {
2,147,483,647✔
1216
    return;
×
1217
  }
1218

1219
  SLDataIter *pIter = pMTree->pPinnedBlockIter;
2,147,483,647✔
1220
  pMTree->pPinnedBlockIter = NULL;
2,147,483,647✔
1221
  tLDataIterUnpinSttBlock(pIter, pMTree->idStr);
2,147,483,647✔
1222
}
1223

1224
int32_t tMergeTreeNext(SMergeTree *pMTree, bool *pHasNext) {
2,147,483,647✔
1225
  int32_t code = 0;
2,147,483,647✔
1226
  if (pHasNext == NULL) {
2,147,483,647✔
1227
    return TSDB_CODE_INVALID_PARA;
×
1228
  }
1229

1230
  *pHasNext = false;
2,147,483,647✔
1231
  while (pMTree->pIter) {
2,147,483,647✔
1232
    SLDataIter *pIter = pMTree->pIter;
2,147,483,647✔
1233
    bool        hasVal = false;
2,147,483,647✔
1234
    code = tLDataIterNextRow(pIter, pMTree->idStr, &hasVal);
2,147,483,647✔
1235
    if (!hasVal || (code != 0)) {
2,147,483,647✔
1236
      if (code == TSDB_CODE_FILE_CORRUPTED) {
291,210,528✔
1237
        code = 0;  // suppress the file corrupt error to enable all queries within this cluster can run without failed.
×
1238
      }
1239

1240
      pMTree->pIter = NULL;
291,210,528✔
1241
    }
1242

1243
    // compare with min in RB Tree
1244
    pIter = (SLDataIter *)tRBTreeMin(&pMTree->rbt);
2,147,483,647✔
1245
    if (pMTree->pIter && pIter) {
2,147,483,647✔
1246
      int32_t c = pMTree->rbt.cmprFn(&pMTree->pIter->node, &pIter->node);
2,147,483,647✔
1247
      if (c > 0) {
2,147,483,647✔
1248
        (void)tRBTreePut(&pMTree->rbt, (SRBTreeNode *)pMTree->pIter);
1,389,818,825✔
1249
        pMTree->pIter = NULL;
1,389,878,876✔
1250
      } else if (!c) {
1,285,054,078✔
1251
        continue;
×
1252
      }
1253
    }
1254

1255
    break;
2,147,483,647✔
1256
  }
1257

1258
  if (pMTree->pIter == NULL) {
2,147,483,647✔
1259
    pMTree->pIter = (SLDataIter *)tRBTreeMin(&pMTree->rbt);
2,147,483,647✔
1260
    if (pMTree->pIter) {
2,147,483,647✔
1261
      tRBTreeDrop(&pMTree->rbt, (SRBTreeNode *)pMTree->pIter);
1,681,833,220✔
1262
    }
1263
  }
1264

1265
  *pHasNext = (pMTree->pIter != NULL);
2,147,483,647✔
1266
  return code;
2,147,483,647✔
1267
}
1268

1269
void tMergeTreeClose(SMergeTree *pMTree) {
1,303,967,222✔
1270
  pMTree->pIter = NULL;
1,303,967,222✔
1271
  pMTree->pPinnedBlockIter = NULL;
1,304,306,633✔
1272
}
1,304,162,629✔
1273

1274
int32_t buildSttTableRowsInfoKV(SMergeTreeConf *pConf, int32_t vgId, SSttStatisCacheKey *pKey,
256✔
1275
                                SSttStatisCacheValue **pValue) {
1276
  *pValue = taosMemoryCalloc(1, sizeof(SSttStatisCacheValue));
256✔
1277
  if (*pValue == NULL) {
256✔
1278
    return terrno;
×
1279
  }
1280

1281
  memset(pKey, 0, sizeof(SSttStatisCacheKey));
256✔
1282

1283
  STFileSet *pFset = (STFileSet *)pConf->pCurrentFileset;
256✔
1284

1285
  pKey->suid = pConf->suid;
256✔
1286
  pKey->vgId = vgId;
256✔
1287
  pKey->fid = pFset->fid;
256✔
1288

1289
  (*pValue)->commitTs = pFset->lastCommit;
256✔
1290

1291
  int32_t numOfLevels = TARRAY2_SIZE(pFset->lvlArr);
256✔
1292

1293
  (*pValue)->pLevel = taosArrayInit(numOfLevels, sizeof(void *));
256✔
1294
  if ((*pValue)->pLevel == NULL) {
256✔
1295
    return terrno;
×
1296
  }
1297

1298
  for (int32_t j = 0; j < numOfLevels; ++j) {
512✔
1299
    SSttLvl *pSttLevel = pFset->lvlArr->data[j];
256✔
1300
    SArray * pIterList = taosArrayGetP(pConf->pSttFileBlockIterArray, j);
256✔
1301
    if (pIterList == NULL) {
256✔
1302
      return terrno;
×
1303
    }
1304

1305
    SArray *pRowsInfoArr = taosArrayInit(TARRAY2_SIZE(pSttLevel->fobjArr), sizeof(SSttTableRowsInfo));
256✔
1306
    if (pRowsInfoArr == NULL) {
256✔
1307
      return terrno;
×
1308
    }
1309

1310
    for (int32_t i = 0; i < TARRAY2_SIZE(pSttLevel->fobjArr); ++i) {  // open all stt file
512✔
1311
      SLDataIter *       pIter = taosArrayGetP(pIterList, i);
256✔
1312
      SSttBlockLoadInfo *pLoadInfo = pIter->pBlockLoadInfo;
256✔
1313

1314
      void *px = taosArrayPush(pRowsInfoArr, &pLoadInfo->info);
256✔
1315
      if (px == NULL) {
256✔
1316
        return terrno;
×
1317
      }
1318

1319
      memset(&pLoadInfo->info, 0, sizeof(SSttTableRowsInfo));
256✔
1320
    }
1321

1322
    void *px = taosArrayPush((*pValue)->pLevel, &pRowsInfoArr);
256✔
1323
    if (px == NULL) {
256✔
1324
      return terrno;
×
1325
    }
1326
  }
1327

1328
  // todo handle memory failure
1329

1330
  return TSDB_CODE_SUCCESS;
256✔
1331
}
1332

1333
int32_t getStatisInfoFromCache(SLRUCache *pCache, SSttStatisCacheKey *pKey, SSttStatisCacheValue **pValue,
134,160✔
1334
                               LRUHandle **pHandle, const char *id) {
1335
  *pValue = NULL;
134,160✔
1336
  *pHandle = NULL;
134,160✔
1337

1338
  (void)taosThreadMutexLock(&statisCacheInfo.lock);
134,160✔
1339
  LRUHandle *pItemHandle = taosLRUCacheLookup(pCache, pKey, sizeof(SSttStatisCacheKey));
134,160✔
1340
  if (pItemHandle == NULL) {
134,160✔
1341
    (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
256✔
1342
    return TSDB_CODE_NOT_FOUND;
256✔
1343
  }
1344

1345
  void *p = taosLRUCacheValue(pCache, pItemHandle);
133,904✔
1346

1347
  *pValue = p;
133,904✔
1348
  *pHandle = pItemHandle;
133,904✔
1349

1350
  tsdbDebug("get statis info from cache suid:%" PRId64 ", vgId:%d, fid:%d, %s, commitTs:%" PRId64, pKey->suid,
133,904✔
1351
            pKey->vgId, pKey->fid, id, (*pValue)->commitTs);
1352

1353
  // (*pEntry)->hitTimes += 1;
1354
  (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
133,904✔
1355
  return TSDB_CODE_SUCCESS;
133,904✔
1356
}
1357

1358
void releaseCacheHandle(SLRUCache *pCache, LRUHandle **pHandle, bool lock) {
133,904✔
1359
  if (lock) {
133,904✔
1360
    (void)taosThreadMutexLock(&statisCacheInfo.lock);
133,904✔
1361
  }
1362

1363
  bool ret = taosLRUCacheRelease(pCache, *pHandle, false);
133,904✔
1364
  *pHandle = NULL;
133,904✔
1365

1366
  if (lock) {
133,904✔
1367
    (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
133,904✔
1368
  }
1369
}
133,904✔
1370

1371
void freeStatisFileItems(const void* key, size_t keyLen, void* value, void* ud) {
256✔
1372
  (void)ud;
1373

1374
  if (value == NULL) {
256✔
1375
    return;
×
1376
  }
1377

1378
  SSttStatisCacheKey *  pKey = (SSttStatisCacheKey *)key;
256✔
1379
  SSttStatisCacheValue *pVal = value;
256✔
1380

1381
  for(int32_t i = 0; i < taosArrayGetSize(pVal->pLevel); ++i) {
512✔
1382
    SArray* pInfos = taosArrayGetP(pVal->pLevel, i);
256✔
1383

1384
    for(int32_t j = 0; j < taosArrayGetSize(pInfos); ++j) {
512✔
1385
      SSttTableRowsInfo* p = taosArrayGet(pInfos, j);
256✔
1386
      taosArrayDestroy(p->pCount);
256✔
1387
      taosArrayDestroyEx(p->pFirstKey, freeItem);
256✔
1388
      taosArrayDestroyEx(p->pLastKey, freeItem);
256✔
1389
      taosArrayDestroy(p->pFirstTs);
256✔
1390
      taosArrayDestroy(p->pLastTs);
256✔
1391
      taosArrayDestroy(p->pUid);
256✔
1392
    }
1393

1394
    taosArrayDestroy(pInfos);
256✔
1395
  }
1396

1397
  taosArrayDestroy(pVal->pLevel);
256✔
1398
  taosMemoryFree(pVal);
256✔
1399
}
1400

1401
int32_t putStatisInfoIntoCache(SLRUCache *pCache, SSttStatisCacheKey *pKey, SSttStatisCacheValue *pValue,
256✔
1402
                               const char *id) {
1403
  (void)taosThreadMutexLock(&statisCacheInfo.lock);
256✔
1404

1405
  LRUStatus status = taosLRUCacheInsert(pCache, pKey, sizeof(SSttStatisCacheKey), pValue, getCacheValueSize(pValue),
256✔
1406
                                        freeStatisFileItems, NULL, NULL, TAOS_LRU_PRIORITY_LOW, NULL);
1407
  if (status != TAOS_LRU_STATUS_OK) {
256✔
1408
    if (status == TAOS_LRU_STATUS_FAIL) {
×
1409
      tsdbError("%s failed to insert items into statis cache, status:%d", id, status);
×
1410
      freeStatisFileItems(NULL, 0, pValue, NULL);
×
1411
    }
1412
  } else {
1413
    int32_t total = taosLRUCacheGetElems(pCache);
256✔
1414
    tsdbDebug("%s put statis info into cache, total:%d suid:%" PRId64 ", vgId:%d, fid:%d", id, total, pKey->suid,
256✔
1415
              pKey->vgId, pKey->fid);
1416
  }
1417

1418
  (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
256✔
1419
  return TSDB_CODE_SUCCESS;
256✔
1420
}
1421

1422
void clearStatisInfoCache(SLRUCache *pStatisCache, SSttStatisCacheKey *pKey, LRUHandle** pHandle) {
×
1423
  (void)taosThreadMutexLock(&statisCacheInfo.lock);
×
1424
  releaseCacheHandle(statisCacheInfo.pStatisFileCache, pHandle, false);
×
1425
  taosLRUCacheErase(pStatisCache, pKey, sizeof(SSttStatisCacheKey));
×
1426
  (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
×
1427
}
×
1428

1429
static int32_t dupPlayload(SValue *p){
×
1430
  if (p != NULL){
×
1431
    int32_t code = tValueDupPayload(p);
×
1432
    if (code != TSDB_CODE_SUCCESS) {
×
1433
      return code;
×
1434
    }
1435
  }
1436
  return 0;
×
1437
}
1438

1439
int32_t sttRowInfoDeepCopy(SSttTableRowsInfo *pDst, SSttTableRowsInfo *pInfo, int32_t numOfPKs) {
44,973✔
1440
  int32_t code = 0;
44,973✔
1441

1442
  pDst->pCount = taosArrayDup(pInfo->pCount, NULL);
44,973✔
1443
  pDst->pFirstKey = taosArrayDup(pInfo->pFirstKey, NULL);
44,973✔
1444
  pDst->pLastKey = taosArrayDup(pInfo->pLastKey, NULL);
44,973✔
1445
  pDst->pFirstTs = taosArrayDup(pInfo->pFirstTs, NULL);
44,973✔
1446
  pDst->pLastTs = taosArrayDup(pInfo->pLastTs, NULL);
44,973✔
1447
  pDst->pUid = taosArrayDup(pInfo->pUid, NULL);
44,973✔
1448

1449
  pDst->memSize = pInfo->memSize;
44,973✔
1450
  
1451
  if (numOfPKs > 0) {
44,973✔
1452
    int32_t len = taosArrayGetSize(pDst->pCount);
×
1453
    for (int32_t i = 0; i < len; ++i) {
×
1454
      SValue *p1 = (SValue *)taosArrayGet(pDst->pFirstKey, i);
×
1455
      if (p1 == NULL) {
×
1456
        return terrno;
×
1457
      }
1458
      code = tValueDupPayload(p1);
×
1459
      if (code != TSDB_CODE_SUCCESS) {
×
1460
        return code;
×
1461
      }
1462
      SValue *p2 = (SValue *)taosArrayGet(pDst->pLastKey, i);
×
1463
      if (p2 == NULL) {
×
1464
        return terrno;
×
1465
      }
1466
      code = tValueDupPayload(p2);
×
1467
      if (code != TSDB_CODE_SUCCESS) {
×
1468
        return code;
×
1469
      }
1470
    }
1471
  }
1472

1473
  return TSDB_CODE_SUCCESS;
44,973✔
1474
}
1475

1476
int32_t getSttTableRowsInfo(SSttStatisCacheValue *pValue, int32_t numOfPKs, int32_t levelIdx, int32_t fileIdx,
44,973✔
1477
                            SSttTableRowsInfo *pRowInfo) {
1478
  if (levelIdx >= taosArrayGetSize(pValue->pLevel)) {
44,973✔
1479
    return TSDB_CODE_INVALID_PARA;
×
1480
  }
1481

1482
  SArray *pRowsInfoArr = *(SArray **)taosArrayGet(pValue->pLevel, levelIdx);
44,973✔
1483
  if (pRowsInfoArr == NULL) {
44,973✔
1484
    return TSDB_CODE_INVALID_PARA;
×
1485
  }
1486

1487
  if (fileIdx >= taosArrayGetSize(pRowsInfoArr)) {
44,973✔
1488
    return TSDB_CODE_INVALID_PARA;
×
1489
  }
1490

1491
  void* p = (SSttTableRowsInfo *)taosArrayGet(pRowsInfoArr, fileIdx);
44,973✔
1492
  if (p == NULL) {
44,973✔
1493
    return TSDB_CODE_INVALID_PARA;
×
1494
  }
1495

1496
  return sttRowInfoDeepCopy(pRowInfo, p, numOfPKs);
44,973✔
1497
}
1498

1499
int32_t getCacheValueSize(const SSttStatisCacheValue *pValue) {
256✔
1500
  int32_t size = sizeof(SSttStatisCacheValue) + sizeof(SArray);
256✔
1501
  for (int32_t i = 0; i < taosArrayGetSize(pValue->pLevel); ++i) {
512✔
1502
    SArray *pRowsInfoArr = *(SArray **)taosArrayGet(pValue->pLevel, i);
256✔
1503
    
1504
    size += sizeof(SArray);
256✔
1505
    for (int32_t j = 0; j < taosArrayGetSize(pRowsInfoArr); ++j) {
512✔
1506
      SSttTableRowsInfo *p = (SSttTableRowsInfo *)taosArrayGet(pRowsInfoArr, j);
256✔
1507
      size += p->memSize;
256✔
1508
    }
1509
  }
1510

1511
  return size;
256✔
1512
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc