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

taosdata / TDengine / #4855

17 Nov 2025 09:53AM UTC coverage: 64.039% (-0.02%) from 64.06%
#4855

push

travis-ci

guanshengliang
Merge branch '3.0' into cover/3.0

218 of 311 new or added lines in 32 files covered. (70.1%)

4723 existing lines in 121 files now uncovered.

151075 of 235910 relevant lines covered (64.04%)

116057894.49 hits per line

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

86.17
/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) {
198,786,497✔
60
  *pInfo = NULL;
198,786,497✔
61

62
  SSttBlockLoadInfo *pLoadInfo = taosMemoryCalloc(1, sizeof(SSttBlockLoadInfo));
198,830,351✔
63
  if (pLoadInfo == NULL) {
198,750,508✔
64
    return terrno;
×
65
  }
66

67
  pLoadInfo->blockData[0].sttBlockIndex = -1;
198,750,508✔
68
  pLoadInfo->blockData[1].sttBlockIndex = -1;
198,755,535✔
69

70
  pLoadInfo->currentLoadBlockIndex = 1;
198,780,503✔
71

72
  int32_t code = tBlockDataCreate(&pLoadInfo->blockData[0].data);
198,800,401✔
73
  if (code) {
198,842,986✔
74
    taosMemoryFreeClear(pLoadInfo);
×
75
    return code;
×
76
  }
77

78
  code = tBlockDataCreate(&pLoadInfo->blockData[1].data);
198,842,986✔
79
  if (code) {
198,835,393✔
80
    taosMemoryFreeClear(pLoadInfo);
×
81
    return code;
×
82
  }
83

84
  pLoadInfo->aSttBlk = taosArrayInit(4, sizeof(SSttBlk));
198,835,393✔
85
  if (pLoadInfo->aSttBlk == NULL) {
198,874,180✔
86
    taosMemoryFreeClear(pLoadInfo);
×
87
    return terrno;
×
88
  }
89

90
  pLoadInfo->pSchema = pSchema;
198,868,676✔
91
  pLoadInfo->colIds = colList;
198,889,581✔
92
  pLoadInfo->numOfCols = numOfCols;
198,881,110✔
93

94
  *pInfo = pLoadInfo;
198,888,872✔
95
  return code;
198,856,880✔
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);
13,222,304✔
102
  }
103
}
2,147,483,647✔
104

105
void destroySttBlockLoadInfo(SSttBlockLoadInfo *pLoadInfo) {
198,804,172✔
106
  if (pLoadInfo == NULL) {
198,804,172✔
107
    return;
×
108
  }
109

110
  pLoadInfo->currentLoadBlockIndex = 1;
198,804,172✔
111

112
  SBlockDataInfo *pInfo = &pLoadInfo->blockData[0];
198,865,090✔
113
  tBlockDataDestroy(&pInfo->data);
198,833,576✔
114
  pInfo->sttBlockIndex = -1;
198,852,493✔
115
  pInfo->pin = false;
198,859,874✔
116

117
  pInfo = &pLoadInfo->blockData[1];
198,849,721✔
118
  tBlockDataDestroy(&pInfo->data);
198,830,610✔
119
  pInfo->sttBlockIndex = -1;
198,890,266✔
120
  pInfo->pin = false;
198,891,888✔
121

122
  taosArrayDestroy(pLoadInfo->info.pUid);
198,882,166✔
123
  taosArrayDestroy(pLoadInfo->info.pCount);
198,871,844✔
124
  taosArrayDestroy(pLoadInfo->info.pFirstTs);
198,874,635✔
125
  taosArrayDestroy(pLoadInfo->info.pLastTs);
198,878,561✔
126

127
  taosArrayDestroyEx(pLoadInfo->info.pFirstKey, freeItem);
198,873,395✔
128
  taosArrayDestroyEx(pLoadInfo->info.pLastKey, freeItem);
198,861,099✔
129

130
  pLoadInfo->info.pUid = NULL;
198,852,215✔
131
  pLoadInfo->info.pFirstKey = NULL;
198,878,199✔
132
  pLoadInfo->info.pLastKey = NULL;
198,882,820✔
133
  pLoadInfo->info.pCount = NULL;
198,879,524✔
134
  pLoadInfo->info.pFirstTs = NULL;
198,858,420✔
135
  pLoadInfo->info.pLastTs = NULL;
198,895,996✔
136

137
  taosArrayDestroy(pLoadInfo->aSttBlk);
198,887,730✔
138
  taosMemoryFree(pLoadInfo);
198,876,721✔
139
}
140

141
void destroyLDataIter(SLDataIter *pIter) {
198,880,485✔
142
  tLDataIterClose2(pIter);
198,880,485✔
143
  destroySttBlockLoadInfo(pIter->pBlockLoadInfo);
198,849,230✔
144
  taosMemoryFree(pIter);
198,847,164✔
145
}
198,865,712✔
146

147
void destroySttBlockReader(SArray *pLDataIterArray, SSttBlockLoadCostInfo *pLoadCost) {
339,658,362✔
148
  if (pLDataIterArray == NULL) {
339,658,362✔
149
    return;
3,609,489✔
150
  }
151

152
  int32_t numOfLevel = taosArrayGetSize(pLDataIterArray);
336,048,873✔
153
  for (int32_t i = 0; i < numOfLevel; ++i) {
534,844,510✔
154
    SArray *pList = taosArrayGetP(pLDataIterArray, i);
198,743,581✔
155
    for (int32_t j = 0; j < taosArrayGetSize(pList); ++j) {
397,612,225✔
156
      SLDataIter *pIter = taosArrayGetP(pList, j);
198,902,335✔
157
      if (pIter->pBlockLoadInfo != NULL) {
198,901,020✔
158
        SSttBlockLoadCostInfo *pCost = &pIter->pBlockLoadInfo->cost;
198,904,388✔
159
        if (pLoadCost != NULL) {
198,900,449✔
160
          pLoadCost->loadBlocks += pCost->loadBlocks;
198,900,154✔
161
          pLoadCost->loadStatisBlocks += pCost->loadStatisBlocks;
198,902,423✔
162
          pLoadCost->blockElapsedTime += pCost->blockElapsedTime;
198,891,559✔
163
          pLoadCost->statisElapsedTime += pCost->statisElapsedTime;
198,900,204✔
164
        }
165
      }
166

167
      destroyLDataIter(pIter);
198,879,740✔
168
    }
169

170
    taosArrayDestroy(pList);
198,717,192✔
171
  }
172

173
  taosArrayDestroy(pLDataIterArray);
336,100,929✔
174
}
175

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

183
  pLoadInfo->currentLoadBlockIndex = nextSlotIndex;
124,311,127✔
184
}
124,252,288✔
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
33,855✔
197
                ", load data, %s",
198
                pIter->iSttBlk, pIter->cid, pIter->uid, idStr);
199
      pInfo->currentLoadBlockIndex = 0;
33,855✔
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
28,859✔
209
                ", load data, %s",
210
                pIter->iSttBlk, pIter->cid, pIter->uid, idStr);
211
      pInfo->currentLoadBlockIndex = 1;
28,859✔
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) {
124,203,572✔
UNCOV
219
    return code;
×
220
  }
221

222
  updateBlockLoadSlot(pInfo);
124,278,961✔
223
  int64_t st = taosGetTimestampUs();
124,316,489✔
224

225
  SBlockData *pBlock = &pInfo->blockData[pInfo->currentLoadBlockIndex].data;
124,316,489✔
226
  code = tsdbSttFileReadBlockDataByColumn(pIter->pReader, pIter->pSttBlk, pBlock, pInfo->pSchema, &pInfo->colIds[1],
124,261,490✔
227
                                          pInfo->numOfCols - 1);
124,309,113✔
228
  if (code != TSDB_CODE_SUCCESS) {
124,309,587✔
UNCOV
229
    return code;
×
230
  }
231

232
  double el = (taosGetTimestampUs() - st) / 1000.0;
124,330,212✔
233
  pInfo->cost.blockElapsedTime += el;
124,330,212✔
234
  pInfo->cost.loadBlocks += 1;
124,320,578✔
235

236
  tsdbDebug("read stt block, total load:%" PRId64 ", trigger by uid:%" PRIu64 ", stt-fileVer:%" PRId64
124,332,753✔
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;
124,332,753✔
244
  pIter->iRow = (pIter->backward) ? pInfo->blockData[pInfo->currentLoadBlockIndex].data.nRow : -1;
124,341,363✔
245

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

249
  *pResBlock = &pInfo->blockData[pInfo->currentLoadBlockIndex].data;
124,333,427✔
250
  return code;
124,276,183✔
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;
144,132,663✔
257
  int32_t step = backward ? 1 : -1;
144,132,663✔
258
  while (i >= 0 && i < num && uid >= pBlockList[i].minUid && uid <= pBlockList[i].maxUid) {
289,581,721✔
259
    i += step;
145,449,058✔
260
  }
261
  return i - step;
144,092,842✔
262
}
263

264
static int32_t binarySearchForStartBlock(SSttBlk *pBlockList, int32_t num, uint64_t uid, int32_t backward) {
288,756,103✔
265
  int32_t midPos = -1;
288,756,103✔
266
  if (num <= 0) {
288,756,103✔
267
    return -1;
77,861,162✔
268
  }
269

270
  int32_t firstPos = 0;
210,894,941✔
271
  int32_t lastPos = num - 1;
210,894,941✔
272

273
  // find the first position which is bigger than the key
274
  if ((uid > pBlockList[lastPos].maxUid) || (uid < pBlockList[firstPos].minUid)) {
210,894,941✔
275
    return -1;
66,814,416✔
276
  }
277

278
  while (1) {
5,558,377✔
279
    if (uid >= pBlockList[firstPos].minUid && uid <= pBlockList[firstPos].maxUid) {
149,629,520✔
280
      return findEarliestIndex(firstPos, uid, pBlockList, num, backward);
138,969,964✔
281
    }
282

283
    if (uid > pBlockList[lastPos].maxUid || uid < pBlockList[firstPos].minUid) {
10,668,122✔
284
      return -1;
7,311✔
285
    }
286

287
    int32_t numOfRows = lastPos - firstPos + 1;
10,680,673✔
288
    midPos = (numOfRows >> 1u) + firstPos;
10,680,673✔
289

290
    if (uid < pBlockList[midPos].minUid) {
10,680,673✔
291
      lastPos = midPos - 1;
2,546,907✔
292
    } else if (uid > pBlockList[midPos].maxUid) {
8,134,050✔
293
      firstPos = midPos + 1;
3,011,470✔
294
    } else {
295
      return findEarliestIndex(midPos, uid, pBlockList, num, backward);
5,122,878✔
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;
144,957,487✔
303
  int32_t step = backward ? 1 : -1;
144,957,487✔
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;
144,936,896✔
308
}
309

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

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

319
  while (1) {
43,077,699✔
320
    if (uid == uidList[firstPos]) {
188,148,720✔
321
      return findEarliestRow(firstPos, uid, uidList, num, backward);
118,835,745✔
322
    }
323

324
    if (uid > uidList[lastPos] || uid < uidList[firstPos]) {
69,284,454✔
325
      return -1;
107,264✔
326
    }
327

328
    int32_t numOfRows = lastPos - firstPos + 1;
69,175,321✔
329
    int32_t midPos = (numOfRows >> 1u) + firstPos;
69,175,321✔
330

331
    if (uid < uidList[midPos]) {
69,175,321✔
332
      lastPos = midPos - 1;
12,938,467✔
333
    } else if (uid > uidList[midPos]) {
56,238,662✔
334
      firstPos = midPos + 1;
30,139,232✔
335
    } else {
336
      return findEarliestRow(midPos, uid, uidList, num, backward);
26,101,151✔
337
    }
338
  }
339
}
340

341
static int32_t extractSttBlockInfo(SLDataIter *pIter, const TSttBlkArray *pArray, SSttBlockLoadInfo *pBlockLoadInfo,
198,792,614✔
342
                                   uint64_t suid) {
343
  void   *px = NULL;
198,792,614✔
344
  int32_t code = TSDB_CODE_SUCCESS;
198,792,614✔
345
  if (TARRAY2_SIZE(pArray) <= 0) {
198,792,614✔
346
    return code;
147,475✔
347
  }
348

349
  SSttBlk *pStart = &pArray->data[0];
198,699,630✔
350
  SSttBlk *pEnd = &pArray->data[TARRAY2_SIZE(pArray) - 1];
198,707,378✔
351

352
  // all identical
353
  if (pStart->suid == pEnd->suid) {
198,665,779✔
354
    if (pStart->suid != suid) {  // no qualified stt block existed
168,751,783✔
355
      taosArrayClear(pBlockLoadInfo->aSttBlk);
43,699,151✔
356
      pIter->iSttBlk = -1;
43,691,154✔
357
      return TSDB_CODE_SUCCESS;
43,695,867✔
358
    } else {  // all blocks are qualified
359
      taosArrayClear(pBlockLoadInfo->aSttBlk);
125,059,405✔
360
      px = taosArrayAddBatch(pBlockLoadInfo->aSttBlk, pArray->data, pArray->size);
125,039,879✔
361
      if (px == NULL) {
125,066,850✔
UNCOV
362
        return terrno;
×
363
      }
364
    }
365
  } else {
366
    SArray *pTmp = taosArrayInit(TARRAY2_SIZE(pArray), sizeof(SSttBlk));
29,964,794✔
367
    if (pTmp == NULL) {
29,967,122✔
UNCOV
368
      return terrno;
×
369
    }
370

371
    for (int32_t i = 0; i < TARRAY2_SIZE(pArray); ++i) {
93,441,041✔
372
      SSttBlk *p = &pArray->data[i];
80,231,359✔
373
      if (p->suid < suid) {
80,230,674✔
374
        continue;
40,411,014✔
375
      }
376

377
      if (p->suid == suid) {
39,821,548✔
378
        void *px = taosArrayPush(pTmp, p);
23,062,905✔
379
        if (px == NULL) {
23,062,905✔
UNCOV
380
          code = terrno;
×
UNCOV
381
          break;
×
382
        }
383
      } else if (p->suid > suid) {
16,757,981✔
384
        break;
16,758,001✔
385
      }
386
    }
387

388
    taosArrayDestroy(pBlockLoadInfo->aSttBlk);
29,965,977✔
389
    pBlockLoadInfo->aSttBlk = pTmp;
29,967,118✔
390
  }
391

392
  return code;
154,958,033✔
393
}
394

395
static int32_t tValueDupPayload(SValue *pVal) {
37,961,368✔
396
  if (IS_VAR_DATA_TYPE(pVal->type) || pVal->type == TSDB_DATA_TYPE_DECIMAL) {
37,961,368✔
397
    char *p = (char *)pVal->pData;
13,224,570✔
398
    char *pBuf = taosMemoryMalloc(pVal->nData);
13,221,262✔
399
    if (pBuf == NULL) {
13,219,054✔
UNCOV
400
      return terrno;
×
401
    }
402

403
    memcpy(pBuf, p, pVal->nData);
13,219,054✔
404
    pVal->pData = (uint8_t *)pBuf;
13,220,474✔
405
  }
406

407
  return TSDB_CODE_SUCCESS;
37,961,213✔
408
}
409

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

418
  int32_t numOfBlocks = TARRAY2_SIZE(pStatisBlkArray);
198,796,320✔
419
  if (numOfBlocks <= 0) {
198,777,679✔
420
    return code;
147,475✔
421
  }
422

423
  while ((startIndex < numOfBlocks) && (pStatisBlkArray->data[startIndex].maxTbid.suid < suid)) {
218,537,566✔
424
    ++startIndex;
19,907,362✔
425
  }
426

427
  if (startIndex >= numOfBlocks || pStatisBlkArray->data[startIndex].minTbid.suid > suid) {
198,659,075✔
428
    return 0;
48,504,026✔
429
  }
430

431
  int32_t endIndex = startIndex;
150,191,205✔
432
  while (endIndex < numOfBlocks && pStatisBlkArray->data[endIndex].minTbid.suid <= suid) {
303,106,562✔
433
    ++endIndex;
152,915,357✔
434
  }
435

436
  int32_t num = endIndex - startIndex;
150,194,279✔
437
  pBlockLoadInfo->cost.loadStatisBlocks += num;
150,194,279✔
438

439
  STbStatisBlock block;
150,178,000✔
440
  code = tStatisBlockInit(&block);
150,141,631✔
441
  QUERY_CHECK_CODE(code, lino, _end);
150,222,109✔
442

443
  int64_t st = taosGetTimestampUs();
150,218,036✔
444

445
  for (int32_t k = startIndex; k < endIndex; ++k) {
303,142,215✔
446
    code = tsdbSttFileReadStatisBlock(pSttFileReader, &pStatisBlkArray->data[k], &block);
152,866,845✔
447
    QUERY_CHECK_CODE(code, lino, _end);
152,938,744✔
448

449
    int32_t i = 0;
152,938,744✔
450
    int32_t rows = block.numOfRecords;
152,938,744✔
451
    while (i < rows && ((int64_t *)block.suids.data)[i] != suid) {
194,221,505✔
452
      ++i;
41,282,761✔
453
    }
454

455
    // existed
456
    if (i < rows) {
152,930,543✔
457
      SSttTableRowsInfo *pInfo = &pBlockLoadInfo->info;
148,070,299✔
458

459
      if (pInfo->pUid == NULL) {
148,082,562✔
460
        pInfo->pUid = taosArrayInit(rows, sizeof(int64_t));
145,354,264✔
461
        pInfo->pFirstTs = taosArrayInit(rows, sizeof(int64_t));
145,340,798✔
462
        pInfo->pLastTs = taosArrayInit(rows, sizeof(int64_t));
145,357,431✔
463
        pInfo->pCount = taosArrayInit(rows, sizeof(int64_t));
145,347,531✔
464

465
        pInfo->pFirstKey = taosArrayInit(rows, sizeof(SValue));
145,346,837✔
466
        pInfo->pLastKey = taosArrayInit(rows, sizeof(SValue));
145,329,214✔
467

468
        if (pInfo->pUid == NULL || pInfo->pFirstTs == NULL || pInfo->pLastTs == NULL || pInfo->pCount == NULL ||
145,348,414✔
469
            pInfo->pFirstKey == NULL || pInfo->pLastKey == NULL) {
145,361,268✔
470
          code = terrno;
5,551✔
UNCOV
471
          goto _end;
×
472
        }
473

474
        pInfo->memSize = sizeof(SSttTableRowsInfo) + sizeof(SArray) * 6;
145,355,703✔
475
      }
476

477
      if (pStatisBlkArray->data[k].maxTbid.suid == suid) {
148,097,823✔
478
        int32_t size = rows - i;
141,745,069✔
479
        int32_t offset = i * sizeof(int64_t);
141,745,069✔
480

481
        px = taosArrayAddBatch(pInfo->pUid, tBufferGetDataAt(&block.uids, offset), size);
141,745,069✔
482
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
141,717,521✔
483

484
        px = taosArrayAddBatch(pInfo->pFirstTs, tBufferGetDataAt(&block.firstKeyTimestamps, offset), size);
141,717,521✔
485
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
141,734,143✔
486

487
        px = taosArrayAddBatch(pInfo->pLastTs, tBufferGetDataAt(&block.lastKeyTimestamps, offset), size);
141,734,143✔
488
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
141,750,100✔
489

490
        px = taosArrayAddBatch(pInfo->pCount, tBufferGetDataAt(&block.counts, offset), size);
141,750,100✔
491
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
141,756,637✔
492

493
        pInfo->memSize += size * sizeof(int64_t) * 4;
141,756,637✔
494
        pInfo->memSize += size * sizeof(SValue) * 2;
141,743,020✔
495

496
        if (block.numOfPKs > 0) {
141,685,513✔
497
          SValue vFirst = {0}, vLast = {0};
8,953,405✔
498
          for (int32_t f = i; f < rows; ++f) {
23,583,111✔
499
            code = tValueColumnGet(&block.firstKeyPKs[0], f, &vFirst);
14,629,355✔
500
            TSDB_CHECK_CODE(code, lino, _end);
14,629,521✔
501

502
            code = tValueDupPayload(&vFirst);
14,629,521✔
503
            TSDB_CHECK_CODE(code, lino, _end);
14,629,871✔
504

505
            px = taosArrayPush(pInfo->pFirstKey, &vFirst);
14,629,871✔
506
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
14,632,052✔
507

508
            // todo add api to clone the original data
509
            code = tValueColumnGet(&block.lastKeyPKs[0], f, &vLast);
14,632,052✔
510
            TSDB_CHECK_CODE(code, lino, _end);
14,632,928✔
511

512
            code = tValueDupPayload(&vLast);
14,632,928✔
513
            TSDB_CHECK_CODE(code, lino, _end);
14,630,933✔
514

515
            px = taosArrayPush(pInfo->pLastKey, &vLast);
14,630,933✔
516
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
14,632,636✔
517

518
            pInfo->memSize += (IS_VAR_DATA_TYPE(vFirst.type) || vFirst.type == TSDB_DATA_TYPE_DECIMAL)? (vFirst.nData + vLast.nData):0;
14,632,636✔
519
          }
520
        } else {
521
          SValue vFirst = {0};
132,732,108✔
522
          for (int32_t j = 0; j < size; ++j) {
1,719,054,078✔
523
            px = taosArrayPush(pInfo->pFirstKey, &vFirst);
1,586,356,062✔
524
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
1,586,169,871✔
525

526
            px = taosArrayPush(pInfo->pLastKey, &vFirst);
1,586,169,871✔
527
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
1,586,317,309✔
528
          }
529
        }
530
      } else {
531
        STbStatisRecord record = {0};
6,334,390✔
532
        while (i < rows) {
14,618,707✔
533
          code = tStatisBlockGet(&block, i, &record);
14,618,794✔
534
          TSDB_CHECK_CODE(code, lino, _end);
14,618,778✔
535

536
          if (record.suid != suid) {
14,618,778✔
537
            break;
6,334,642✔
538
          }
539

540
          px = taosArrayPush(pInfo->pUid, &record.uid);
8,284,136✔
541
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
8,283,954✔
542

543
          px = taosArrayPush(pInfo->pCount, &record.count);
8,283,954✔
544
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
8,284,875✔
545

546
          px = taosArrayPush(pInfo->pFirstTs, &record.firstKey.ts);
8,284,875✔
547
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
8,285,093✔
548

549
          px = taosArrayPush(pInfo->pLastTs, &record.lastKey.ts);
8,285,093✔
550
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
8,284,494✔
551

552
          pInfo->memSize += (sizeof(int64_t) * 4 + sizeof(SValue) * 2);
8,284,494✔
553

554
          if (record.firstKey.numOfPKs > 0) {
8,283,540✔
555
            SValue first = record.firstKey.pks[0];
4,349,727✔
556
            code = tValueDupPayload(&first);
4,349,435✔
557
            TSDB_CHECK_CODE(code, lino, _end);
4,349,416✔
558

559
            px = taosArrayPush(pInfo->pFirstKey, &first);
4,349,416✔
560
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
4,349,581✔
561

562
            SValue last = record.lastKey.pks[0];
4,349,581✔
563
            code = tValueDupPayload(&last);
4,349,581✔
564
            TSDB_CHECK_CODE(code, lino, _end);
4,349,727✔
565

566
            px = taosArrayPush(pInfo->pLastKey, &last);
4,349,727✔
567
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
4,349,562✔
568

569
            pInfo->memSize += (IS_VAR_DATA_TYPE(first.type) || first.type == TSDB_DATA_TYPE_DECIMAL)? (first.nData + last.nData):0;
4,349,562✔
570
          } else {
571
            SValue v = {0};
3,933,813✔
572
            px = taosArrayPush(pInfo->pFirstKey, &v);
3,934,409✔
573
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
3,935,257✔
574

575
            px = taosArrayPush(pInfo->pLastKey, &v);
3,935,257✔
576
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
3,935,492✔
577
          }
578

579
          i += 1;
8,284,317✔
580
        }
581
      }
582
    }
583
  }
584

585
_end:
150,299,822✔
586
  tStatisBlockDestroy(&block);
150,176,253✔
587
  if (code != 0) {
150,214,436✔
UNCOV
588
    tsdbError("%s error happens at:%s line number: %d, code:%s", id, __func__, lino, tstrerror(code));
×
589
  } else {
590
    double el = (taosGetTimestampUs() - st) / 1000.0;
150,211,414✔
591
    pBlockLoadInfo->cost.statisElapsedTime += el;
150,211,414✔
592

593
    tsdbDebug("%s load %d statis blocks into buf, elapsed time:%.2fms", id, num, el);
150,231,527✔
594
  }
595
  return code;
150,212,740✔
596
}
597

598
static int32_t doLoadSttFilesBlk(SSttBlockLoadInfo *pBlockLoadInfo, SLDataIter *pIter, int64_t suid,
198,784,515✔
599
                                 _load_tomb_fn loadTombFn, void *pReader1, const char *idStr, bool loadFromDisk) {
600
  int64_t st = taosGetTimestampUs();
198,857,464✔
601

602
  const TSttBlkArray *pSttBlkArray = NULL;
198,857,464✔
603
  pBlockLoadInfo->sttBlockLoaded = true;
198,822,608✔
604

605
  // load the stt block info for each stt-block
606
  int32_t code = tsdbSttFileReadSttBlk(pIter->pReader, &pSttBlkArray);
198,876,335✔
607
  if (code != TSDB_CODE_SUCCESS) {
198,798,457✔
UNCOV
608
    tsdbError("load stt blk failed, code:%s, %s", tstrerror(code), idStr);
×
UNCOV
609
    return code;
×
610
  }
611

612
  // load the stt block info for each stt file block
613
  code = extractSttBlockInfo(pIter, pSttBlkArray, pBlockLoadInfo, suid);
198,798,457✔
614
  if (code != TSDB_CODE_SUCCESS) {
198,790,997✔
615
    tsdbError("load stt block info failed, code:%s, %s", tstrerror(code), idStr);
875✔
UNCOV
616
    return code;
×
617
  }
618

619
  if (loadFromDisk) {
198,792,052✔
620
    // load stt statistics block for all stt-blocks, to decide if the data of queried table exists in current stt file
621
    TStatisBlkArray *pStatisBlkArray = NULL;
198,788,791✔
622
    code = tsdbSttFileReadStatisBlk(pIter->pReader, (const TStatisBlkArray **)&pStatisBlkArray);
198,784,485✔
623
    if (code != TSDB_CODE_SUCCESS) {
198,799,467✔
UNCOV
624
      tsdbError("failed to load stt block statistics, code:%s, %s", tstrerror(code), idStr);
×
UNCOV
625
      return code;
×
626
    }
627

628
    // load statistics block for all tables in current stt file
629
    code = loadSttStatisticsBlockData(pIter->pReader, pIter->pBlockLoadInfo, pStatisBlkArray, suid, idStr);
198,799,467✔
630
    if (code != TSDB_CODE_SUCCESS) {
198,812,090✔
UNCOV
631
      tsdbError("failed to load stt statistics block data, code:%s, %s", tstrerror(code), idStr);
×
UNCOV
632
      return code;
×
633
    }
634
  } else {
635
    tsdbDebug("stt block statis info loaded from cache, %s", idStr);
3,261✔
636
  }
637

638
  code = loadTombFn(pReader1, pIter->pReader, pIter->pBlockLoadInfo);
198,856,182✔
639

640
  double el = (taosGetTimestampUs() - st) / 1000.0;
198,869,482✔
641
  tsdbDebug("load the stt file blk info completed, elapsed time:%.2fms, %s", el, idStr);
198,869,482✔
642
  return code;
198,836,130✔
643
}
644

645
static int32_t uidComparFn(const void *p1, const void *p2) {
279,985,442✔
646
  const uint64_t *pFirst = p1;
279,985,442✔
647
  const uint64_t *pVal = p2;
279,985,442✔
648

649
  if (*pFirst == *pVal) {
279,985,442✔
650
    return 0;
144,053,204✔
651
  } else {
652
    return *pFirst < *pVal ? -1 : 1;
136,018,389✔
653
  }
654
}
655

656
static void setSttInfoForCurrentTable(SSttBlockLoadInfo *pLoadInfo, uint64_t uid, SSttKeyRange *pRange,
288,752,931✔
657
                                      int64_t *numOfRows) {
658
  if (pRange == NULL || taosArrayGetSize(pLoadInfo->info.pUid) == 0) {
288,752,931✔
659
    return;
77,864,670✔
660
  }
661

662
  int32_t index = taosArraySearchIdx(pLoadInfo->info.pUid, &uid, uidComparFn, TD_EQ);
210,947,349✔
663
  if (index >= 0) {
210,882,063✔
664
    pRange->skey.ts = *(int64_t *)taosArrayGet(pLoadInfo->info.pFirstTs, index);
144,025,629✔
665
    pRange->ekey.ts = *(int64_t *)taosArrayGet(pLoadInfo->info.pLastTs, index);
144,054,049✔
666

667
    *numOfRows += *(int64_t *)taosArrayGet(pLoadInfo->info.pCount, index);
144,060,741✔
668

669
    if (pRange->skey.numOfPKs > 0) {
144,053,399✔
670
      memcpy(&pRange->skey.pks[0], taosArrayGet(pLoadInfo->info.pFirstKey, index), sizeof(SValue));
11,533,415✔
671
      memcpy(&pRange->ekey.pks[0], taosArrayGet(pLoadInfo->info.pLastKey, index), sizeof(SValue));
11,536,548✔
672
    }
673
  }
674
}
675

676
int32_t tLDataIterOpen2(SLDataIter *pIter, SSttFileReader *pSttFileReader, int32_t cid, int8_t backward,
288,786,856✔
677
                        SMergeTreeConf *pConf, SSttBlockLoadInfo *pBlockLoadInfo, SSttKeyRange *pKeyRange,
678
                        int64_t *numOfRows, const char *idStr, bool loadFromDisk) {
679
  int32_t code = TSDB_CODE_SUCCESS;
288,786,856✔
680

681
  pIter->uid = pConf->uid;
288,786,856✔
682
  pIter->cid = cid;
288,844,709✔
683
  pIter->backward = backward;
288,875,144✔
684
  pIter->verRange.minVer = pConf->verRange.minVer;
288,862,415✔
685
  pIter->verRange.maxVer = pConf->verRange.maxVer;
288,774,577✔
686
  pIter->timeWindow.skey = pConf->timewindow.skey;
288,832,143✔
687
  pIter->timeWindow.ekey = pConf->timewindow.ekey;
288,778,518✔
688

689
  pIter->pStartRowKey = pConf->pCurRowKey;
288,839,522✔
690
  pIter->pReader = pSttFileReader;
288,776,773✔
691
  pIter->pBlockLoadInfo = pBlockLoadInfo;
288,851,158✔
692

693
  // open stt file failed, ignore and continue
694
  if (pIter->pReader == NULL) {
288,848,183✔
UNCOV
695
    tsdbError("stt file reader is null, %s", idStr);
×
UNCOV
696
    pIter->pSttBlk = NULL;
×
UNCOV
697
    pIter->iSttBlk = -1;
×
698
    return TSDB_CODE_SUCCESS;
×
699
  }
700

701
  if (!pBlockLoadInfo->sttBlockLoaded) {
288,747,703✔
702
      code = doLoadSttFilesBlk(pBlockLoadInfo, pIter, pConf->suid, pConf->loadTombFn, pConf->pReader, idStr, loadFromDisk);
198,786,969✔
703
  }
704

705
  setSttInfoForCurrentTable(pBlockLoadInfo, pConf->uid, pKeyRange, numOfRows);
288,698,689✔
706

707
  // find the start block, actually we could load the position to avoid repeatly searching for the start position when
708
  // the skey is updated.
709
  size_t size = taosArrayGetSize(pBlockLoadInfo->aSttBlk);
288,772,654✔
710
  pIter->iSttBlk = binarySearchForStartBlock(pBlockLoadInfo->aSttBlk->pData, size, pConf->uid, backward);
288,826,056✔
711
  if (pIter->iSttBlk != -1) {
288,767,177✔
712
    pIter->pSttBlk = taosArrayGet(pBlockLoadInfo->aSttBlk, pIter->iSttBlk);
144,162,841✔
713
    pIter->iRow = (pIter->backward) ? pIter->pSttBlk->nRow : -1;
144,134,933✔
714

715
    if ((!backward) && ((pConf->strictTimeRange && pIter->pSttBlk->minKey >= pIter->timeWindow.ekey) ||
144,129,268✔
716
                        (!pConf->strictTimeRange && pIter->pSttBlk->minKey > pIter->timeWindow.ekey))) {
137,081,675✔
717
      pIter->pSttBlk = NULL;
12,728✔
718
    }
719

720
    if (backward && ((pConf->strictTimeRange && pIter->pSttBlk->maxKey <= pIter->timeWindow.skey) ||
144,078,420✔
721
                     (!pConf->strictTimeRange && pIter->pSttBlk->maxKey < pIter->timeWindow.skey))) {
7,064,528✔
722
      pIter->pSttBlk = NULL;
201,972✔
723
      pIter->ignoreEarlierTs = true;
185,217✔
724
    }
725
  }
726

727
  return code;
288,674,054✔
728
}
729

730
void tLDataIterClose2(SLDataIter *pIter) {
198,863,136✔
731
  tsdbSttFileReaderClose(&pIter->pReader);
198,863,136✔
732
  pIter->pReader = NULL;
198,862,108✔
733
}
198,866,700✔
734

735
void tLDataIterNextBlock(SLDataIter *pIter, const char *idStr) {
147,965,451✔
736
  int32_t step = pIter->backward ? -1 : 1;
147,965,451✔
737
  int32_t oldIndex = pIter->iSttBlk;
148,001,676✔
738

739
  pIter->iSttBlk += step;
148,006,627✔
740

741
  int32_t index = -1;
148,007,463✔
742
  size_t  size = pIter->pBlockLoadInfo->aSttBlk->size;
148,007,463✔
743
  for (int32_t i = pIter->iSttBlk; i < size && i >= 0; i += step) {
148,376,890✔
744
    SSttBlk *p = taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, i);
13,791,120✔
745
    if ((!pIter->backward) && p->minUid > pIter->uid) {
13,791,536✔
746
      break;
6,123,094✔
747
    }
748

749
    if (pIter->backward && p->maxUid < pIter->uid) {
7,670,351✔
750
      break;
944,718✔
751
    }
752

753
    // check uid firstly
754
    if (p->minUid <= pIter->uid && p->maxUid >= pIter->uid) {
6,723,907✔
755
      if ((!pIter->backward) && p->minKey > pIter->timeWindow.ekey) {
6,723,907✔
756
        break;
81,484✔
757
      }
758

759
      if (pIter->backward && p->maxKey < pIter->timeWindow.skey) {
6,642,314✔
760
        break;
104✔
761
      }
762

763
      // check time range secondly
764
      if (p->minKey <= pIter->timeWindow.ekey && p->maxKey >= pIter->timeWindow.skey) {
6,642,210✔
765
        if ((!pIter->backward) && p->minVer > pIter->verRange.maxVer) {
6,271,066✔
UNCOV
766
          break;
×
767
        }
768

769
        if (pIter->backward && p->maxVer < pIter->verRange.minVer) {
6,270,957✔
UNCOV
770
          break;
×
771
        }
772

773
        if (p->minVer <= pIter->verRange.maxVer && p->maxVer >= pIter->verRange.minVer) {
6,270,848✔
774
          index = i;
6,271,066✔
775
          break;
6,271,066✔
776
        }
777
      }
778
    }
779
  }
780

781
  pIter->pSttBlk = NULL;
148,026,814✔
782
  if (index != -1) {
147,966,593✔
783
    SSttBlk *p = taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, index);
6,271,066✔
784

785
    pIter->iSttBlk = index;
6,271,066✔
786
    pIter->pSttBlk = (SSttBlk *)taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, pIter->iSttBlk);
6,271,066✔
787
    tsdbDebug("try next stt-file block:%d from %d, trigger by uid:%" PRIu64 ", stt-fileVer:%" PRId64
6,270,957✔
788
              ", uidRange:%" PRId64 "-%" PRId64 " %s",
789
              pIter->iSttBlk, oldIndex, pIter->uid, pIter->cid, p->minUid, p->maxUid, idStr);
790
  } else {
791
    tsdbDebug("no more last block qualified, uid:%" PRIu64 ", stt-file block:%d, %s", pIter->uid, oldIndex, idStr);
141,695,527✔
792
  }
793
}
147,966,484✔
794

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

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

807
  // mostly we only need to find the start position for a given table
808
  if ((((i == 0) && (!pIter->backward)) || (i == pData->nRow - 1 && pIter->backward)) && pData->aUid != NULL) {
2,147,483,647✔
809
    i = binarySearchForStartRowIndex((uint64_t *)pData->aUid, pData->nRow, pIter->uid, pIter->backward);
145,077,492✔
810
    if (i == -1) {
145,013,948✔
811
      tsdbDebug("failed to find the data in pBlockData, uid:%" PRIu64 " , %s", pIter->uid, idStr);
107,264✔
812
      pIter->iRow = -1;
107,264✔
813
      return code;
107,264✔
814
    }
815
  }
816

817
  for (; i < pData->nRow && i >= 0; i += step) {
2,147,483,647✔
818
    if (pData->aUid != NULL) {
2,147,483,647✔
819
      if (!pIter->backward) {
2,147,483,647✔
820
        if (pData->aUid[i] > pIter->uid) {
2,147,483,647✔
821
          break;
26,910,729✔
822
        }
823
      } else {
824
        if (pData->aUid[i] < pIter->uid) {
516,244,992✔
825
          break;
2,551,146✔
826
        }
827
      }
828
    }
829

830
    int64_t ts = pData->aTSKEY[i];
2,147,483,647✔
831
    if (!pIter->backward) {               // asc
2,147,483,647✔
832
      if (ts > pIter->timeWindow.ekey) {  // no more data
2,147,483,647✔
833
        break;
521,402✔
834
      } else {
835
        if (ts < pIter->timeWindow.skey) {
2,147,483,647✔
836
          continue;
1,155,867,503✔
837
        }
838

839
        if (ts == pIter->timeWindow.skey && pIter->pStartRowKey->numOfPKs > 0) {
2,147,483,647✔
840
          SRowKey key;
164,304✔
841
          tColRowGetKey(pData, i, &key);
164,304✔
842
          int32_t ret = pkCompEx(&key, pIter->pStartRowKey);
164,304✔
843
          if (ret < 0) {
164,304✔
UNCOV
844
            continue;
×
845
          }
846
        }
847
      }
848
    } else {
849
      if (ts < pIter->timeWindow.skey) {
530,259,942✔
850
        break;
786,605✔
851
      } else {
852
        if (ts > pIter->timeWindow.ekey) {
529,466,124✔
853
          continue;
86,609,788✔
854
        }
855

856
        if (ts == pIter->timeWindow.ekey && pIter->pStartRowKey->numOfPKs > 0) {
442,886,663✔
UNCOV
857
          SRowKey key;
×
UNCOV
858
          tColRowGetKey(pData, i, &key);
×
UNCOV
859
          int32_t ret = pkCompEx(&key, pIter->pStartRowKey);
×
860
          if (ret > 0) {
×
861
            continue;
×
862
          }
863
        }
864
      }
865
    }
866

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

872
    // todo opt handle desc case
873
    if (ver > pIter->verRange.maxVer) {
2,147,483,647✔
UNCOV
874
      continue;
×
875
    }
876

877
    hasVal = true;
2,147,483,647✔
878
    break;
2,147,483,647✔
879
  }
880

881
  pIter->iRow = (hasVal) ? i : -1;
2,147,483,647✔
882
  return code;
2,147,483,647✔
883
}
884

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

892
  *hasNext = false;
2,147,483,647✔
893

894
  // no qualified last file block in current file, no need to fetch row
895
  if (pIter->pSttBlk == NULL) {
2,147,483,647✔
896
    return code;
144,910,730✔
897
  }
898

899
  code = loadLastBlock(pIter, idStr, &pBlockData);
2,147,483,647✔
900
  if (pBlockData == NULL || code != TSDB_CODE_SUCCESS) {
2,147,483,647✔
UNCOV
901
    lino = __LINE__;
×
UNCOV
902
    goto _exit;
×
903
  }
904

905
  pIter->iRow += step;
2,147,483,647✔
906

907
  while (1) {
6,271,066✔
908
    bool skipBlock = false;
2,147,483,647✔
909
    code = findNextValidRow(pIter, idStr);
2,147,483,647✔
910
    TSDB_CHECK_CODE(code, lino, _exit);
2,147,483,647✔
911

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

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

935
    if (skipBlock || pIter->iRow >= pBlockData->nRow || pIter->iRow < 0) {
2,147,483,647✔
936
      tLDataIterNextBlock(pIter, idStr);
153,890,634✔
937
      if (pIter->pSttBlk == NULL) {  // no more data
147,962,667✔
938
        goto _exit;
141,740,218✔
939
      }
940
    } else {
941
      break;
942
    }
943

944
    if (iBlockL != pIter->iSttBlk) {
6,271,066✔
945
      code = loadLastBlock(pIter, idStr, &pBlockData);
6,271,066✔
946
      if ((pBlockData == NULL) || (code != 0)) {
6,270,957✔
UNCOV
947
        lino = __LINE__;
×
UNCOV
948
        goto _exit;
×
949
      }
950

951
      // set start row index
952
      pIter->iRow = pIter->backward ? pBlockData->nRow - 1 : 0;
6,271,066✔
953
    }
954
  }
955

956
  pIter->rInfo.suid = pBlockData->suid;
2,147,483,647✔
957
  pIter->rInfo.uid = pBlockData->uid;
2,147,483,647✔
958
  pIter->rInfo.row = tsdbRowFromBlockData(pBlockData, pIter->iRow);
2,147,483,647✔
959

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

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

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

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

978
  int32_t ret = tRowKeyCompare(&rkey1, &rkey2);
2,147,483,647✔
979
  if (ret < 0) {
2,147,483,647✔
980
    return -1;
1,454,104,705✔
981
  } else if (ret > 0) {
2,147,483,647✔
982
    return 1;
1,910,223,377✔
983
  } else {
984
    int64_t ver1 = TSDBROW_VERSION(&pIter1->rInfo.row);
2,147,483,647✔
985
    int64_t ver2 = TSDBROW_VERSION(&pIter2->rInfo.row);
2,147,483,647✔
986

987
    if (ver1 < ver2) {
2,147,483,647✔
988
      return -1;
1,270,002,755✔
989
    } else if (ver1 > ver2) {
1,910,846,274✔
990
      return 1;
1,910,855,121✔
991
    } else {
UNCOV
992
      return 0;
×
993
    }
994
  }
995
}
996

997
static FORCE_INLINE int32_t tLDataIterDescCmprFn(const SRBTreeNode *p1, const SRBTreeNode *p2) {
26,655,053✔
998
  return -1 * tLDataIterCmprFn(p1, p2);
26,655,053✔
999
}
1000

1001
static void clearTableRowsInfoCache(void) {
131,794✔
1002
  int32_t items = (statisCacheInfo.pStatisFileCache != NULL)? taosLRUCacheGetElems(statisCacheInfo.pStatisFileCache):0;
131,794✔
1003
  tsdbInfo("start to free %d items in statisCache", items);
131,794✔
1004

1005
  taosLRUCacheCleanup(statisCacheInfo.pStatisFileCache);
131,794✔
1006
  (void)taosThreadMutexDestroy(&statisCacheInfo.lock);
131,794✔
1007
}
131,794✔
1008

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

1016
int32_t tMergeTreeOpen2(SMergeTree *pMTree, SMergeTreeConf *pConf, SSttDataInfoForTable *pSttDataInfo) {
309,648,837✔
1017
  int32_t               code = TSDB_CODE_SUCCESS;
309,648,837✔
1018
  STFileSet *           pFset = (STFileSet *)pConf->pCurrentFileset;
309,648,837✔
1019
  bool                  loadStatisFromDisk = true;
309,690,817✔
1020
  int32_t               lino = 0;
309,690,817✔
1021
  int32_t               numOfLevels = pFset->lvlArr->size;
309,690,817✔
1022
  SSttStatisCacheValue* pValue = NULL;
309,683,308✔
1023
  LRUHandle*            pHandle = NULL;
309,679,928✔
1024
  SSttStatisCacheKey    key = {.suid = pConf->suid, .fid = pFset->fid, .vgId = TD_VID(pConf->pTsdb->pVnode)};
309,677,921✔
1025

1026
  (void)taosThreadOnce(&tsCacheInit, initTableRowsInfoCache);
309,692,395✔
1027

1028
  pMTree->pIter = NULL;
309,604,909✔
1029
  pMTree->backward = pConf->backward;
309,648,202✔
1030
  pMTree->idStr = pConf->idstr;
309,573,817✔
1031

1032
  if (!pMTree->backward) {  // asc
309,628,349✔
1033
    tRBTreeCreate(&pMTree->rbt, tLDataIterCmprFn);
296,835,705✔
1034
  } else {  // desc
1035
    tRBTreeCreate(&pMTree->rbt, tLDataIterDescCmprFn);
12,808,049✔
1036
  }
1037

1038
  pMTree->ignoreEarlierTs = false;
309,631,176✔
1039

1040
  // no data exists, go to end
1041
  if (numOfLevels == 0) {
309,609,063✔
1042
    goto _end;
39,783,696✔
1043
  }
1044

1045
  code = adjustSttDataIters(pConf->pSttFileBlockIterArray, pConf->pCurrentFileset);
269,825,367✔
1046
  if (code) {
269,836,701✔
UNCOV
1047
    goto _end;
×
1048
  }
1049

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

1066
  for (int32_t j = 0; j < numOfLevels; ++j) {
558,259,684✔
1067
    SSttLvl *pSttLevel = ((STFileSet *)pConf->pCurrentFileset)->lvlArr->data[j];
288,406,410✔
1068
    SArray  *pList = taosArrayGetP(pConf->pSttFileBlockIterArray, j);
288,473,636✔
1069

1070
    for (int32_t i = 0; i < TARRAY2_SIZE(pSttLevel->fobjArr); ++i) {  // open all last file
577,347,034✔
1071
      SLDataIter *pIter = taosArrayGetP(pList, i);
288,801,417✔
1072

1073
      SSttFileReader    *pSttFileReader = pIter->pReader;
288,848,941✔
1074
      SSttBlockLoadInfo *pLoadInfo = pIter->pBlockLoadInfo;
288,830,202✔
1075

1076
      // open stt file reader if not opened yet
1077
      // if failed to open this stt file, ignore the error and try next one
1078
      if (pSttFileReader == NULL) {
288,856,481✔
1079
        int32_t pgSize = pConf->pTsdb->pVnode->config.tsdbPageSize;
198,827,235✔
1080

1081
        SSttFileReaderConfig conf = {
397,758,273✔
1082
            .tsdb = pConf->pTsdb, .szPage = pgSize, .file[0] = *pSttLevel->fobjArr->data[i]->f};
198,848,498✔
1083

1084
        code = tsdbSttFileReaderOpen(pSttLevel->fobjArr->data[i]->fname, &conf, &pSttFileReader);
198,885,110✔
1085
        if (code != TSDB_CODE_SUCCESS) {
198,760,834✔
UNCOV
1086
          tsdbError("open stt file reader error. file name %s, code %s, %s", pSttLevel->fobjArr->data[i]->fname,
×
1087
                    tstrerror(code), pMTree->idStr);
1088
        }
1089
      }
1090

1091
      if (pLoadInfo == NULL) {
288,789,635✔
1092
        code = tCreateSttBlockLoadInfo(pConf->pSchema, pConf->pCols, pConf->numOfCols, &pLoadInfo);
198,777,245✔
1093
        if (code != TSDB_CODE_SUCCESS) {
198,845,483✔
UNCOV
1094
          goto _end;
×
1095
        }
1096
      }
1097

1098
      if (!loadStatisFromDisk && (pLoadInfo->info.pCount == NULL)) {
288,857,873✔
1099
          code = getSttTableRowsInfo(pValue, pConf->pCurRowKey->numOfPKs, j, i, &pLoadInfo->info);
3,787✔
1100
          if (code != TSDB_CODE_SUCCESS) {
3,787✔
UNCOV
1101
            loadStatisFromDisk = true;  // failed to get statis info from cache, load it from stt file
×
1102
          }
1103
      }
1104

1105
      memset(pIter, 0, sizeof(SLDataIter));
288,857,873✔
1106

1107
      SSttKeyRange range = {.skey.numOfPKs = pConf->pCurRowKey->numOfPKs, .ekey.numOfPKs = pConf->pCurRowKey->numOfPKs};
288,857,873✔
1108
      int64_t      numOfRows = 0;
288,840,536✔
1109
      int64_t      cid = pSttLevel->fobjArr->data[i]->f->cid;
288,832,637✔
1110

1111
      code = tLDataIterOpen2(pIter, pSttFileReader, cid, pMTree->backward, pConf, pLoadInfo, &range, &numOfRows,
288,866,125✔
1112
                             pMTree->idStr, loadStatisFromDisk);
1113
      if (code != TSDB_CODE_SUCCESS) {
288,747,165✔
UNCOV
1114
        goto _end;
×
1115
      }
1116

1117
      bool hasVal = NULL;
288,747,165✔
1118
      code = tLDataIterNextRow(pIter, pMTree->idStr, &hasVal);
288,807,228✔
1119
      if (code) {
288,708,523✔
UNCOV
1120
        goto _end;
×
1121
      }
1122

1123
      if (hasVal) {
288,708,523✔
1124
        tMergeTreeAddIter(pMTree, pIter);
142,903,205✔
1125

1126
        // let's record the time window for current table of uid in the stt files
1127
        if (pSttDataInfo != NULL && numOfRows > 0) {
142,907,051✔
1128
          void *px = taosArrayPush(pSttDataInfo->pKeyRangeList, &range);
142,921,701✔
1129
          QUERY_CHECK_NULL(px, code, lino, _end, terrno);
142,952,421✔
1130

1131
          pSttDataInfo->numOfRows += numOfRows;
142,952,421✔
1132
        }
1133
      } else {
1134
        if (!pMTree->ignoreEarlierTs) {
145,805,318✔
1135
          pMTree->ignoreEarlierTs = pIter->ignoreEarlierTs;
145,699,432✔
1136
        }
1137
      }
1138
    }
1139
  }
1140

1141
  if (pConf->cacheStatis && loadStatisFromDisk) {
269,853,274✔
1142
    SSttStatisCacheKey    k = {0};
789✔
1143
    SSttStatisCacheValue *pVal = NULL;
789✔
1144

1145
    code = buildSttTableRowsInfoKV(pConf, TD_VID(pConf->pTsdb->pVnode), &k, &pVal);
789✔
1146
    if (code == TSDB_CODE_SUCCESS) {
789✔
1147
      code = putStatisInfoIntoCache(statisCacheInfo.pStatisFileCache, &k, pVal, pConf->idstr);
789✔
1148
    }
1149
  }
1150

1151
  if (pHandle != NULL && pConf->cacheStatis) {
269,750,915✔
1152
    releaseCacheHandle(statisCacheInfo.pStatisFileCache, &pHandle, true);
5,023✔
1153
  }
1154

1155
  return code;
269,760,054✔
1156

1157
_end:
39,751,512✔
1158
  if (pHandle != NULL && pConf->cacheStatis) {
39,782,956✔
UNCOV
1159
    releaseCacheHandle(statisCacheInfo.pStatisFileCache, &pHandle, true);
×
1160
  }
1161

1162
  tMergeTreeClose(pMTree);
39,782,956✔
1163
  return code;
39,783,336✔
1164
}
1165

1166
void tMergeTreeAddIter(SMergeTree *pMTree, SLDataIter *pIter) {
142,890,128✔
1167
  SRBTreeNode *node = tRBTreePut(&pMTree->rbt, (SRBTreeNode *)pIter);
142,890,128✔
1168
}
142,909,156✔
1169

UNCOV
1170
bool tMergeTreeIgnoreEarlierTs(SMergeTree *pMTree) { return pMTree->ignoreEarlierTs; }
×
1171

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

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

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

UNCOV
1187
  tsdbError("failed to pin any stt block, sttBlock:%d stt-fileVer:%" PRId64 " %s", pIter->iSttBlk, pIter->cid, id);
×
1188
}
1189

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

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

UNCOV
1204
  tsdbError("failed to unpin any stt block, sttBlock:%d stt-fileVer:%" PRId64 " %s", pIter->iSttBlk, pIter->cid, id);
×
1205
}
1206

1207
void tMergeTreePinSttBlock(SMergeTree *pMTree) {
2,147,483,647✔
1208
  if (pMTree->pIter == NULL) {
2,147,483,647✔
UNCOV
1209
    return;
×
1210
  }
1211

1212
  SLDataIter *pIter = pMTree->pIter;
2,147,483,647✔
1213
  pMTree->pPinnedBlockIter = pIter;
2,147,483,647✔
1214
  tLDataIterPinSttBlock(pIter, pMTree->idStr);
2,147,483,647✔
1215
}
1216

1217
void tMergeTreeUnpinSttBlock(SMergeTree *pMTree) {
2,147,483,647✔
1218
  if (pMTree->pPinnedBlockIter == NULL) {
2,147,483,647✔
UNCOV
1219
    return;
×
1220
  }
1221

1222
  SLDataIter *pIter = pMTree->pPinnedBlockIter;
2,147,483,647✔
1223
  pMTree->pPinnedBlockIter = NULL;
2,147,483,647✔
1224
  tLDataIterUnpinSttBlock(pIter, pMTree->idStr);
2,147,483,647✔
1225
}
1226

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

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

1243
      pMTree->pIter = NULL;
131,410,776✔
1244
    }
1245

1246
    // compare with min in RB Tree
1247
    pIter = (SLDataIter *)tRBTreeMin(&pMTree->rbt);
2,147,483,647✔
1248
    if (pMTree->pIter && pIter) {
2,147,483,647✔
1249
      int32_t c = pMTree->rbt.cmprFn(&pMTree->pIter->node, &pIter->node);
1,445,390,434✔
1250
      if (c > 0) {
1,445,365,468✔
1251
        (void)tRBTreePut(&pMTree->rbt, (SRBTreeNode *)pMTree->pIter);
1,252,095,308✔
1252
        pMTree->pIter = NULL;
1,252,113,488✔
1253
      } else if (!c) {
193,270,160✔
UNCOV
1254
        continue;
×
1255
      }
1256
    }
1257

1258
    break;
2,147,483,647✔
1259
  }
1260

1261
  if (pMTree->pIter == NULL) {
2,147,483,647✔
1262
    pMTree->pIter = (SLDataIter *)tRBTreeMin(&pMTree->rbt);
1,700,361,723✔
1263
    if (pMTree->pIter) {
1,700,327,338✔
1264
      tRBTreeDrop(&pMTree->rbt, (SRBTreeNode *)pMTree->pIter);
1,392,892,168✔
1265
    }
1266
  }
1267

1268
  *pHasNext = (pMTree->pIter != NULL);
2,147,483,647✔
1269
  return code;
2,147,483,647✔
1270
}
1271

1272
void tMergeTreeClose(SMergeTree *pMTree) {
611,154,299✔
1273
  pMTree->pIter = NULL;
611,154,299✔
1274
  pMTree->pPinnedBlockIter = NULL;
611,259,116✔
1275
}
611,224,544✔
1276

1277
int32_t buildSttTableRowsInfoKV(SMergeTreeConf *pConf, int32_t vgId, SSttStatisCacheKey *pKey,
789✔
1278
                                SSttStatisCacheValue **pValue) {
1279
  *pValue = taosMemoryCalloc(1, sizeof(SSttStatisCacheValue));
789✔
1280
  if (*pValue == NULL) {
789✔
UNCOV
1281
    return terrno;
×
1282
  }
1283

1284
  memset(pKey, 0, sizeof(SSttStatisCacheKey));
789✔
1285

1286
  STFileSet *pFset = (STFileSet *)pConf->pCurrentFileset;
789✔
1287

1288
  pKey->suid = pConf->suid;
789✔
1289
  pKey->vgId = vgId;
789✔
1290
  pKey->fid = pFset->fid;
789✔
1291

1292
  (*pValue)->commitTs = pFset->lastCommit;
789✔
1293

1294
  int32_t numOfLevels = TARRAY2_SIZE(pFset->lvlArr);
789✔
1295

1296
  (*pValue)->pLevel = taosArrayInit(numOfLevels, sizeof(void *));
789✔
1297
  if ((*pValue)->pLevel == NULL) {
789✔
UNCOV
1298
    return terrno;
×
1299
  }
1300

1301
  for (int32_t j = 0; j < numOfLevels; ++j) {
1,578✔
1302
    SSttLvl *pSttLevel = pFset->lvlArr->data[j];
789✔
1303
    SArray * pIterList = taosArrayGetP(pConf->pSttFileBlockIterArray, j);
789✔
1304
    if (pIterList == NULL) {
789✔
UNCOV
1305
      return terrno;
×
1306
    }
1307

1308
    SArray *pRowsInfoArr = taosArrayInit(TARRAY2_SIZE(pSttLevel->fobjArr), sizeof(SSttTableRowsInfo));
789✔
1309
    if (pRowsInfoArr == NULL) {
789✔
UNCOV
1310
      return terrno;
×
1311
    }
1312

1313
    for (int32_t i = 0; i < TARRAY2_SIZE(pSttLevel->fobjArr); ++i) {  // open all stt file
1,578✔
1314
      SLDataIter *       pIter = taosArrayGetP(pIterList, i);
789✔
1315
      SSttBlockLoadInfo *pLoadInfo = pIter->pBlockLoadInfo;
789✔
1316

1317
      void *px = taosArrayPush(pRowsInfoArr, &pLoadInfo->info);
789✔
1318
      if (px == NULL) {
789✔
UNCOV
1319
        return terrno;
×
1320
      }
1321

1322
      memset(&pLoadInfo->info, 0, sizeof(SSttTableRowsInfo));
789✔
1323
    }
1324

1325
    void *px = taosArrayPush((*pValue)->pLevel, &pRowsInfoArr);
789✔
1326
    if (px == NULL) {
789✔
UNCOV
1327
      return terrno;
×
1328
    }
1329
  }
1330

1331
  // todo handle memory failure
1332

1333
  return TSDB_CODE_SUCCESS;
789✔
1334
}
1335

1336
int32_t getStatisInfoFromCache(SLRUCache *pCache, SSttStatisCacheKey *pKey, SSttStatisCacheValue **pValue,
5,812✔
1337
                               LRUHandle **pHandle, const char *id) {
1338
  *pValue = NULL;
5,812✔
1339
  *pHandle = NULL;
5,812✔
1340

1341
  (void)taosThreadMutexLock(&statisCacheInfo.lock);
5,812✔
1342
  LRUHandle *pItemHandle = taosLRUCacheLookup(pCache, pKey, sizeof(SSttStatisCacheKey));
5,812✔
1343
  if (pItemHandle == NULL) {
5,812✔
1344
    (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
789✔
1345
    return TSDB_CODE_NOT_FOUND;
789✔
1346
  }
1347

1348
  void *p = taosLRUCacheValue(pCache, pItemHandle);
5,023✔
1349

1350
  *pValue = p;
5,023✔
1351
  *pHandle = pItemHandle;
5,023✔
1352

1353
  tsdbDebug("get statis info from cache suid:%" PRId64 ", vgId:%d, fid:%d, %s, commitTs:%" PRId64, pKey->suid,
5,023✔
1354
            pKey->vgId, pKey->fid, id, (*pValue)->commitTs);
1355

1356
  // (*pEntry)->hitTimes += 1;
1357
  (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
5,023✔
1358
  return TSDB_CODE_SUCCESS;
5,023✔
1359
}
1360

1361
void releaseCacheHandle(SLRUCache *pCache, LRUHandle **pHandle, bool lock) {
5,023✔
1362
  if (lock) {
5,023✔
1363
    (void)taosThreadMutexLock(&statisCacheInfo.lock);
5,023✔
1364
  }
1365

1366
  bool ret = taosLRUCacheRelease(pCache, *pHandle, false);
5,023✔
1367
  *pHandle = NULL;
5,023✔
1368

1369
  if (lock) {
5,023✔
1370
    (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
5,023✔
1371
  }
1372
}
5,023✔
1373

1374
void freeStatisFileItems(const void* key, size_t keyLen, void* value, void* ud) {
789✔
1375
  (void)ud;
1376

1377
  if (value == NULL) {
789✔
UNCOV
1378
    return;
×
1379
  }
1380

1381
  SSttStatisCacheKey *  pKey = (SSttStatisCacheKey *)key;
789✔
1382
  SSttStatisCacheValue *pVal = value;
789✔
1383

1384
  for(int32_t i = 0; i < taosArrayGetSize(pVal->pLevel); ++i) {
1,578✔
1385
    SArray* pInfos = taosArrayGetP(pVal->pLevel, i);
789✔
1386

1387
    for(int32_t j = 0; j < taosArrayGetSize(pInfos); ++j) {
1,578✔
1388
      SSttTableRowsInfo* p = taosArrayGet(pInfos, j);
789✔
1389
      taosArrayDestroy(p->pCount);
789✔
1390
      taosArrayDestroyEx(p->pFirstKey, freeItem);
789✔
1391
      taosArrayDestroyEx(p->pLastKey, freeItem);
789✔
1392
      taosArrayDestroy(p->pFirstTs);
789✔
1393
      taosArrayDestroy(p->pLastTs);
789✔
1394
      taosArrayDestroy(p->pUid);
789✔
1395
    }
1396

1397
    taosArrayDestroy(pInfos);
789✔
1398
  }
1399

1400
  taosArrayDestroy(pVal->pLevel);
789✔
1401
  taosMemoryFree(pVal);
789✔
1402
}
1403

1404
int32_t putStatisInfoIntoCache(SLRUCache *pCache, SSttStatisCacheKey *pKey, SSttStatisCacheValue *pValue,
789✔
1405
                               const char *id) {
1406
  (void)taosThreadMutexLock(&statisCacheInfo.lock);
789✔
1407

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

1421
  (void)taosThreadMutexUnlock(&statisCacheInfo.lock);
789✔
1422
  return TSDB_CODE_SUCCESS;
789✔
1423
}
1424

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

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

1442
int32_t sttRowInfoDeepCopy(SSttTableRowsInfo *pDst, SSttTableRowsInfo *pInfo, int32_t numOfPKs) {
3,787✔
1443
  int32_t code = 0;
3,787✔
1444

1445
  pDst->pCount = taosArrayDup(pInfo->pCount, NULL);
3,787✔
1446
  pDst->pFirstKey = taosArrayDup(pInfo->pFirstKey, NULL);
3,787✔
1447
  pDst->pLastKey = taosArrayDup(pInfo->pLastKey, NULL);
3,787✔
1448
  pDst->pFirstTs = taosArrayDup(pInfo->pFirstTs, NULL);
3,787✔
1449
  pDst->pLastTs = taosArrayDup(pInfo->pLastTs, NULL);
3,787✔
1450
  pDst->pUid = taosArrayDup(pInfo->pUid, NULL);
3,787✔
1451

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

1476
  return TSDB_CODE_SUCCESS;
3,787✔
1477
}
1478

1479
int32_t getSttTableRowsInfo(SSttStatisCacheValue *pValue, int32_t numOfPKs, int32_t levelIdx, int32_t fileIdx,
3,787✔
1480
                            SSttTableRowsInfo *pRowInfo) {
1481
  if (levelIdx >= taosArrayGetSize(pValue->pLevel)) {
3,787✔
UNCOV
1482
    return TSDB_CODE_INVALID_PARA;
×
1483
  }
1484

1485
  SArray *pRowsInfoArr = *(SArray **)taosArrayGet(pValue->pLevel, levelIdx);
3,787✔
1486
  if (pRowsInfoArr == NULL) {
3,787✔
1487
    return TSDB_CODE_INVALID_PARA;
×
1488
  }
1489

1490
  if (fileIdx >= taosArrayGetSize(pRowsInfoArr)) {
3,787✔
UNCOV
1491
    return TSDB_CODE_INVALID_PARA;
×
1492
  }
1493

1494
  void* p = (SSttTableRowsInfo *)taosArrayGet(pRowsInfoArr, fileIdx);
3,787✔
1495
  if (p == NULL) {
3,787✔
1496
    return TSDB_CODE_INVALID_PARA;
×
1497
  }
1498

1499
  return sttRowInfoDeepCopy(pRowInfo, p, numOfPKs);
3,787✔
1500
}
1501

1502
int32_t getCacheValueSize(const SSttStatisCacheValue *pValue) {
789✔
1503
  int32_t size = sizeof(SSttStatisCacheValue) + sizeof(SArray);
789✔
1504
  for (int32_t i = 0; i < taosArrayGetSize(pValue->pLevel); ++i) {
1,578✔
1505
    SArray *pRowsInfoArr = *(SArray **)taosArrayGet(pValue->pLevel, i);
789✔
1506
    
1507
    size += sizeof(SArray);
789✔
1508
    for (int32_t j = 0; j < taosArrayGetSize(pRowsInfoArr); ++j) {
1,578✔
1509
      SSttTableRowsInfo *p = (SSttTableRowsInfo *)taosArrayGet(pRowsInfoArr, j);
789✔
1510
      size += p->memSize;
789✔
1511
    }
1512
  }
1513

1514
  return size;
789✔
1515
}
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