taosdata/TDengine | Build 3565 | source/dnode/vnode/src/tsdb/tsdbUtil2.c | Coveralls

UNCOV

void tTombBlockInit(STombBlock *tombBlock) {

×

UNCOV

20

  tombBlock->numOfRecords = 0;

×

UNCOV

21

  for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {

×

UNCOV

22

    tBufferInit(&tombBlock->buffers[i]);

×

UNCOV

24

  return;

×

UNCOV

27

void tTombBlockDestroy(STombBlock *tombBlock) {

×

UNCOV

28

  tombBlock->numOfRecords = 0;

×

UNCOV

29

  for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {

×

UNCOV

30

    tBufferDestroy(&tombBlock->buffers[i]);

×

UNCOV

32

×

UNCOV

34

void tTombBlockClear(STombBlock *tombBlock) {

×

UNCOV

35

  tombBlock->numOfRecords = 0;

×

UNCOV

36

  for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {

×

UNCOV

37

    tBufferClear(&tombBlock->buffers[i]);

×

UNCOV

39

×

UNCOV

41

int32_t tTombBlockPut(STombBlock *tombBlock, const STombRecord *record) {

×

UNCOV

42

  for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {

×

UNCOV

43

    TAOS_CHECK_RETURN(tBufferPutI64(&tombBlock->buffers[i], record->data[i]));

×

UNCOV

45

  tombBlock->numOfRecords++;

×

UNCOV

46

  return 0;

×

UNCOV

49

int32_t tTombBlockGet(STombBlock *tombBlock, int32_t idx, STombRecord *record) {

×

UNCOV

50

  if (idx < 0 || idx >= tombBlock->numOfRecords) {

×

51

    return TSDB_CODE_OUT_OF_RANGE;

×

UNCOV

54

  for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {

×

UNCOV

55

    SBufferReader br = BUFFER_READER_INITIALIZER(sizeof(int64_t) * idx, &tombBlock->buffers[i]);

×

UNCOV

56

    TAOS_CHECK_RETURN(tBufferGetI64(&br, &record->data[i]));

×

UNCOV

58

  return 0;

×

UNCOV

61

int32_t tTombRecordCompare(const STombRecord *r1, const STombRecord *r2) {

×

UNCOV

62

  if (r1->suid < r2->suid) return -1;

×

UNCOV

63

  if (r1->suid > r2->suid) return 1;

×

UNCOV

64

  if (r1->uid < r2->uid) return -1;

×

UNCOV

65

  if (r1->uid > r2->uid) return 1;

×

UNCOV

66

  if (r1->version < r2->version) return -1;

×

UNCOV

67

  if (r1->version > r2->version) return 1;

×

68

  return 0;

×

UNCOV

72

int32_t tStatisBlockInit(STbStatisBlock *statisBlock) {

×

UNCOV

73

  int32_t code = 0;

×

UNCOV

75

  statisBlock->numOfPKs = 0;

×

UNCOV

76

  statisBlock->numOfRecords = 0;

×

UNCOV

77

  for (int32_t i = 0; i < ARRAY_SIZE(statisBlock->buffers); ++i) {

×

UNCOV

78

    tBufferInit(&statisBlock->buffers[i]);

×

UNCOV

80

  for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {

×

UNCOV

81

    TAOS_CHECK_GOTO(tValueColumnInit(&statisBlock->firstKeyPKs[i]), NULL, _exit);

×

UNCOV

82

    TAOS_CHECK_GOTO(tValueColumnInit(&statisBlock->lastKeyPKs[i]), NULL, _exit);

×

UNCOV

85

_exit:

×

UNCOV

86

  if (code) {

×

87

    tStatisBlockDestroy(statisBlock);

×

UNCOV

89

  return code;

×

UNCOV

92

void tStatisBlockDestroy(STbStatisBlock *statisBlock) {

×

UNCOV

93

  statisBlock->numOfPKs = 0;

×

UNCOV

94

  statisBlock->numOfRecords = 0;

×

UNCOV

95

  for (int32_t i = 0; i < ARRAY_SIZE(statisBlock->buffers); ++i) {

×

UNCOV

96

    tBufferDestroy(&statisBlock->buffers[i]);

×

UNCOV

98

  for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {

×

UNCOV

99

    tValueColumnDestroy(&statisBlock->firstKeyPKs[i]);

×

UNCOV

100

    tValueColumnDestroy(&statisBlock->lastKeyPKs[i]);

×

UNCOV

102

×

UNCOV

104

void tStatisBlockClear(STbStatisBlock *statisBlock) {

×

UNCOV

105

  statisBlock->numOfPKs = 0;

×

UNCOV

106

  statisBlock->numOfRecords = 0;

×

UNCOV

107

  for (int32_t i = 0; i < ARRAY_SIZE(statisBlock->buffers); ++i) {

×

UNCOV

108

    tBufferClear(&statisBlock->buffers[i]);

×

UNCOV

110

  for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {

×

UNCOV

111

    tValueColumnClear(&statisBlock->firstKeyPKs[i]);

×

UNCOV

112

    tValueColumnClear(&statisBlock->lastKeyPKs[i]);

×

UNCOV

114

  return;

×

UNCOV

117

static int32_t tStatisBlockAppend(STbStatisBlock *block, SRowInfo *row) {

×

UNCOV

120

  tsdbRowGetKey(&row->row, &key);

×

UNCOV

121

  if (block->numOfRecords == 0) {

×

UNCOV

122

    block->numOfPKs = key.key.numOfPKs;

×

UNCOV

123

  } else if (block->numOfPKs != key.key.numOfPKs) {

×

UNCOV

124

    return TSDB_CODE_INVALID_PARA;

×

UNCOV

126

    for (int i = 0; i < block->numOfPKs; i++) {

×

UNCOV

127

      if (key.key.pks[i].type != block->firstKeyPKs[i].type) {

×

128

        return TSDB_CODE_INVALID_PARA;

×

UNCOV

133

  TAOS_CHECK_RETURN(tBufferPutI64(&block->suids, row->suid));

×

UNCOV

134

  TAOS_CHECK_RETURN(tBufferPutI64(&block->uids, row->uid));

×

UNCOV

135

  TAOS_CHECK_RETURN(tBufferPutI64(&block->firstKeyTimestamps, key.key.ts));

×

UNCOV

136

  TAOS_CHECK_RETURN(tBufferPutI64(&block->lastKeyTimestamps, key.key.ts));

×

UNCOV

137

  TAOS_CHECK_RETURN(tBufferPutI64(&block->counts, 1));

×

UNCOV

138

  for (int32_t i = 0; i < block->numOfPKs; ++i) {

×

UNCOV

139

    TAOS_CHECK_RETURN(tValueColumnAppend(block->firstKeyPKs + i, key.key.pks + i));

×

UNCOV

140

    TAOS_CHECK_RETURN(tValueColumnAppend(block->lastKeyPKs + i, key.key.pks + i));

×

UNCOV

143

  block->numOfRecords++;

×

UNCOV

144

  return 0;

×

UNCOV

147

static int32_t tStatisBlockUpdate(STbStatisBlock *block, SRowInfo *row) {

×

UNCOV

152

  TAOS_CHECK_RETURN(tStatisBlockGet(block, block->numOfRecords - 1, &record));

×

UNCOV

153

  tsdbRowGetKey(&row->row, &key);

×

UNCOV

155

  c = tRowKeyCompare(&record.lastKey, &key.key);

×

UNCOV

156

  if (c == 0) {

×

UNCOV

157

    return 0;

×

UNCOV

158

  } else if (c < 0) {

×

UNCOV

160

    TAOS_CHECK_RETURN(tBufferPutAt(&block->lastKeyTimestamps, (block->numOfRecords - 1) * sizeof(record.lastKey.ts),

×

UNCOV

164

    for (int i = 0; i < block->numOfPKs; i++) {

×

UNCOV

165

      TAOS_CHECK_RETURN(tValueColumnUpdate(&block->lastKeyPKs[i], block->numOfRecords - 1, &key.key.pks[i]));

×

UNCOV

169

    record.count++;

×

UNCOV

170

    TAOS_CHECK_RETURN(tBufferPutAt(&block->counts, (block->numOfRecords - 1) * sizeof(record.count), &record.count,

×

173

    return TSDB_CODE_INVALID_PARA;

×

UNCOV

176

  return 0;

×

UNCOV

179

int32_t tStatisBlockPut(STbStatisBlock *block, SRowInfo *row, int32_t maxRecords) {

×

UNCOV

180

  if (block->numOfRecords > 0) {

×

UNCOV

182

    SBufferReader br = BUFFER_READER_INITIALIZER(sizeof(int64_t) * (block->numOfRecords - 1), &block->uids);

×

UNCOV

183

    TAOS_CHECK_RETURN(tBufferGetI64(&br, &lastUid));

×

UNCOV

185

    if (lastUid == row->uid) {

×

UNCOV

186

      return tStatisBlockUpdate(block, row);

×

UNCOV

187

    } else if (block->numOfRecords >= maxRecords) {

×

UNCOV

188

      return TSDB_CODE_INVALID_PARA;

×

UNCOV

191

  return tStatisBlockAppend(block, row);

×

UNCOV

194

int32_t tStatisBlockGet(STbStatisBlock *statisBlock, int32_t idx, STbStatisRecord *record) {

×

UNCOV

197

  if (idx < 0 || idx >= statisBlock->numOfRecords) {

×

198

    return TSDB_CODE_OUT_OF_RANGE;

×

UNCOV

201

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->suid), &statisBlock->suids);

×

UNCOV

202

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->suid));

×

UNCOV

204

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->uid), &statisBlock->uids);

×

UNCOV

205

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->uid));

×

UNCOV

207

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->firstKey.ts), &statisBlock->firstKeyTimestamps);

×

UNCOV

208

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->firstKey.ts));

×

UNCOV

210

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->lastKey.ts), &statisBlock->lastKeyTimestamps);

×

UNCOV

211

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->lastKey.ts));

×

UNCOV

213

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->count), &statisBlock->counts);

×

UNCOV

214

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->count));

×

UNCOV

217

  for (record->firstKey.numOfPKs = 0; record->firstKey.numOfPKs < statisBlock->numOfPKs; record->firstKey.numOfPKs++) {

×

UNCOV

218

    TAOS_CHECK_RETURN(tValueColumnGet(&statisBlock->firstKeyPKs[record->firstKey.numOfPKs], idx,

×

UNCOV

222

  for (record->lastKey.numOfPKs = 0; record->lastKey.numOfPKs < statisBlock->numOfPKs; record->lastKey.numOfPKs++) {

×

UNCOV

223

    TAOS_CHECK_RETURN(tValueColumnGet(&statisBlock->lastKeyPKs[record->lastKey.numOfPKs], idx,

×

UNCOV

227

  return 0;

×

UNCOV

231

int32_t tBrinBlockInit(SBrinBlock *brinBlock) {

×

UNCOV

234

  brinBlock->numOfPKs = 0;

×

UNCOV

235

  brinBlock->numOfRecords = 0;

×

UNCOV

236

  for (int32_t i = 0; i < ARRAY_SIZE(brinBlock->buffers); ++i) {

×

UNCOV

237

    tBufferInit(&brinBlock->buffers[i]);

×

UNCOV

239

  for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {

×

UNCOV

240

    TAOS_CHECK_GOTO(tValueColumnInit(&brinBlock->firstKeyPKs[i]), NULL, _exit);

×

UNCOV

241

    TAOS_CHECK_GOTO(tValueColumnInit(&brinBlock->lastKeyPKs[i]), NULL, _exit);

×

UNCOV

244

_exit:

×

UNCOV

245

  if (code) {

×

246

    tBrinBlockDestroy(brinBlock);

×

UNCOV

248

  return code;

×

UNCOV

251

void tBrinBlockDestroy(SBrinBlock *brinBlock) {

×

UNCOV

252

  brinBlock->numOfPKs = 0;

×

UNCOV

253

  brinBlock->numOfRecords = 0;

×

UNCOV

254

  for (int32_t i = 0; i < ARRAY_SIZE(brinBlock->buffers); ++i) {

×

UNCOV

255

    tBufferDestroy(&brinBlock->buffers[i]);

×

UNCOV

257

  for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {

×

UNCOV

258

    tValueColumnDestroy(&brinBlock->firstKeyPKs[i]);

×

UNCOV

259

    tValueColumnDestroy(&brinBlock->lastKeyPKs[i]);

×

UNCOV

261

×

UNCOV

263

void tBrinBlockClear(SBrinBlock *brinBlock) {

×

UNCOV

264

  brinBlock->numOfPKs = 0;

×

UNCOV

265

  brinBlock->numOfRecords = 0;

×

UNCOV

266

  for (int32_t i = 0; i < ARRAY_SIZE(brinBlock->buffers); ++i) {

×

UNCOV

267

    tBufferClear(&brinBlock->buffers[i]);

×

UNCOV

269

  for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {

×

UNCOV

270

    tValueColumnClear(&brinBlock->firstKeyPKs[i]);

×

UNCOV

271

    tValueColumnClear(&brinBlock->lastKeyPKs[i]);

×

UNCOV

273

×

UNCOV

275

int32_t tBrinBlockPut(SBrinBlock *brinBlock, const SBrinRecord *record) {

×

UNCOV

276

  if (record->firstKey.key.numOfPKs != record->lastKey.key.numOfPKs) {

×

277

    return TSDB_CODE_INVALID_PARA;

×

UNCOV

280

  if (brinBlock->numOfRecords == 0) {  // the first row

×

UNCOV

281

    brinBlock->numOfPKs = record->firstKey.key.numOfPKs;

×

UNCOV

282

  } else if (brinBlock->numOfPKs != record->firstKey.key.numOfPKs) {

×

UNCOV

285

    return TSDB_CODE_INVALID_PARA;

×

UNCOV

287

    for (int i = 0; i < brinBlock->numOfPKs; i++) {

×

UNCOV

288

      if (record->firstKey.key.pks[i].type != brinBlock->firstKeyPKs[i].type) {

×

289

        return TSDB_CODE_INVALID_PARA;

×

UNCOV

294

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->suids, record->suid));

×

UNCOV

295

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->uids, record->uid));

×

UNCOV

296

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->firstKeyTimestamps, record->firstKey.key.ts));

×

UNCOV

297

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->firstKeyVersions, record->firstKey.version));

×

UNCOV

298

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->lastKeyTimestamps, record->lastKey.key.ts));

×

UNCOV

299

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->lastKeyVersions, record->lastKey.version));

×

UNCOV

300

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->minVers, record->minVer));

×

UNCOV

301

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->maxVers, record->maxVer));

×

UNCOV

302

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->blockOffsets, record->blockOffset));

×

UNCOV

303

  TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->smaOffsets, record->smaOffset));

×

UNCOV

304

  TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->blockSizes, record->blockSize));

×

UNCOV

305

  TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->blockKeySizes, record->blockKeySize));

×

UNCOV

306

  TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->smaSizes, record->smaSize));

×

UNCOV

307

  TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->numRows, record->numRow));

×

UNCOV

308

  TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->counts, record->count));

×

UNCOV

310

  if (brinBlock->numOfPKs > 0) {

×

UNCOV

311

    for (int32_t i = 0; i < brinBlock->numOfPKs; ++i) {

×

UNCOV

312

      TAOS_CHECK_RETURN(tValueColumnAppend(&brinBlock->firstKeyPKs[i], &record->firstKey.key.pks[i]));

×

UNCOV

315

    for (int32_t i = 0; i < brinBlock->numOfPKs; ++i) {

×

UNCOV

316

      TAOS_CHECK_RETURN(tValueColumnAppend(&brinBlock->lastKeyPKs[i], &record->lastKey.key.pks[i]));

×

UNCOV

320

  brinBlock->numOfRecords++;

×

UNCOV

322

  return 0;

×

UNCOV

325

int32_t tBrinBlockGet(SBrinBlock *brinBlock, int32_t idx, SBrinRecord *record) {

×

UNCOV

328

  if (idx < 0 || idx >= brinBlock->numOfRecords) {

×

329

    return TSDB_CODE_OUT_OF_RANGE;

×

UNCOV

332

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->suids);

×

UNCOV

333

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->suid));

×

UNCOV

335

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->uids);

×

UNCOV

336

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->uid));

×

UNCOV

338

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->firstKeyTimestamps);

×

UNCOV

339

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->firstKey.key.ts));

×

UNCOV

341

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->firstKeyVersions);

×

UNCOV

342

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->firstKey.version));

×

UNCOV

344

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->lastKeyTimestamps);

×

UNCOV

345

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->lastKey.key.ts));

×

UNCOV

347

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->lastKeyVersions);

×

UNCOV

348

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->lastKey.version));

×

UNCOV

350

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->minVers);

×

UNCOV

351

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->minVer));

×

UNCOV

353

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->maxVers);

×

UNCOV

354

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->maxVer));

×

UNCOV

356

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->blockOffsets);

×

UNCOV

357

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->blockOffset));

×

UNCOV

359

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->smaOffsets);

×

UNCOV

360

  TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->smaOffset));

×

UNCOV

362

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->blockSizes);

×

UNCOV

363

  TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->blockSize));

×

UNCOV

365

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->blockKeySizes);

×

UNCOV

366

  TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->blockKeySize));

×

UNCOV

368

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->smaSizes);

×

UNCOV

369

  TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->smaSize));

×

UNCOV

371

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->numRows);

×

UNCOV

372

  TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->numRow));

×

UNCOV

374

  reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->counts);

×

UNCOV

375

  TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->count));

×

UNCOV

378

  for (record->firstKey.key.numOfPKs = 0; record->firstKey.key.numOfPKs < brinBlock->numOfPKs;

×

UNCOV

379

       record->firstKey.key.numOfPKs++) {

×

UNCOV

380

    TAOS_CHECK_RETURN(tValueColumnGet(&brinBlock->firstKeyPKs[record->firstKey.key.numOfPKs], idx,

×

UNCOV

384

  for (record->lastKey.key.numOfPKs = 0; record->lastKey.key.numOfPKs < brinBlock->numOfPKs;

×

UNCOV

385

       record->lastKey.key.numOfPKs++) {

×

UNCOV

386

    TAOS_CHECK_RETURN(tValueColumnGet(&brinBlock->lastKeyPKs[record->lastKey.key.numOfPKs], idx,

×

UNCOV

390

  return 0;

×

UNCOV

394

int32_t tsdbUpdateSkmTb(STsdb *pTsdb, const TABLEID *tbid, SSkmInfo *pSkmTb) {

×

UNCOV

395

  if (tbid->suid) {

×

UNCOV

396

    if (pSkmTb->suid == tbid->suid) {

×

UNCOV

397

      pSkmTb->uid = tbid->uid;

×

UNCOV

398

      return 0;

×

UNCOV

400

  } else if (pSkmTb->uid == tbid->uid) {

×

UNCOV

401

    return 0;

×

UNCOV

404

  pSkmTb->suid = tbid->suid;

×

UNCOV

405

  pSkmTb->uid = tbid->uid;

×

UNCOV

406

  tDestroyTSchema(pSkmTb->pTSchema);

×

UNCOV

407

  return metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, tbid->suid, tbid->uid, -1, &pSkmTb->pTSchema);

×

UNCOV

410

int32_t tsdbUpdateSkmRow(STsdb *pTsdb, const TABLEID *tbid, int32_t sver, SSkmInfo *pSkmRow) {

×

UNCOV

411

  if (pSkmRow->pTSchema && pSkmRow->suid == tbid->suid) {

×

UNCOV

412

    if (pSkmRow->suid) {

×

UNCOV

413

      if (sver == pSkmRow->pTSchema->version) return 0;

×

UNCOV

414

    } else if (pSkmRow->uid == tbid->uid && pSkmRow->pTSchema->version == sver) {

×

UNCOV

415

      return 0;

×

419

  pSkmRow->suid = tbid->suid;

×

420

  pSkmRow->uid = tbid->uid;

×

421

  tDestroyTSchema(pSkmRow->pTSchema);

×

422

  return metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, tbid->suid, tbid->uid, sver, &pSkmRow->pTSchema);

×

424

int32_t tsdbUpdateColCmprObj(STsdb *pTsdb, const TABLEID *tbid, SHashObj **ppColCmpr) { return 0; }

×

taosdata / TDengine / #3565

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

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 "tsdbUtil2.h"
17
18	// SDelBlock ----------
UNCOV 19	void tTombBlockInit(STombBlock *tombBlock) {	×
UNCOV 20	tombBlock->numOfRecords = 0;	×
UNCOV 21	for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {	×
UNCOV 22	tBufferInit(&tombBlock->buffers[i]);	×
23	}
UNCOV 24	return;	×
25	}
26
UNCOV 27	void tTombBlockDestroy(STombBlock *tombBlock) {	×
UNCOV 28	tombBlock->numOfRecords = 0;	×
UNCOV 29	for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {	×
UNCOV 30	tBufferDestroy(&tombBlock->buffers[i]);	×
31	}
UNCOV 32	}	×
33
UNCOV 34	void tTombBlockClear(STombBlock *tombBlock) {	×
UNCOV 35	tombBlock->numOfRecords = 0;	×
UNCOV 36	for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {	×
UNCOV 37	tBufferClear(&tombBlock->buffers[i]);	×
38	}
UNCOV 39	}	×
40
UNCOV 41	int32_t tTombBlockPut(STombBlock tombBlock, const STombRecord record) {	×
UNCOV 42	for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {	×
UNCOV 43	TAOS_CHECK_RETURN(tBufferPutI64(&tombBlock->buffers[i], record->data[i]));	×
44	}
UNCOV 45	tombBlock->numOfRecords++;	×
UNCOV 46	return 0;	×
47	}
48
UNCOV 49	int32_t tTombBlockGet(STombBlock tombBlock, int32_t idx, STombRecord record) {	×
UNCOV 50	if (idx < 0 \|\| idx >= tombBlock->numOfRecords) {	×
51	return TSDB_CODE_OUT_OF_RANGE;	×
52	}
53
UNCOV 54	for (int32_t i = 0; i < TOMB_RECORD_ELEM_NUM; ++i) {	×
UNCOV 55	SBufferReader br = BUFFER_READER_INITIALIZER(sizeof(int64_t) * idx, &tombBlock->buffers[i]);	×
UNCOV 56	TAOS_CHECK_RETURN(tBufferGetI64(&br, &record->data[i]));	×
57	}
UNCOV 58	return 0;	×
59	}
60
UNCOV 61	int32_t tTombRecordCompare(const STombRecord r1, const STombRecord r2) {	×
UNCOV 62	if (r1->suid < r2->suid) return -1;	×
UNCOV 63	if (r1->suid > r2->suid) return 1;	×
UNCOV 64	if (r1->uid < r2->uid) return -1;	×
UNCOV 65	if (r1->uid > r2->uid) return 1;	×
UNCOV 66	if (r1->version < r2->version) return -1;	×
UNCOV 67	if (r1->version > r2->version) return 1;	×
68	return 0;	×
69	}
70
71	// STbStatisBlock ----------
UNCOV 72	int32_t tStatisBlockInit(STbStatisBlock *statisBlock) {	×
UNCOV 73	int32_t code = 0;	×
74
UNCOV 75	statisBlock->numOfPKs = 0;	×
UNCOV 76	statisBlock->numOfRecords = 0;	×
UNCOV 77	for (int32_t i = 0; i < ARRAY_SIZE(statisBlock->buffers); ++i) {	×
UNCOV 78	tBufferInit(&statisBlock->buffers[i]);	×
79	}
UNCOV 80	for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {	×
UNCOV 81	TAOS_CHECK_GOTO(tValueColumnInit(&statisBlock->firstKeyPKs[i]), NULL, _exit);	×
UNCOV 82	TAOS_CHECK_GOTO(tValueColumnInit(&statisBlock->lastKeyPKs[i]), NULL, _exit);	×
83	}
84
UNCOV 85	_exit:	×
UNCOV 86	if (code) {	×
87	tStatisBlockDestroy(statisBlock);	×
88	}
UNCOV 89	return code;	×
90	}
91
UNCOV 92	void tStatisBlockDestroy(STbStatisBlock *statisBlock) {	×
UNCOV 93	statisBlock->numOfPKs = 0;	×
UNCOV 94	statisBlock->numOfRecords = 0;	×
UNCOV 95	for (int32_t i = 0; i < ARRAY_SIZE(statisBlock->buffers); ++i) {	×
UNCOV 96	tBufferDestroy(&statisBlock->buffers[i]);	×
97	}
UNCOV 98	for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {	×
UNCOV 99	tValueColumnDestroy(&statisBlock->firstKeyPKs[i]);	×
UNCOV 100	tValueColumnDestroy(&statisBlock->lastKeyPKs[i]);	×
101	}
UNCOV 102	}	×
103
UNCOV 104	void tStatisBlockClear(STbStatisBlock *statisBlock) {	×
UNCOV 105	statisBlock->numOfPKs = 0;	×
UNCOV 106	statisBlock->numOfRecords = 0;	×
UNCOV 107	for (int32_t i = 0; i < ARRAY_SIZE(statisBlock->buffers); ++i) {	×
UNCOV 108	tBufferClear(&statisBlock->buffers[i]);	×
109	}
UNCOV 110	for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {	×
UNCOV 111	tValueColumnClear(&statisBlock->firstKeyPKs[i]);	×
UNCOV 112	tValueColumnClear(&statisBlock->lastKeyPKs[i]);	×
113	}
UNCOV 114	return;	×
115	}
116
UNCOV 117	static int32_t tStatisBlockAppend(STbStatisBlock block, SRowInfo row) {	×
118	STsdbRowKey key;
119
UNCOV 120	tsdbRowGetKey(&row->row, &key);	×
UNCOV 121	if (block->numOfRecords == 0) {	×
UNCOV 122	block->numOfPKs = key.key.numOfPKs;	×
UNCOV 123	} else if (block->numOfPKs != key.key.numOfPKs) {	×
UNCOV 124	return TSDB_CODE_INVALID_PARA;	×
125	} else {
UNCOV 126	for (int i = 0; i < block->numOfPKs; i++) {	×
UNCOV 127	if (key.key.pks[i].type != block->firstKeyPKs[i].type) {	×
128	return TSDB_CODE_INVALID_PARA;	×
129	}
130	}
131	}
132
UNCOV 133	TAOS_CHECK_RETURN(tBufferPutI64(&block->suids, row->suid));	×
UNCOV 134	TAOS_CHECK_RETURN(tBufferPutI64(&block->uids, row->uid));	×
UNCOV 135	TAOS_CHECK_RETURN(tBufferPutI64(&block->firstKeyTimestamps, key.key.ts));	×
UNCOV 136	TAOS_CHECK_RETURN(tBufferPutI64(&block->lastKeyTimestamps, key.key.ts));	×
UNCOV 137	TAOS_CHECK_RETURN(tBufferPutI64(&block->counts, 1));	×
UNCOV 138	for (int32_t i = 0; i < block->numOfPKs; ++i) {	×
UNCOV 139	TAOS_CHECK_RETURN(tValueColumnAppend(block->firstKeyPKs + i, key.key.pks + i));	×
UNCOV 140	TAOS_CHECK_RETURN(tValueColumnAppend(block->lastKeyPKs + i, key.key.pks + i));	×
141	}
142
UNCOV 143	block->numOfRecords++;	×
UNCOV 144	return 0;	×
145	}
146
UNCOV 147	static int32_t tStatisBlockUpdate(STbStatisBlock block, SRowInfo row) {	×
148	STbStatisRecord record;
149	STsdbRowKey key;
150	int32_t c;
151
UNCOV 152	TAOS_CHECK_RETURN(tStatisBlockGet(block, block->numOfRecords - 1, &record));	×
UNCOV 153	tsdbRowGetKey(&row->row, &key);	×
154
UNCOV 155	c = tRowKeyCompare(&record.lastKey, &key.key);	×
UNCOV 156	if (c == 0) {	×
UNCOV 157	return 0;	×
UNCOV 158	} else if (c < 0) {	×
159	// last ts
UNCOV 160	TAOS_CHECK_RETURN(tBufferPutAt(&block->lastKeyTimestamps, (block->numOfRecords - 1) * sizeof(record.lastKey.ts),	×
161	&key.key.ts, sizeof(key.key.ts)));
162
163	// last primary keys
UNCOV 164	for (int i = 0; i < block->numOfPKs; i++) {	×
UNCOV 165	TAOS_CHECK_RETURN(tValueColumnUpdate(&block->lastKeyPKs[i], block->numOfRecords - 1, &key.key.pks[i]));	×
166	}
167
168	// count
UNCOV 169	record.count++;	×
UNCOV 170	TAOS_CHECK_RETURN(tBufferPutAt(&block->counts, (block->numOfRecords - 1) * sizeof(record.count), &record.count,	×
171	sizeof(record.count)));
172	} else {
173	return TSDB_CODE_INVALID_PARA;	×
174	}
175
UNCOV 176	return 0;	×
177	}
178
UNCOV 179	int32_t tStatisBlockPut(STbStatisBlock block, SRowInfo row, int32_t maxRecords) {	×
UNCOV 180	if (block->numOfRecords > 0) {	×
181	int64_t lastUid;
UNCOV 182	SBufferReader br = BUFFER_READER_INITIALIZER(sizeof(int64_t) * (block->numOfRecords - 1), &block->uids);	×
UNCOV 183	TAOS_CHECK_RETURN(tBufferGetI64(&br, &lastUid));	×
184
UNCOV 185	if (lastUid == row->uid) {	×
UNCOV 186	return tStatisBlockUpdate(block, row);	×
UNCOV 187	} else if (block->numOfRecords >= maxRecords) {	×
UNCOV 188	return TSDB_CODE_INVALID_PARA;	×
189	}
190	}
UNCOV 191	return tStatisBlockAppend(block, row);	×
192	}
193
UNCOV 194	int32_t tStatisBlockGet(STbStatisBlock statisBlock, int32_t idx, STbStatisRecord record) {	×
195	SBufferReader reader;
196
UNCOV 197	if (idx < 0 \|\| idx >= statisBlock->numOfRecords) {	×
198	return TSDB_CODE_OUT_OF_RANGE;	×
199	}
200
UNCOV 201	reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->suid), &statisBlock->suids);	×
UNCOV 202	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->suid));	×
203
UNCOV 204	reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->uid), &statisBlock->uids);	×
UNCOV 205	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->uid));	×
206
UNCOV 207	reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->firstKey.ts), &statisBlock->firstKeyTimestamps);	×
UNCOV 208	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->firstKey.ts));	×
209
UNCOV 210	reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->lastKey.ts), &statisBlock->lastKeyTimestamps);	×
UNCOV 211	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->lastKey.ts));	×
212
UNCOV 213	reader = BUFFER_READER_INITIALIZER(idx * sizeof(record->count), &statisBlock->counts);	×
UNCOV 214	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->count));	×
215
216	// primary keys
UNCOV 217	for (record->firstKey.numOfPKs = 0; record->firstKey.numOfPKs < statisBlock->numOfPKs; record->firstKey.numOfPKs++) {	×
UNCOV 218	TAOS_CHECK_RETURN(tValueColumnGet(&statisBlock->firstKeyPKs[record->firstKey.numOfPKs], idx,	×
219	&record->firstKey.pks[record->firstKey.numOfPKs]));
220	}
221
UNCOV 222	for (record->lastKey.numOfPKs = 0; record->lastKey.numOfPKs < statisBlock->numOfPKs; record->lastKey.numOfPKs++) {	×
UNCOV 223	TAOS_CHECK_RETURN(tValueColumnGet(&statisBlock->lastKeyPKs[record->lastKey.numOfPKs], idx,	×
224	&record->lastKey.pks[record->lastKey.numOfPKs]));
225	}
226
UNCOV 227	return 0;	×
228	}
229
230	// SBrinRecord ----------
UNCOV 231	int32_t tBrinBlockInit(SBrinBlock *brinBlock) {	×
232	int32_t code;
233
UNCOV 234	brinBlock->numOfPKs = 0;	×
UNCOV 235	brinBlock->numOfRecords = 0;	×
UNCOV 236	for (int32_t i = 0; i < ARRAY_SIZE(brinBlock->buffers); ++i) {	×
UNCOV 237	tBufferInit(&brinBlock->buffers[i]);	×
238	}
UNCOV 239	for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {	×
UNCOV 240	TAOS_CHECK_GOTO(tValueColumnInit(&brinBlock->firstKeyPKs[i]), NULL, _exit);	×
UNCOV 241	TAOS_CHECK_GOTO(tValueColumnInit(&brinBlock->lastKeyPKs[i]), NULL, _exit);	×
242	}
243
UNCOV 244	_exit:	×
UNCOV 245	if (code) {	×
246	tBrinBlockDestroy(brinBlock);	×
247	}
UNCOV 248	return code;	×
249	}
250
UNCOV 251	void tBrinBlockDestroy(SBrinBlock *brinBlock) {	×
UNCOV 252	brinBlock->numOfPKs = 0;	×
UNCOV 253	brinBlock->numOfRecords = 0;	×
UNCOV 254	for (int32_t i = 0; i < ARRAY_SIZE(brinBlock->buffers); ++i) {	×
UNCOV 255	tBufferDestroy(&brinBlock->buffers[i]);	×
256	}
UNCOV 257	for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {	×
UNCOV 258	tValueColumnDestroy(&brinBlock->firstKeyPKs[i]);	×
UNCOV 259	tValueColumnDestroy(&brinBlock->lastKeyPKs[i]);	×
260	}
UNCOV 261	}	×
262
UNCOV 263	void tBrinBlockClear(SBrinBlock *brinBlock) {	×
UNCOV 264	brinBlock->numOfPKs = 0;	×
UNCOV 265	brinBlock->numOfRecords = 0;	×
UNCOV 266	for (int32_t i = 0; i < ARRAY_SIZE(brinBlock->buffers); ++i) {	×
UNCOV 267	tBufferClear(&brinBlock->buffers[i]);	×
268	}
UNCOV 269	for (int32_t i = 0; i < TD_MAX_PK_COLS; ++i) {	×
UNCOV 270	tValueColumnClear(&brinBlock->firstKeyPKs[i]);	×
UNCOV 271	tValueColumnClear(&brinBlock->lastKeyPKs[i]);	×
272	}
UNCOV 273	}	×
274
UNCOV 275	int32_t tBrinBlockPut(SBrinBlock brinBlock, const SBrinRecord record) {	×
UNCOV 276	if (record->firstKey.key.numOfPKs != record->lastKey.key.numOfPKs) {	×
277	return TSDB_CODE_INVALID_PARA;	×
278	}
279
UNCOV 280	if (brinBlock->numOfRecords == 0) { // the first row	×
UNCOV 281	brinBlock->numOfPKs = record->firstKey.key.numOfPKs;	×
UNCOV 282	} else if (brinBlock->numOfPKs != record->firstKey.key.numOfPKs) {	×
283	// if the number of primary keys are not the same,
284	// return an error code and the caller should handle it
UNCOV 285	return TSDB_CODE_INVALID_PARA;	×
286	} else {
UNCOV 287	for (int i = 0; i < brinBlock->numOfPKs; i++) {	×
UNCOV 288	if (record->firstKey.key.pks[i].type != brinBlock->firstKeyPKs[i].type) {	×
289	return TSDB_CODE_INVALID_PARA;	×
290	}
291	}
292	}
293
UNCOV 294	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->suids, record->suid));	×
UNCOV 295	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->uids, record->uid));	×
UNCOV 296	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->firstKeyTimestamps, record->firstKey.key.ts));	×
UNCOV 297	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->firstKeyVersions, record->firstKey.version));	×
UNCOV 298	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->lastKeyTimestamps, record->lastKey.key.ts));	×
UNCOV 299	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->lastKeyVersions, record->lastKey.version));	×
UNCOV 300	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->minVers, record->minVer));	×
UNCOV 301	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->maxVers, record->maxVer));	×
UNCOV 302	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->blockOffsets, record->blockOffset));	×
UNCOV 303	TAOS_CHECK_RETURN(tBufferPutI64(&brinBlock->smaOffsets, record->smaOffset));	×
UNCOV 304	TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->blockSizes, record->blockSize));	×
UNCOV 305	TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->blockKeySizes, record->blockKeySize));	×
UNCOV 306	TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->smaSizes, record->smaSize));	×
UNCOV 307	TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->numRows, record->numRow));	×
UNCOV 308	TAOS_CHECK_RETURN(tBufferPutI32(&brinBlock->counts, record->count));	×
309
UNCOV 310	if (brinBlock->numOfPKs > 0) {	×
UNCOV 311	for (int32_t i = 0; i < brinBlock->numOfPKs; ++i) {	×
UNCOV 312	TAOS_CHECK_RETURN(tValueColumnAppend(&brinBlock->firstKeyPKs[i], &record->firstKey.key.pks[i]));	×
313	}
314
UNCOV 315	for (int32_t i = 0; i < brinBlock->numOfPKs; ++i) {	×
UNCOV 316	TAOS_CHECK_RETURN(tValueColumnAppend(&brinBlock->lastKeyPKs[i], &record->lastKey.key.pks[i]));	×
317	}
318	}
319
UNCOV 320	brinBlock->numOfRecords++;	×
321
UNCOV 322	return 0;	×
323	}
324
UNCOV 325	int32_t tBrinBlockGet(SBrinBlock brinBlock, int32_t idx, SBrinRecord record) {	×
326	SBufferReader reader;
327
UNCOV 328	if (idx < 0 \|\| idx >= brinBlock->numOfRecords) {	×
329	return TSDB_CODE_OUT_OF_RANGE;	×
330	}
331
UNCOV 332	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->suids);	×
UNCOV 333	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->suid));	×
334
UNCOV 335	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->uids);	×
UNCOV 336	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->uid));	×
337
UNCOV 338	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->firstKeyTimestamps);	×
UNCOV 339	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->firstKey.key.ts));	×
340
UNCOV 341	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->firstKeyVersions);	×
UNCOV 342	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->firstKey.version));	×
343
UNCOV 344	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->lastKeyTimestamps);	×
UNCOV 345	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->lastKey.key.ts));	×
346
UNCOV 347	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->lastKeyVersions);	×
UNCOV 348	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->lastKey.version));	×
349
UNCOV 350	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->minVers);	×
UNCOV 351	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->minVer));	×
352
UNCOV 353	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->maxVers);	×
UNCOV 354	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->maxVer));	×
355
UNCOV 356	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->blockOffsets);	×
UNCOV 357	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->blockOffset));	×
358
UNCOV 359	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int64_t), &brinBlock->smaOffsets);	×
UNCOV 360	TAOS_CHECK_RETURN(tBufferGetI64(&reader, &record->smaOffset));	×
361
UNCOV 362	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->blockSizes);	×
UNCOV 363	TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->blockSize));	×
364
UNCOV 365	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->blockKeySizes);	×
UNCOV 366	TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->blockKeySize));	×
367
UNCOV 368	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->smaSizes);	×
UNCOV 369	TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->smaSize));	×
370
UNCOV 371	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->numRows);	×
UNCOV 372	TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->numRow));	×
373
UNCOV 374	reader = BUFFER_READER_INITIALIZER(idx * sizeof(int32_t), &brinBlock->counts);	×
UNCOV 375	TAOS_CHECK_RETURN(tBufferGetI32(&reader, &record->count));	×
376
377	// primary keys
UNCOV 378	for (record->firstKey.key.numOfPKs = 0; record->firstKey.key.numOfPKs < brinBlock->numOfPKs;	×
UNCOV 379	record->firstKey.key.numOfPKs++) {	×
UNCOV 380	TAOS_CHECK_RETURN(tValueColumnGet(&brinBlock->firstKeyPKs[record->firstKey.key.numOfPKs], idx,	×
381	&record->firstKey.key.pks[record->firstKey.key.numOfPKs]));
382	}
383
UNCOV 384	for (record->lastKey.key.numOfPKs = 0; record->lastKey.key.numOfPKs < brinBlock->numOfPKs;	×
UNCOV 385	record->lastKey.key.numOfPKs++) {	×
UNCOV 386	TAOS_CHECK_RETURN(tValueColumnGet(&brinBlock->lastKeyPKs[record->lastKey.key.numOfPKs], idx,	×
387	&record->lastKey.key.pks[record->lastKey.key.numOfPKs]));
388	}
389
UNCOV 390	return 0;	×
391	}
392
393	// other apis ----------
UNCOV 394	int32_t tsdbUpdateSkmTb(STsdb pTsdb, const TABLEID tbid, SSkmInfo *pSkmTb) {	×
UNCOV 395	if (tbid->suid) {	×
UNCOV 396	if (pSkmTb->suid == tbid->suid) {	×
UNCOV 397	pSkmTb->uid = tbid->uid;	×
UNCOV 398	return 0;	×
399	}
UNCOV 400	} else if (pSkmTb->uid == tbid->uid) {	×
UNCOV 401	return 0;	×
402	}
403
UNCOV 404	pSkmTb->suid = tbid->suid;	×
UNCOV 405	pSkmTb->uid = tbid->uid;	×
UNCOV 406	tDestroyTSchema(pSkmTb->pTSchema);	×
UNCOV 407	return metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, tbid->suid, tbid->uid, -1, &pSkmTb->pTSchema);	×
408	}
409
UNCOV 410	int32_t tsdbUpdateSkmRow(STsdb pTsdb, const TABLEID tbid, int32_t sver, SSkmInfo *pSkmRow) {	×
UNCOV 411	if (pSkmRow->pTSchema && pSkmRow->suid == tbid->suid) {	×
UNCOV 412	if (pSkmRow->suid) {	×
UNCOV 413	if (sver == pSkmRow->pTSchema->version) return 0;	×
UNCOV 414	} else if (pSkmRow->uid == tbid->uid && pSkmRow->pTSchema->version == sver) {	×
UNCOV 415	return 0;	×
416	}
417	}
418
419	pSkmRow->suid = tbid->suid;	×
420	pSkmRow->uid = tbid->uid;	×
421	tDestroyTSchema(pSkmRow->pTSchema);	×
422	return metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, tbid->suid, tbid->uid, sver, &pSkmRow->pTSchema);	×
423	}
424	int32_t tsdbUpdateColCmprObj(STsdb pTsdb, const TABLEID tbid, SHashObj **ppColCmpr) { return 0; }	×

taosdata / TDengine / #3565

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

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