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

refact: use tsdbTFileUpdVerRange in tsdbSttFWriterCloseCommit

This commit is contained in:
Benguang Zhao 2023-09-01 19:06:48 +08:00
parent 54a10154a4
commit 0a67cc8477
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/dnode/vnode/src/tsdb/tsdbDataFileRW.h
View File

@ -110,6 +110,7 @@ int32_t tsdbFileWriteTombFooter(STsdbFD *fd, const STombFooter *footer, int64_t
// utils // utils
int32_t tsdbWriterUpdVerRange(SVersionRange *range, int64_t minVer, int64_t maxVer); int32_t tsdbWriterUpdVerRange(SVersionRange *range, int64_t minVer, int64_t maxVer);
int32_t tsdbTFileUpdVerRange(STFile *f, SVersionRange range);
#ifdef __cplusplus #ifdef __cplusplus
} }

3
source/dnode/vnode/src/tsdb/tsdbSttFileRW.c
View File

@ -721,8 +721,7 @@ static int32_t tsdbSttFWriterCloseCommit(SSttFileWriter *writer, TFileOpArray *o
.fid = writer->config->fid, .fid = writer->config->fid,
.nf = writer->file[0], .nf = writer->file[0],
}; };
op.nf.minVer = TMIN(op.nf.minVer, writer->ctx->range.minVer); tsdbTFileUpdVerRange(&op.nf, writer->ctx->range);
op.nf.maxVer = TMAX(op.nf.maxVer, writer->ctx->range.maxVer);
code = TARRAY2_APPEND(opArray, op); code = TARRAY2_APPEND(opArray, op);
TSDB_CHECK_CODE(code, lino, _exit); TSDB_CHECK_CODE(code, lino, _exit);