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

refact: rename func names of tsdbDataWriterUpdVerRange and tsdbSttWriterUpdVerRange

This commit is contained in:
Benguang Zhao 2023-08-31 15:53:51 +08:00
parent 399afe1094
commit f207b3ddd5
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/dnode/vnode/src/tsdb/tsdbDataFileRW.c
View File

@ -642,7 +642,7 @@ _exit:
return code;
}
static int32_t tsdbSDataUpdVerRange(SDataFileWriterConfig *config, SVersionRange *range) {
static int32_t tsdbDataWriterUpdVerRange(SDataFileWriterConfig *config, SVersionRange *range) {
config->minVer = TMIN(config->minVer, range->minVer);
config->maxVer = TMAX(config->maxVer, range->maxVer);
return 0;
@ -746,7 +746,7 @@ static int32_t tsdbDataFileWriteBrinBlock(SDataFileWriter *writer) {
&range);
TSDB_CHECK_CODE(code, lino, _exit);
tsdbSDataUpdVerRange(writer->config, &range);
tsdbDataWriterUpdVerRange(writer->config, &range);
_exit:
if (code) {
@ -813,7 +813,7 @@ static int32_t tsdbDataFileDoWriteBlockData(SDataFileWriter *writer, SBlockData
}
SVersionRange range = {.minVer = record->minVer, .maxVer = record->maxVer};
tsdbSDataUpdVerRange(writer->config, &range);
tsdbDataWriterUpdVerRange(writer->config, &range);
// to .data file
int32_t sizeArr[5] = {0};
@ -1246,7 +1246,7 @@ static int32_t tsdbDataFileDoWriteTombBlock(SDataFileWriter *writer) {
code = tsdbFileWriteTombBlock(writer->fd[TSDB_FTYPE_TOMB], writer->tombBlock, writer->config->cmprAlg,
&writer->files[TSDB_FTYPE_TOMB].size, writer->tombBlkArray, writer->config->bufArr, &range);
TSDB_CHECK_CODE(code, lino, _exit);
tsdbSDataUpdVerRange(writer->config, &range);
tsdbDataWriterUpdVerRange(writer->config, &range);
_exit:
if (code) {

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

@ -402,7 +402,7 @@ struct SSttFileWriter {
uint8_t *bufArr[5];
};
static int32_t tsdbSSttUpdVerRange(SSttFileWriterConfig *config, SVersionRange *range) {
static int32_t tsdbSttWriterUpdVerRange(SSttFileWriterConfig *config, SVersionRange *range) {
config->minVer = TMIN(config->minVer, range->minVer);
config->maxVer = TMAX(config->maxVer, range->maxVer);
return 0;
@ -469,7 +469,7 @@ static int32_t tsdbSttFileDoWriteBlockData(SSttFileWriter *writer) {
code = tsdbFileDoWriteSttBlockData(writer->fd, writer->blockData, writer->config->cmprAlg, &writer->file->size,
writer->sttBlkArray, writer->config->bufArr, &range);
TSDB_CHECK_CODE(code, lino, _exit);
tsdbSSttUpdVerRange(writer->config, &range);
tsdbSttWriterUpdVerRange(writer->config, &range);
_exit:
if (code) {
@ -539,7 +539,7 @@ static int32_t tsdbSttFileDoWriteTombBlock(SSttFileWriter *writer) {
code = tsdbFileWriteTombBlock(writer->fd, writer->tombBlock, writer->config->cmprAlg, &writer->file->size,
writer->tombBlkArray, writer->config->bufArr, &range);
TSDB_CHECK_CODE(code, lino, _exit);
tsdbSSttUpdVerRange(writer->config, &range);
tsdbSttWriterUpdVerRange(writer->config, &range);
_exit:
if (code) {