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

taosdata / TDengine / #4890

19 Dec 2025 11:37AM UTC coverage: 62.824% (-2.7%) from 65.487%
#4890

push

travis-ci

web-flow
feat: support TOTP code login and password expired tip (#33969)

22 of 26 new or added lines in 3 files covered. (84.62%)

1989 existing lines in 120 files now uncovered.

63068 of 100389 relevant lines covered (62.82%)

286770988.88 hits per line

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

86.51
/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) {
197,235,207✔
60
  *pInfo = NULL;
197,235,207✔
61

62
  SSttBlockLoadInfo *pLoadInfo = taosMemoryCalloc(1, sizeof(SSttBlockLoadInfo));
197,273,195✔
63
  if (pLoadInfo == NULL) {
197,197,353✔
64
    return terrno;
×
65
  }
66

67
  pLoadInfo->blockData[0].sttBlockIndex = -1;
197,197,353✔
68
  pLoadInfo->blockData[1].sttBlockIndex = -1;
197,199,199✔
69

70
  pLoadInfo->currentLoadBlockIndex = 1;
197,216,579✔
71

72
  int32_t code = tBlockDataCreate(&pLoadInfo->blockData[0].data);
197,228,604✔
73
  if (code) {
197,273,663✔
74
    taosMemoryFreeClear(pLoadInfo);
×
75
    return code;
×
76
  }
77

78
  code = tBlockDataCreate(&pLoadInfo->blockData[1].data);
197,273,663✔
79
  if (code) {
197,293,337✔
80
    taosMemoryFreeClear(pLoadInfo);
×
81
    return code;
×
82
  }
83

84
  pLoadInfo->aSttBlk = taosArrayInit(4, sizeof(SSttBlk));
197,293,337✔
85
  if (pLoadInfo->aSttBlk == NULL) {
197,313,338✔
86
    taosMemoryFreeClear(pLoadInfo);
×
87
    return terrno;
×
88
  }
89

90
  pLoadInfo->pSchema = pSchema;
197,333,500✔
91
  pLoadInfo->colIds = colList;
197,324,828✔
92
  pLoadInfo->numOfCols = numOfCols;
197,328,617✔
93

94
  *pInfo = pLoadInfo;
197,355,916✔
95
  return code;
197,326,048✔
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);
8,039,786✔
102
  }
103
}
2,147,483,647✔
104

105
void destroySttBlockLoadInfo(SSttBlockLoadInfo *pLoadInfo) {
197,247,737✔
106
  if (pLoadInfo == NULL) {
197,247,737✔
107
    return;
×
108
  }
109

110
  pLoadInfo->currentLoadBlockIndex = 1;
197,247,737✔
111

112
  SBlockDataInfo *pInfo = &pLoadInfo->blockData[0];
197,322,901✔
113
  tBlockDataDestroy(&pInfo->data);
197,299,153✔
114
  pInfo->sttBlockIndex = -1;
197,317,657✔
115
  pInfo->pin = false;
197,315,583✔
116

117
  pInfo = &pLoadInfo->blockData[1];
197,301,489✔
118
  tBlockDataDestroy(&pInfo->data);
197,267,109✔
119
  pInfo->sttBlockIndex = -1;
197,334,719✔
120
  pInfo->pin = false;
197,334,089✔
121

122
  taosArrayDestroy(pLoadInfo->info.pUid);
197,328,001✔
123
  taosArrayDestroy(pLoadInfo->info.pCount);
197,327,381✔
124
  taosArrayDestroy(pLoadInfo->info.pFirstTs);
197,334,358✔
125
  taosArrayDestroy(pLoadInfo->info.pLastTs);
197,326,920✔
126

127
  taosArrayDestroyEx(pLoadInfo->info.pFirstKey, freeItem);
197,329,440✔
128
  taosArrayDestroyEx(pLoadInfo->info.pLastKey, freeItem);
197,307,414✔
129

130
  pLoadInfo->info.pUid = NULL;
197,323,828✔
131
  pLoadInfo->info.pFirstKey = NULL;
197,339,109✔
132
  pLoadInfo->info.pLastKey = NULL;
197,334,131✔
133
  pLoadInfo->info.pCount = NULL;
197,332,225✔
134
  pLoadInfo->info.pFirstTs = NULL;
197,308,395✔
135
  pLoadInfo->info.pLastTs = NULL;
197,342,995✔
136

137
  taosArrayDestroy(pLoadInfo->aSttBlk);
197,335,238✔
138
  taosMemoryFree(pLoadInfo);
197,325,608✔
139
}
140

141
void destroyLDataIter(SLDataIter *pIter) {
197,342,025✔
142
  tLDataIterClose2(pIter);
197,342,025✔
143
  destroySttBlockLoadInfo(pIter->pBlockLoadInfo);
197,304,411✔
144
  taosMemoryFree(pIter);
197,294,622✔
145
}
197,313,983✔
146

147
void destroySttBlockReader(SArray *pLDataIterArray, SSttBlockLoadCostInfo *pLoadCost) {
326,317,877✔
148
  if (pLDataIterArray == NULL) {
326,317,877✔
149
    return;
3,831,768✔
150
  }
151

152
  int32_t numOfLevel = taosArrayGetSize(pLDataIterArray);
322,486,109✔
153
  for (int32_t i = 0; i < numOfLevel; ++i) {
519,716,321✔
154
    SArray *pList = taosArrayGetP(pLDataIterArray, i);
197,205,351✔
155
    for (int32_t j = 0; j < taosArrayGetSize(pList); ++j) {
394,507,246✔
156
      SLDataIter *pIter = taosArrayGetP(pList, j);
197,370,357✔
157
      if (pIter->pBlockLoadInfo != NULL) {
197,366,015✔
158
        SSttBlockLoadCostInfo *pCost = &pIter->pBlockLoadInfo->cost;
197,373,656✔
159
        if (pLoadCost != NULL) {
197,368,015✔
160
          pLoadCost->loadBlocks += pCost->loadBlocks;
197,369,364✔
161
          pLoadCost->loadStatisBlocks += pCost->loadStatisBlocks;
197,366,532✔
162
          pLoadCost->blockElapsedTime += pCost->blockElapsedTime;
197,349,861✔
163
          pLoadCost->statisElapsedTime += pCost->statisElapsedTime;
197,360,856✔
164
        }
165
      }
166

167
      destroyLDataIter(pIter);
197,345,691✔
168
    }
169

170
    taosArrayDestroy(pList);
197,160,975✔
171
  }
172

173
  taosArrayDestroy(pLDataIterArray);
322,510,970✔
174
}
175

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

183
  pLoadInfo->currentLoadBlockIndex = nextSlotIndex;
129,397,186✔
184
}
129,335,161✔
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
14,519✔
197
                ", load data, %s",
198
                pIter->iSttBlk, pIter->cid, pIter->uid, idStr);
199
      pInfo->currentLoadBlockIndex = 0;
14,519✔
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
8,714✔
209
                ", load data, %s",
210
                pIter->iSttBlk, pIter->cid, pIter->uid, idStr);
211
      pInfo->currentLoadBlockIndex = 1;
8,714✔
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) {
129,275,098✔
219
    return code;
×
220
  }
221

222
  updateBlockLoadSlot(pInfo);
129,336,960✔
223
  int64_t st = taosGetTimestampUs();
129,357,606✔
224

225
  SBlockData *pBlock = &pInfo->blockData[pInfo->currentLoadBlockIndex].data;
129,357,606✔
226
  code = tsdbSttFileReadBlockDataByColumn(pIter->pReader, pIter->pSttBlk, pBlock, pInfo->pSchema, &pInfo->colIds[1],
129,282,459✔
227
                                          pInfo->numOfCols - 1);
129,305,966✔
228
  if (code != TSDB_CODE_SUCCESS) {
129,363,972✔
229
    return code;
×
230
  }
231

232
  double el = (taosGetTimestampUs() - st) / 1000.0;
129,411,003✔
233
  pInfo->cost.blockElapsedTime += el;
129,411,003✔
234
  pInfo->cost.loadBlocks += 1;
129,379,674✔
235

236
  tsdbDebug("read stt block, total load:%" PRId64 ", trigger by uid:%" PRIu64 ", stt-fileVer:%" PRId64
129,396,206✔
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;
129,397,190✔
244
  pIter->iRow = (pIter->backward) ? pInfo->blockData[pInfo->currentLoadBlockIndex].data.nRow : -1;
129,402,639✔
245

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

249
  *pResBlock = &pInfo->blockData[pInfo->currentLoadBlockIndex].data;
129,392,773✔
250
  return code;
129,355,342✔
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;
146,660,428✔
257
  int32_t step = backward ? 1 : -1;
146,660,428✔
258
  while (i >= 0 && i < num && uid >= pBlockList[i].minUid && uid <= pBlockList[i].maxUid) {
294,706,746✔
259
    i += step;
148,046,318✔
260
  }
261
  return i - step;
146,624,841✔
262
}
263

264
static int32_t binarySearchForStartBlock(SSttBlk *pBlockList, int32_t num, uint64_t uid, int32_t backward) {
279,680,442✔
265
  int32_t midPos = -1;
279,680,442✔
266
  if (num <= 0) {
279,680,442✔
267
    return -1;
62,857,874✔
268
  }
269

270
  int32_t firstPos = 0;
216,822,568✔
271
  int32_t lastPos = num - 1;
216,822,568✔
272

273
  // find the first position which is bigger than the key
274
  if ((uid > pBlockList[lastPos].maxUid) || (uid < pBlockList[firstPos].minUid)) {
216,822,568✔
275
    return -1;
70,194,643✔
276
  }
277

278
  while (1) {
6,787,807✔
279
    if (uid >= pBlockList[firstPos].minUid && uid <= pBlockList[firstPos].maxUid) {
153,380,714✔
280
      return findEarliestIndex(firstPos, uid, pBlockList, num, backward);
141,421,022✔
281
    }
282

283
    if (uid > pBlockList[lastPos].maxUid || uid < pBlockList[firstPos].minUid) {
11,993,930✔
284
      return -1;
9,322✔
285
    }
286

287
    int32_t numOfRows = lastPos - firstPos + 1;
11,990,607✔
288
    midPos = (numOfRows >> 1u) + firstPos;
11,990,607✔
289

290
    if (uid < pBlockList[midPos].minUid) {
11,990,607✔
291
      lastPos = midPos - 1;
3,104,945✔
292
    } else if (uid > pBlockList[midPos].maxUid) {
8,886,464✔
293
      firstPos = midPos + 1;
3,682,862✔
294
    } else {
295
      return findEarliestIndex(midPos, uid, pBlockList, num, backward);
5,203,819✔
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;
148,941,401✔
303
  int32_t step = backward ? 1 : -1;
148,941,401✔
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;
148,952,884✔
308
}
309

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

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

319
  while (1) {
45,787,807✔
320
    if (uid == uidList[firstPos]) {
194,901,562✔
321
      return findEarliestRow(firstPos, uid, uidList, num, backward);
122,717,385✔
322
    }
323

324
    if (uid > uidList[lastPos] || uid < uidList[firstPos]) {
72,174,718✔
325
      return -1;
151,356✔
326
    }
327

328
    int32_t numOfRows = lastPos - firstPos + 1;
72,018,772✔
329
    int32_t midPos = (numOfRows >> 1u) + firstPos;
72,018,772✔
330

331
    if (uid < uidList[midPos]) {
72,018,772✔
332
      lastPos = midPos - 1;
13,904,488✔
333
    } else if (uid > uidList[midPos]) {
58,119,490✔
334
      firstPos = midPos + 1;
31,883,319✔
335
    } else {
336
      return findEarliestRow(midPos, uid, uidList, num, backward);
26,235,499✔
337
    }
338
  }
339
}
340

341
static int32_t extractSttBlockInfo(SLDataIter *pIter, const TSttBlkArray *pArray, SSttBlockLoadInfo *pBlockLoadInfo,
197,252,829✔
342
                                   uint64_t suid) {
343
  void   *px = NULL;
197,252,829✔
344
  int32_t code = TSDB_CODE_SUCCESS;
197,252,829✔
345
  if (TARRAY2_SIZE(pArray) <= 0) {
197,252,829✔
346
    return code;
153,802✔
347
  }
348

349
  SSttBlk *pStart = &pArray->data[0];
197,148,593✔
350
  SSttBlk *pEnd = &pArray->data[TARRAY2_SIZE(pArray) - 1];
197,152,756✔
351

352
  // all identical
353
  if (pStart->suid == pEnd->suid) {
197,102,149✔
354
    if (pStart->suid != suid) {  // no qualified stt block existed
169,855,268✔
355
      taosArrayClear(pBlockLoadInfo->aSttBlk);
39,108,530✔
356
      pIter->iSttBlk = -1;
39,102,772✔
357
      return TSDB_CODE_SUCCESS;
39,106,823✔
358
    } else {  // all blocks are qualified
359
      taosArrayClear(pBlockLoadInfo->aSttBlk);
130,745,345✔
360
      px = taosArrayAddBatch(pBlockLoadInfo->aSttBlk, pArray->data, pArray->size);
130,748,384✔
361
      if (px == NULL) {
130,786,687✔
362
        return terrno;
×
363
      }
364
    }
365
  } else {
366
    SArray *pTmp = taosArrayInit(TARRAY2_SIZE(pArray), sizeof(SSttBlk));
27,279,803✔
367
    if (pTmp == NULL) {
27,285,663✔
368
      return terrno;
×
369
    }
370

371
    for (int32_t i = 0; i < TARRAY2_SIZE(pArray); ++i) {
92,875,755✔
372
      SSttBlk *p = &pArray->data[i];
76,059,539✔
373
      if (p->suid < suid) {
76,055,254✔
374
        continue;
42,940,847✔
375
      }
376

377
      if (p->suid == suid) {
33,117,537✔
378
        void *px = taosArrayPush(pTmp, p);
22,649,245✔
379
        if (px == NULL) {
22,649,245✔
380
          code = terrno;
×
381
          break;
×
382
        }
383
      } else if (p->suid > suid) {
10,467,707✔
384
        break;
10,471,453✔
385
      }
386
    }
387

388
    taosArrayDestroy(pBlockLoadInfo->aSttBlk);
27,283,142✔
389
    pBlockLoadInfo->aSttBlk = pTmp;
27,288,724✔
390
  }
391

392
  return code;
157,998,307✔
393
}
394

395
static int32_t tValueDupPayload(SValue *pVal) {
26,238,769✔
396
  if (IS_VAR_DATA_TYPE(pVal->type) || pVal->type == TSDB_DATA_TYPE_DECIMAL) {
26,238,769✔
397
    char *p = (char *)pVal->pData;
8,038,258✔
398
    char *pBuf = taosMemoryMalloc(pVal->nData);
8,038,939✔
399
    if (pBuf == NULL) {
8,038,424✔
400
      return terrno;
×
401
    }
402

403
    memcpy(pBuf, p, pVal->nData);
8,038,424✔
404
    pVal->pData = (uint8_t *)pBuf;
8,037,743✔
405
  }
406

407
  return TSDB_CODE_SUCCESS;
26,237,573✔
408
}
409

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

418
  int32_t numOfBlocks = TARRAY2_SIZE(pStatisBlkArray);
197,233,946✔
419
  if (numOfBlocks <= 0) {
197,250,199✔
420
    return code;
153,802✔
421
  }
422

423
  while ((startIndex < numOfBlocks) && (pStatisBlkArray->data[startIndex].maxTbid.suid < suid)) {
215,155,709✔
424
    ++startIndex;
18,059,312✔
425
  }
426

427
  if (startIndex >= numOfBlocks || pStatisBlkArray->data[startIndex].minTbid.suid > suid) {
197,128,751✔
428
    return 0;
46,074,791✔
429
  }
430

431
  int32_t endIndex = startIndex;
151,072,938✔
432
  while (endIndex < numOfBlocks && pStatisBlkArray->data[endIndex].minTbid.suid <= suid) {
305,121,198✔
433
    ++endIndex;
154,048,260✔
434
  }
435

436
  int32_t num = endIndex - startIndex;
151,058,195✔
437
  pBlockLoadInfo->cost.loadStatisBlocks += num;
151,058,195✔
438

439
  STbStatisBlock block;
151,052,010✔
440
  code = tStatisBlockInit(&block);
151,001,992✔
441
  QUERY_CHECK_CODE(code, lino, _end);
151,119,818✔
442

443
  int64_t st = taosGetTimestampUs();
151,090,462✔
444

445
  for (int32_t k = startIndex; k < endIndex; ++k) {
305,150,143✔
446
    code = tsdbSttFileReadStatisBlock(pSttFileReader, &pStatisBlkArray->data[k], &block);
154,018,511✔
447
    QUERY_CHECK_CODE(code, lino, _end);
154,095,009✔
448

449
    int32_t i = 0;
154,095,009✔
450
    int32_t rows = block.numOfRecords;
154,095,009✔
451
    while (i < rows && ((int64_t *)block.suids.data)[i] != suid) {
183,050,458✔
452
      ++i;
28,955,449✔
453
    }
454

455
    // existed
456
    if (i < rows) {
154,098,729✔
457
      SSttTableRowsInfo *pInfo = &pBlockLoadInfo->info;
153,489,293✔
458

459
      if (pInfo->pUid == NULL) {
153,495,459✔
460
        pInfo->pUid = taosArrayInit(rows, sizeof(int64_t));
150,496,008✔
461
        pInfo->pFirstTs = taosArrayInit(rows, sizeof(int64_t));
150,509,915✔
462
        pInfo->pLastTs = taosArrayInit(rows, sizeof(int64_t));
150,505,752✔
463
        pInfo->pCount = taosArrayInit(rows, sizeof(int64_t));
150,508,320✔
464

465
        pInfo->pFirstKey = taosArrayInit(rows, sizeof(SValue));
150,485,153✔
466
        pInfo->pLastKey = taosArrayInit(rows, sizeof(SValue));
150,487,263✔
467

468
        if (pInfo->pUid == NULL || pInfo->pFirstTs == NULL || pInfo->pLastTs == NULL || pInfo->pCount == NULL ||
150,472,976✔
469
            pInfo->pFirstKey == NULL || pInfo->pLastKey == NULL) {
150,482,058✔
470
          code = terrno;
28,891✔
471
          goto _end;
×
472
        }
473

474
        pInfo->memSize = sizeof(SSttTableRowsInfo) + sizeof(SArray) * 6;
150,470,906✔
475
      }
476

477
      if (pStatisBlkArray->data[k].maxTbid.suid == suid) {
153,485,771✔
478
        int32_t size = rows - i;
145,705,812✔
479
        int32_t offset = i * sizeof(int64_t);
145,705,812✔
480

481
        px = taosArrayAddBatch(pInfo->pUid, tBufferGetDataAt(&block.uids, offset), size);
145,705,812✔
482
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
145,739,303✔
483

484
        px = taosArrayAddBatch(pInfo->pFirstTs, tBufferGetDataAt(&block.firstKeyTimestamps, offset), size);
145,739,303✔
485
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
145,734,542✔
486

487
        px = taosArrayAddBatch(pInfo->pLastTs, tBufferGetDataAt(&block.lastKeyTimestamps, offset), size);
145,734,542✔
488
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
145,731,705✔
489

490
        px = taosArrayAddBatch(pInfo->pCount, tBufferGetDataAt(&block.counts, offset), size);
145,731,705✔
491
        TSDB_CHECK_NULL(px, code, lino, _end, terrno);
145,742,661✔
492

493
        pInfo->memSize += size * sizeof(int64_t) * 4;
145,742,661✔
494
        pInfo->memSize += size * sizeof(SValue) * 2;
145,722,302✔
495

496
        if (block.numOfPKs > 0) {
145,656,756✔
497
          SValue vFirst = {0}, vLast = {0};
6,418,729✔
498
          for (int32_t f = i; f < rows; ++f) {
15,489,464✔
499
            code = tValueColumnGet(&block.firstKeyPKs[0], f, &vFirst);
9,069,888✔
500
            TSDB_CHECK_CODE(code, lino, _end);
9,064,623✔
501

502
            code = tValueDupPayload(&vFirst);
9,064,623✔
503
            TSDB_CHECK_CODE(code, lino, _end);
9,067,845✔
504

505
            px = taosArrayPush(pInfo->pFirstKey, &vFirst);
9,067,845✔
506
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
9,070,735✔
507

508
            // todo add api to clone the original data
509
            code = tValueColumnGet(&block.lastKeyPKs[0], f, &vLast);
9,070,735✔
510
            TSDB_CHECK_CODE(code, lino, _end);
9,071,416✔
511

512
            code = tValueDupPayload(&vLast);
9,071,416✔
513
            TSDB_CHECK_CODE(code, lino, _end);
9,069,888✔
514

515
            px = taosArrayPush(pInfo->pLastKey, &vLast);
9,069,888✔
516
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
9,070,735✔
517

518
            pInfo->memSize += (IS_VAR_DATA_TYPE(vFirst.type) || vFirst.type == TSDB_DATA_TYPE_DECIMAL)? (vFirst.nData + vLast.nData):0;
9,070,735✔
519
          }
520
        } else {
521
          SValue vFirst = {0};
139,238,027✔
522
          for (int32_t j = 0; j < size; ++j) {
2,051,305,110✔
523
            px = taosArrayPush(pInfo->pFirstKey, &vFirst);
1,912,535,432✔
524
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
1,911,833,657✔
525

526
            px = taosArrayPush(pInfo->pLastKey, &vFirst);
1,911,833,657✔
527
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
1,912,031,443✔
528
          }
529
        }
530
      } else {
531
        STbStatisRecord record = {0};
7,762,026✔
532
        while (i < rows) {
24,373,318✔
533
          code = tStatisBlockGet(&block, i, &record);
24,371,452✔
534
          TSDB_CHECK_CODE(code, lino, _end);
24,378,904✔
535

536
          if (record.suid != suid) {
24,378,904✔
537
            break;
7,769,459✔
538
          }
539

540
          px = taosArrayPush(pInfo->pUid, &record.uid);
16,609,445✔
541
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
16,610,679✔
542

543
          px = taosArrayPush(pInfo->pCount, &record.count);
16,610,679✔
544
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
16,612,720✔
545

546
          px = taosArrayPush(pInfo->pFirstTs, &record.firstKey.ts);
16,612,720✔
547
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
16,613,536✔
548

549
          px = taosArrayPush(pInfo->pLastTs, &record.lastKey.ts);
16,613,536✔
550
          TSDB_CHECK_NULL(px, code, lino, _end, terrno);
16,613,779✔
551

552
          pInfo->memSize += (sizeof(int64_t) * 4 + sizeof(SValue) * 2);
16,613,779✔
553

554
          if (record.firstKey.numOfPKs > 0) {
16,606,798✔
555
            SValue first = record.firstKey.pks[0];
4,049,239✔
556
            code = tValueDupPayload(&first);
4,049,239✔
557
            TSDB_CHECK_CODE(code, lino, _end);
4,049,239✔
558

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

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

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

569
            pInfo->memSize += (IS_VAR_DATA_TYPE(first.type) || first.type == TSDB_DATA_TYPE_DECIMAL)? (first.nData + last.nData):0;
4,049,239✔
570
          } else {
571
            SValue v = {0};
12,557,559✔
572
            px = taosArrayPush(pInfo->pFirstKey, &v);
12,559,530✔
573
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
12,562,226✔
574

575
            px = taosArrayPush(pInfo->pLastKey, &v);
12,562,226✔
576
            TSDB_CHECK_NULL(px, code, lino, _end, terrno);
12,563,150✔
577
          }
578

579
          i += 1;
16,608,066✔
580
        }
581
      }
582
    }
583
  }
584

585
_end:
151,198,687✔
586
  tStatisBlockDestroy(&block);
151,044,615✔
587
  if (code != 0) {
151,105,962✔
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;
151,097,814✔
591
    pBlockLoadInfo->cost.statisElapsedTime += el;
151,097,814✔
592

593
    tsdbDebug("%s load %d statis blocks into buf, elapsed time:%.2fms", id, num, el);
151,117,525✔
594
  }
595
  return code;
151,103,214✔
596
}
597

598
static int32_t doLoadSttFilesBlk(SSttBlockLoadInfo *pBlockLoadInfo, SLDataIter *pIter, int64_t suid,
197,206,349✔
599
                                 _load_tomb_fn loadTombFn, void *pReader1, const char *idStr, bool loadFromDisk) {
600
  int64_t st = taosGetTimestampUs();
197,324,695✔
601

602
  const TSttBlkArray *pSttBlkArray = NULL;
197,324,695✔
603
  pBlockLoadInfo->sttBlockLoaded = true;
197,278,835✔
604

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

612
  // load the stt block info for each stt file block
613
  code = extractSttBlockInfo(pIter, pSttBlkArray, pBlockLoadInfo, suid);
197,241,486✔
614
  if (code != TSDB_CODE_SUCCESS) {
197,250,502✔
615
    tsdbError("load stt block info failed, code:%s, %s", tstrerror(code), idStr);
13,674✔
616
    return code;
×
617
  }
618

619
  if (loadFromDisk) {
197,236,828✔
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;
197,235,820✔
622
    code = tsdbSttFileReadStatisBlk(pIter->pReader, (const TStatisBlkArray **)&pStatisBlkArray);
197,213,597✔
623
    if (code != TSDB_CODE_SUCCESS) {
197,254,504✔
624
      tsdbError("failed to load stt block statistics, code:%s, %s", tstrerror(code), idStr);
×
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);
197,254,504✔
630
    if (code != TSDB_CODE_SUCCESS) {
197,228,868✔
631
      tsdbError("failed to load stt statistics block data, code:%s, %s", tstrerror(code), idStr);
×
632
      return code;
×
633
    }
634
  } else {
635
    tsdbDebug("stt block statis info loaded from cache, %s", idStr);
1,008✔
636
  }
637

638
  code = loadTombFn(pReader1, pIter->pReader, pIter->pBlockLoadInfo);
197,323,238✔
639

640
  double el = (taosGetTimestampUs() - st) / 1000.0;
197,288,013✔
641
  tsdbDebug("load the stt file blk info completed, elapsed time:%.2fms, %s", el, idStr);
197,288,013✔
642
  return code;
197,300,166✔
643
}
644

645
static int32_t uidComparFn(const void *p1, const void *p2) {
289,015,390✔
646
  const uint64_t *pFirst = p1;
289,015,390✔
647
  const uint64_t *pVal = p2;
289,015,390✔
648

649
  if (*pFirst == *pVal) {
289,015,390✔
650
    return 0;
146,559,236✔
651
  } else {
652
    return *pFirst < *pVal ? -1 : 1;
142,573,799✔
653
  }
654
}
655

656
static void setSttInfoForCurrentTable(SSttBlockLoadInfo *pLoadInfo, uint64_t uid, SSttKeyRange *pRange,
279,687,896✔
657
                                      int64_t *numOfRows) {
658
  if (pRange == NULL || taosArrayGetSize(pLoadInfo->info.pUid) == 0) {
279,687,896✔
659
    return;
62,867,495✔
660
  }
661

662
  int32_t index = taosArraySearchIdx(pLoadInfo->info.pUid, &uid, uidComparFn, TD_EQ);
216,878,092✔
663
  if (index >= 0) {
216,857,265✔
664
    pRange->skey.ts = *(int64_t *)taosArrayGet(pLoadInfo->info.pFirstTs, index);
146,554,363✔
665
    pRange->ekey.ts = *(int64_t *)taosArrayGet(pLoadInfo->info.pLastTs, index);
146,563,821✔
666

667
    *numOfRows += *(int64_t *)taosArrayGet(pLoadInfo->info.pCount, index);
146,564,343✔
668

669
    if (pRange->skey.numOfPKs > 0) {
146,564,368✔
670
      memcpy(&pRange->skey.pks[0], taosArrayGet(pLoadInfo->info.pFirstKey, index), sizeof(SValue));
5,246,229✔
671
      memcpy(&pRange->ekey.pks[0], taosArrayGet(pLoadInfo->info.pLastKey, index), sizeof(SValue));
5,245,714✔
672
    }
673
  }
674
}
675

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

681
  pIter->uid = pConf->uid;
279,767,771✔
682
  pIter->cid = cid;
279,826,131✔
683
  pIter->backward = backward;
279,813,070✔
684
  pIter->verRange.minVer = pConf->verRange.minVer;
279,797,367✔
685
  pIter->verRange.maxVer = pConf->verRange.maxVer;
279,730,904✔
686
  pIter->timeWindow.skey = pConf->timewindow.skey;
279,782,097✔
687
  pIter->timeWindow.ekey = pConf->timewindow.ekey;
279,734,969✔
688

689
  pIter->pStartRowKey = pConf->pCurRowKey;
279,783,521✔
690
  pIter->pReader = pSttFileReader;
279,725,334✔
691
  pIter->pBlockLoadInfo = pBlockLoadInfo;
279,782,678✔
692

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

701
  if (!pBlockLoadInfo->sttBlockLoaded) {
279,667,384✔
702
      code = doLoadSttFilesBlk(pBlockLoadInfo, pIter, pConf->suid, pConf->loadTombFn, pConf->pReader, idStr, loadFromDisk);
197,240,353✔
703
  }
704

705
  setSttInfoForCurrentTable(pBlockLoadInfo, pConf->uid, pKeyRange, numOfRows);
279,667,656✔
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);
279,723,245✔
710
  pIter->iSttBlk = binarySearchForStartBlock(pBlockLoadInfo->aSttBlk->pData, size, pConf->uid, backward);
279,776,498✔
711
  if (pIter->iSttBlk != -1) {
279,688,598✔
712
    pIter->pSttBlk = taosArrayGet(pBlockLoadInfo->aSttBlk, pIter->iSttBlk);
146,665,677✔
713
    pIter->iRow = (pIter->backward) ? pIter->pSttBlk->nRow : -1;
146,682,957✔
714

715
    if ((!backward) && ((pConf->strictTimeRange && pIter->pSttBlk->minKey >= pIter->timeWindow.ekey) ||
146,649,381✔
716
                        (!pConf->strictTimeRange && pIter->pSttBlk->minKey > pIter->timeWindow.ekey))) {
139,903,782✔
717
      pIter->pSttBlk = NULL;
22,303✔
718
    }
719

720
    if (backward && ((pConf->strictTimeRange && pIter->pSttBlk->maxKey <= pIter->timeWindow.skey) ||
146,580,029✔
721
                     (!pConf->strictTimeRange && pIter->pSttBlk->maxKey < pIter->timeWindow.skey))) {
6,779,307✔
722
      pIter->pSttBlk = NULL;
145,197✔
723
      pIter->ignoreEarlierTs = true;
189,614✔
724
    }
725
  }
726

727
  return code;
279,566,489✔
728
}
729

730
void tLDataIterClose2(SLDataIter *pIter) {
197,322,206✔
731
  tsdbSttFileReaderClose(&pIter->pReader);
197,322,206✔
732
  pIter->pReader = NULL;
197,298,657✔
733
}
197,311,803✔
734

735
void tLDataIterNextBlock(SLDataIter *pIter, const char *idStr) {
152,080,038✔
736
  int32_t step = pIter->backward ? -1 : 1;
152,080,038✔
737
  int32_t oldIndex = pIter->iSttBlk;
152,097,191✔
738

739
  pIter->iSttBlk += step;
152,141,889✔
740

741
  int32_t index = -1;
152,087,449✔
742
  size_t  size = pIter->pBlockLoadInfo->aSttBlk->size;
152,087,449✔
743
  for (int32_t i = pIter->iSttBlk; i < size && i >= 0; i += step) {
152,628,602✔
744
    SSttBlk *p = taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, i);
15,695,152✔
745
    if ((!pIter->backward) && p->minUid > pIter->uid) {
15,695,073✔
746
      break;
6,704,958✔
747
    }
748

749
    if (pIter->backward && p->maxUid < pIter->uid) {
8,992,003✔
750
      break;
773,583✔
751
    }
752

753
    // check uid firstly
754
    if (p->minUid <= pIter->uid && p->maxUid >= pIter->uid) {
8,217,570✔
755
      if ((!pIter->backward) && p->minKey > pIter->timeWindow.ekey) {
8,216,825✔
756
        break;
82,406✔
757
      }
758

759
      if (pIter->backward && p->maxKey < pIter->timeWindow.skey) {
8,135,164✔
760
        break;
140✔
761
      }
762

763
      // check time range secondly
764
      if (p->minKey <= pIter->timeWindow.ekey && p->maxKey >= pIter->timeWindow.skey) {
8,135,024✔
765
        if ((!pIter->backward) && p->minVer > pIter->verRange.maxVer) {
7,586,667✔
766
          break;
×
767
        }
768

769
        if (pIter->backward && p->maxVer < pIter->verRange.minVer) {
7,586,667✔
770
          break;
×
771
        }
772

773
        if (p->minVer <= pIter->verRange.maxVer && p->maxVer >= pIter->verRange.minVer) {
7,586,667✔
774
          index = i;
7,586,667✔
775
          break;
7,586,667✔
776
        }
777
      }
778
    }
779
  }
780

781
  pIter->pSttBlk = NULL;
152,135,695✔
782
  if (index != -1) {
152,072,585✔
783
    SSttBlk *p = taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, index);
7,586,667✔
784

785
    pIter->iSttBlk = index;
7,586,667✔
786
    pIter->pSttBlk = (SSttBlk *)taosArrayGet(pIter->pBlockLoadInfo->aSttBlk, pIter->iSttBlk);
7,586,667✔
787
    tsdbDebug("try next stt-file block:%d from %d, trigger by uid:%" PRIu64 ", stt-fileVer:%" PRId64
7,586,667✔
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);
144,485,918✔
792
  }
793
}
152,072,585✔
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✔
803
    tsdbError("failed to load stt block, code:%s, %s", tstrerror(code), idStr);
×
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);
149,090,170✔
810
    if (i == -1) {
149,041,654✔
811
      tsdbDebug("failed to find the data in pBlockData, uid:%" PRIu64 " , %s", pIter->uid, idStr);
151,356✔
812
      pIter->iRow = -1;
151,356✔
813
      return code;
151,356✔
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;
27,053,498✔
822
        }
823
      } else {
824
        if (pData->aUid[i] < pIter->uid) {
490,730,737✔
825
          break;
2,328,923✔
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;
739,384✔
834
      } else {
835
        if (ts < pIter->timeWindow.skey) {
2,147,483,647✔
836
          continue;
2,008,011,011✔
837
        }
838

839
        if (ts == pIter->timeWindow.skey && pIter->pStartRowKey->numOfPKs > 0) {
2,147,483,647✔
840
          SRowKey key;
6,671,884✔
841
          tColRowGetKey(pData, i, &key);
6,671,884✔
842
          int32_t ret = pkCompEx(&key, pIter->pStartRowKey);
6,671,884✔
843
          if (ret < 0) {
6,671,884✔
844
            continue;
×
845
          }
846
        }
847
      }
848
    } else {
849
      if (ts < pIter->timeWindow.skey) {
505,445,931✔
850
        break;
821,951✔
851
      } else {
852
        if (ts > pIter->timeWindow.ekey) {
504,560,457✔
853
          continue;
52,380,984✔
854
        }
855

856
        if (ts == pIter->timeWindow.ekey && pIter->pStartRowKey->numOfPKs > 0) {
452,195,227✔
857
          SRowKey key;
×
858
          tColRowGetKey(pData, i, &key);
×
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✔
869
      continue;
×
870
    }
871

872
    // todo opt handle desc case
873
    if (ver > pIter->verRange.maxVer) {
2,147,483,647✔
874
      continue;
272✔
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;
133,264,266✔
897
  }
898

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

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

907
  while (1) {
7,586,460✔
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✔
913
      skipBlock = true;
×
914
      int16_t *aCols = pIter->pBlockLoadInfo->colIds;
×
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)) {
×
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);
158,277,565✔
937
      if (pIter->pSttBlk == NULL) {  // no more data
152,067,938✔
938
        goto _exit;
144,539,699✔
939
      }
940
    } else {
941
      break;
942
    }
943

944
    if (iBlockL != pIter->iSttBlk) {
7,586,667✔
945
      code = loadLastBlock(pIter, idStr, &pBlockData);
7,586,667✔
946
      if ((pBlockData == NULL) || (code != 0)) {
7,586,667✔
947
        lino = __LINE__;
×
948
        goto _exit;
×
949
      }
950

951
      // set start row index
952
      pIter->iRow = pIter->backward ? pBlockData->nRow - 1 : 0;
7,586,667✔
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✔
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,270,584,867✔
981
  } else if (ret > 0) {
2,147,483,647✔
982
    return 1;
1,862,156,329✔
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,237,168,190✔
989
    } else if (ver1 > ver2) {
1,862,733,393✔
990
      return 1;
1,862,744,166✔
991
    } else {
992
      return 0;
×
993
    }
994
  }
995
}
996

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

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

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

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

1016
int32_t tMergeTreeOpen2(SMergeTree *pMTree, SMergeTreeConf *pConf, SSttDataInfoForTable *pSttDataInfo) {
284,146,684✔
1017
  int32_t               code = TSDB_CODE_SUCCESS;
284,146,684✔
1018
  STFileSet *           pFset = (STFileSet *)pConf->pCurrentFileset;
284,146,684✔
1019
  bool                  loadStatisFromDisk = true;
284,173,422✔
1020
  int32_t               lino = 0;
284,173,422✔
1021
  int32_t               numOfLevels = pFset->lvlArr->size;
284,173,422✔
1022
  SSttStatisCacheValue* pValue = NULL;
284,159,547✔
1023
  LRUHandle*            pHandle = NULL;
284,153,400✔
1024
  SSttStatisCacheKey    key = {.suid = pConf->suid, .fid = pFset->fid, .vgId = TD_VID(pConf->pTsdb->pVnode)};
284,160,349✔
1025

1026
  (void)taosThreadOnce(&tsCacheInit, initTableRowsInfoCache);
284,166,458✔
1027

1028
  pMTree->pIter = NULL;
284,101,164✔
1029
  pMTree->backward = pConf->backward;
284,132,565✔
1030
  pMTree->idStr = pConf->idstr;
284,120,729✔
1031

1032
  if (!pMTree->backward) {  // asc
284,111,949✔
1033
    tRBTreeCreate(&pMTree->rbt, tLDataIterCmprFn);
273,013,043✔
1034
  } else {  // desc
1035
    tRBTreeCreate(&pMTree->rbt, tLDataIterDescCmprFn);
11,112,782✔
1036
  }
1037

1038
  pMTree->ignoreEarlierTs = false;
284,068,767✔
1039

1040
  // no data exists, go to end
1041
  if (numOfLevels == 0) {
284,037,371✔
1042
    goto _end;
26,736,870✔
1043
  }
1044

1045
  code = adjustSttDataIters(pConf->pSttFileBlockIterArray, pConf->pCurrentFileset);
257,300,501✔
1046
  if (code) {
257,352,234✔
1047
    goto _end;
×
1048
  }
1049

1050
  if (pConf->cacheStatis) {
257,352,234✔
1051
    int32_t ret = getStatisInfoFromCache(statisCacheInfo.pStatisFileCache, &key, &pValue, &pHandle, pConf->idstr);
1,728✔
1052
    if (ret == TSDB_CODE_SUCCESS) {  // use cached statis info
1,728✔
1053
      if (pValue->commitTs == pFset->lastCommit) {
1,536✔
1054
        loadStatisFromDisk = false;
1,536✔
1055
      } else {  // release the handle ref, and then remove it from lru cache
1056
        int64_t ts = pValue->commitTs;
×
1057
        clearStatisInfoCache(statisCacheInfo.pStatisFileCache, &key, &pHandle);
×
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) {
536,725,210✔
1067
    SSttLvl *pSttLevel = ((STFileSet *)pConf->pCurrentFileset)->lvlArr->data[j];
279,312,272✔
1068
    SArray  *pList = taosArrayGetP(pConf->pSttFileBlockIterArray, j);
279,361,001✔
1069

1070
    for (int32_t i = 0; i < TARRAY2_SIZE(pSttLevel->fobjArr); ++i) {  // open all last file
559,195,233✔
1071
      SLDataIter *pIter = taosArrayGetP(pList, i);
279,757,767✔
1072

1073
      SSttFileReader    *pSttFileReader = pIter->pReader;
279,797,098✔
1074
      SSttBlockLoadInfo *pLoadInfo = pIter->pBlockLoadInfo;
279,785,173✔
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) {
279,788,659✔
1079
        int32_t pgSize = pConf->pTsdb->pVnode->config.tsdbPageSize;
197,316,313✔
1080

1081
        SSttFileReaderConfig conf = {
394,678,876✔
1082
            .tsdb = pConf->pTsdb, .szPage = pgSize, .file[0] = *pSttLevel->fobjArr->data[i]->f};
197,322,743✔
1083

1084
        code = tsdbSttFileReaderOpen(pSttLevel->fobjArr->data[i]->fname, &conf, &pSttFileReader);
197,347,850✔
1085
        if (code != TSDB_CODE_SUCCESS) {
197,205,395✔
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) {
279,639,604✔
1092
        code = tCreateSttBlockLoadInfo(pConf->pSchema, pConf->pCols, pConf->numOfCols, &pLoadInfo);
197,194,169✔
1093
        if (code != TSDB_CODE_SUCCESS) {
197,313,767✔
1094
          goto _end;
×
1095
        }
1096
      }
1097

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

1105
      memset(pIter, 0, sizeof(SLDataIter));
279,759,202✔
1106

1107
      SSttKeyRange range = {.skey.numOfPKs = pConf->pCurRowKey->numOfPKs, .ekey.numOfPKs = pConf->pCurRowKey->numOfPKs};
279,759,202✔
1108
      int64_t      numOfRows = 0;
279,802,578✔
1109
      int64_t      cid = pSttLevel->fobjArr->data[i]->f->cid;
279,788,121✔
1110

1111
      code = tLDataIterOpen2(pIter, pSttFileReader, cid, pMTree->backward, pConf, pLoadInfo, &range, &numOfRows,
279,822,674✔
1112
                             pMTree->idStr, loadStatisFromDisk);
1113
      if (code != TSDB_CODE_SUCCESS) {
279,660,694✔
1114
        goto _end;
×
1115
      }
1116

1117
      bool hasVal = NULL;
279,660,694✔
1118
      code = tLDataIterNextRow(pIter, pMTree->idStr, &hasVal);
279,725,278✔
1119
      if (code) {
279,581,994✔
1120
        goto _end;
×
1121
      }
1122

1123
      if (hasVal) {
279,581,994✔
1124
        tMergeTreeAddIter(pMTree, pIter);
144,683,716✔
1125

1126
        // let's record the time window for current table of uid in the stt files
1127
        if (pSttDataInfo != NULL && numOfRows > 0) {
144,694,254✔
1128
          void *px = taosArrayPush(pSttDataInfo->pKeyRangeList, &range);
144,728,395✔
1129
          QUERY_CHECK_NULL(px, code, lino, _end, terrno);
144,792,927✔
1130

1131
          pSttDataInfo->numOfRows += numOfRows;
144,792,927✔
1132
        }
1133
      } else {
1134
        if (!pMTree->ignoreEarlierTs) {
134,898,278✔
1135
          pMTree->ignoreEarlierTs = pIter->ignoreEarlierTs;
134,799,762✔
1136
        }
1137
      }
1138
    }
1139
  }
1140

1141
  if (pConf->cacheStatis && loadStatisFromDisk) {
257,412,938✔
1142
    SSttStatisCacheKey    k = {0};
192✔
1143
    SSttStatisCacheValue *pVal = NULL;
192✔
1144

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

1151
  if (pHandle != NULL && pConf->cacheStatis) {
257,265,967✔
1152
    releaseCacheHandle(statisCacheInfo.pStatisFileCache, &pHandle, true);
1,536✔
1153
  }
1154

1155
  return code;
257,273,792✔
1156

1157
_end:
26,730,713✔
1158
  if (pHandle != NULL && pConf->cacheStatis) {
26,738,074✔
1159
    releaseCacheHandle(statisCacheInfo.pStatisFileCache, &pHandle, true);
×
1160
  }
1161

1162
  tMergeTreeClose(pMTree);
26,738,074✔
1163
  return code;
26,737,902✔
1164
}
1165

1166
void tMergeTreeAddIter(SMergeTree *pMTree, SLDataIter *pIter) {
144,706,424✔
1167
  SRBTreeNode *node = tRBTreePut(&pMTree->rbt, (SRBTreeNode *)pIter);
144,706,424✔
1168
}
144,695,274✔
1169

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

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✔
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✔
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✔
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) {
137,052,446✔
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;
137,052,446✔
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,261,074,308✔
1250
      if (c > 0) {
1,261,064,291✔
1251
        (void)tRBTreePut(&pMTree->rbt, (SRBTreeNode *)pMTree->pIter);
1,218,259,804✔
1252
        pMTree->pIter = NULL;
1,218,267,931✔
1253
      } else if (!c) {
42,804,487✔
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,643,426,470✔
1263
    if (pMTree->pIter) {
1,643,352,588✔
1264
      tRBTreeDrop(&pMTree->rbt, (SRBTreeNode *)pMTree->pIter);
1,361,229,212✔
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) {
547,225,244✔
1273
  pMTree->pIter = NULL;
547,225,244✔
1274
  pMTree->pPinnedBlockIter = NULL;
547,383,470✔
1275
}
547,379,092✔
1276

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

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

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

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

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

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

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

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

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

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

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

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

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

1331
  // todo handle memory failure
1332

1333
  return TSDB_CODE_SUCCESS;
192✔
1334
}
1335

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

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

1348
  void *p = taosLRUCacheValue(pCache, pItemHandle);
1,536✔
1349

1350
  *pValue = p;
1,536✔
1351
  *pHandle = pItemHandle;
1,536✔
1352

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

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

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

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

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

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

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

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

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

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

1397
    taosArrayDestroy(pInfos);
192✔
1398
  }
1399

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

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

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

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

1425
void clearStatisInfoCache(SLRUCache *pStatisCache, SSttStatisCacheKey *pKey, LRUHandle** pHandle) {
×
1426
  (void)taosThreadMutexLock(&statisCacheInfo.lock);
×
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){
×
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) {
1,104✔
1443
  int32_t code = 0;
1,104✔
1444

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

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

1476
  return TSDB_CODE_SUCCESS;
1,104✔
1477
}
1478

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

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

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

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

1499
  return sttRowInfoDeepCopy(pRowInfo, p, numOfPKs);
1,104✔
1500
}
1501

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

1514
  return size;
192✔
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