From 1c182684c4fae38dddad2536f2cb5386800b4122 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Wed, 24 Aug 2022 11:51:34 +0800 Subject: [PATCH] more code --- source/dnode/vnode/src/tsdb/tsdbCommit.c | 48 ------------------------ 1 file changed, 48 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit.c b/source/dnode/vnode/src/tsdb/tsdbCommit.c index 2debc7b2de..ea398461ae 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCommit.c +++ b/source/dnode/vnode/src/tsdb/tsdbCommit.c @@ -327,54 +327,6 @@ _exit: return code; } -// static int32_t tsdbCommitterNextLastRow(SCommitter *pCommitter) { -// int32_t code = 0; - -// ASSERT(pCommitter->dReader.pReader); -// ASSERT(pCommitter->dReader.pRowInfo); - -// SBlockData *pBlockDatal = &pCommitter->dReader.bDatal; -// pCommitter->dReader.iRow++; -// if (pCommitter->dReader.iRow < pBlockDatal->nRow) { -// if (pBlockDatal->uid) { -// pCommitter->dReader.pRowInfo->uid = pBlockDatal->uid; -// } else { -// pCommitter->dReader.pRowInfo->uid = pBlockDatal->aUid[pCommitter->dReader.iRow]; -// } -// pCommitter->dReader.pRowInfo->row = tsdbRowFromBlockData(pBlockDatal, pCommitter->dReader.iRow); -// } else { -// pCommitter->dReader.iBlockL++; -// if (pCommitter->dReader.iBlockL < taosArrayGetSize(pCommitter->dReader.aBlockL)) { -// SBlockL *pBlockL = (SBlockL *)taosArrayGet(pCommitter->dReader.aBlockL, pCommitter->dReader.iBlockL); -// int64_t suid = pBlockL->suid; -// int64_t uid = pBlockL->maxUid; - -// code = tsdbCommitterUpdateTableSchema(pCommitter, suid, uid); -// if (code) goto _exit; - -// code = tBlockDataInit(pBlockDatal, suid, suid ? 0 : uid, pCommitter->skmTable.pTSchema); -// if (code) goto _exit; - -// code = tsdbReadLastBlock(pCommitter->dReader.pReader, pBlockL, pBlockDatal); -// if (code) goto _exit; - -// pCommitter->dReader.iRow = 0; -// pCommitter->dReader.pRowInfo->suid = pBlockDatal->suid; -// if (pBlockDatal->uid) { -// pCommitter->dReader.pRowInfo->uid = pBlockDatal->uid; -// } else { -// pCommitter->dReader.pRowInfo->uid = pBlockDatal->aUid[0]; -// } -// pCommitter->dReader.pRowInfo->row = tsdbRowFromBlockData(pBlockDatal, pCommitter->dReader.iRow); -// } else { -// pCommitter->dReader.pRowInfo = NULL; -// } -// } - -// _exit: -// return code; -// } - static int32_t tsdbCommitterNextTableData(SCommitter *pCommitter) { int32_t code = 0;