xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

more code

This commit is contained in:
Hongze Cheng 2023-02-08 14:28:54 +08:00
parent 89cc687b42
commit 0f70a61253
2 changed files with 15 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
source/dnode/vnode/src/tsdb/tsdbCompact.c
View File

@ -95,6 +95,8 @@ static int32_t tsdbAbortCompact(STsdbCompactor *pCompactor) {
_exit: _exit:
if (code) { if (code) {
tsdbError("vgId:%d %s failed at line %d since %s", TD_VID(pTsdb->pVnode), __func__, lino, tstrerror(code)); tsdbError("vgId:%d %s failed at line %d since %s", TD_VID(pTsdb->pVnode), __func__, lino, tstrerror(code));
} else {
tsdbInfo("vgId:%d %s done", TD_VID(pTsdb->pVnode), __func__);
} }
return code; return code;
} }
@ -580,6 +582,15 @@ _exit:
if (code) { if (code) {
tsdbError("vgId:%d %s failed at line %d since %s, commit ID:%" PRId64, TD_VID(pTsdb->pVnode), __func__, lino, tsdbError("vgId:%d %s failed at line %d since %s, commit ID:%" PRId64, TD_VID(pTsdb->pVnode), __func__, lino,
tstrerror(code), pCompactor->commitID); tstrerror(code), pCompactor->commitID);
tBlockDataDestroy(&pCompactor->sData);
tBlockDataDestroy(&pCompactor->bData);
if (pCompactor->fs.pDelFile) {
taosArrayDestroy(pCompactor->aSkyLine);
taosArrayDestroy(pCompactor->aDelData);
taosArrayDestroy(pCompactor->aDelIdx);
if (pCompactor->pDelFReader) tsdbDelFReaderClose(&pCompactor->pDelFReader);
}
tsdbFSDestroy(&pCompactor->fs);
} else { } else {
tsdbInfo("vgId:%d %s done, commit ID:%" PRId64, TD_VID(pTsdb->pVnode), __func__, pCompactor->commitID); tsdbInfo("vgId:%d %s done, commit ID:%" PRId64, TD_VID(pTsdb->pVnode), __func__, pCompactor->commitID);
} }
@ -588,16 +599,12 @@ _exit:
int32_t tsdbCompact(STsdb *pTsdb, int32_t flag) { int32_t tsdbCompact(STsdb *pTsdb, int32_t flag) {
int32_t code = 0; int32_t code = 0;
int32_t lino = 0;
STsdbCompactor *pCompactor = &(STsdbCompactor){0}; STsdbCompactor *pCompactor = &(STsdbCompactor){0};
// begin compact if ((code = tsdbBeginCompact(pTsdb, pCompactor))) return code;
code = tsdbBeginCompact(pTsdb, pCompactor);
TSDB_CHECK_CODE(code, lino, _exit);
// loop to compact each file set for (;;) {
while (true) {
SDFileSet *pSet = (SDFileSet *)taosArraySearch(pCompactor->fs.aDFileSet, &(SDFileSet){.fid = pCompactor->fid}, SDFileSet *pSet = (SDFileSet *)taosArraySearch(pCompactor->fs.aDFileSet, &(SDFileSet){.fid = pCompactor->fid},
tDFileSetCmprFn, TD_GT); tDFileSetCmprFn, TD_GT);
if (pSet == NULL) { if (pSet == NULL) {
@ -605,18 +612,13 @@ int32_t tsdbCompact(STsdb *pTsdb, int32_t flag) {
break; break;
} }
code = tsdbCompactFileSet(pCompactor, pSet); if ((code = tsdbCompactFileSet(pCompactor, pSet))) goto _exit;
TSDB_CHECK_CODE(code, lino, _exit);
} }
code = tsdbFSUpsertDelFile(&pCompactor->fs, NULL); if ((code = tsdbFSUpsertDelFile(&pCompactor->fs, NULL))) goto _exit;
TSDB_CHECK_CODE(code, lino, _exit);
_exit: _exit:
// commit/abort compact
if (code) { if (code) {
tsdbError("vgId:%d %s failed at line %d since %s, commit ID:%" PRId64, TD_VID(pTsdb->pVnode), __func__, lino,
tstrerror(code), pCompactor->commitID);
tsdbAbortCompact(pCompactor); tsdbAbortCompact(pCompactor);
} else { } else {
tsdbCommitCompact(pCompactor); tsdbCommitCompact(pCompactor);

1
source/dnode/vnode/src/tsdb/tsdbDataIter.c
View File

@ -16,7 +16,6 @@
#include "tsdb.h" #include "tsdb.h"
// STsdbDataIter2 // STsdbDataIter2
/* open */ /* open */
int32_t tsdbOpenDataFileDataIter(SDataFReader* pReader, STsdbDataIter2** ppIter) { int32_t tsdbOpenDataFileDataIter(SDataFReader* pReader, STsdbDataIter2** ppIter) {
int32_t code = 0; int32_t code = 0;