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

fix: fix bug that counted the number of child tables handled by threads incorrectly

This commit is contained in:
Yaming Pei 2025-03-03 17:28:26 +08:00
parent 6bc6223db3
commit 7eef6659ac
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tools/taos-tools/src/benchCsv.c
View File

@ -114,7 +114,7 @@ static void csvCalcCtbRange(CsvThreadMeta* thread_meta, size_t total_threads, in
thread_meta->ctb_start_idx = ctb_start_idx;
thread_meta->ctb_end_idx = ctb_end_idx;
thread_meta->ctb_count = ctb_count;
thread_meta->ctb_count = ctb_end_idx - ctb_start_idx;
return;
}
@ -385,7 +385,10 @@ int csvGenCreateStbSql(SDataBase* db, SSuperTable* stb, char* buf, int size) {
if (pos <= 0 || pos >= size) return -1;
}
infoPrint("create stable: <%s>\n", buf);
pos += snprintf(buf + pos, size - pos, "\n");
if (pos <= 0 || pos >= size) return -1;
// infoPrint("create stable: <%s>.\n", buf);
return (pos > 0 && pos < size) ? pos : -1;
}
@ -677,7 +680,7 @@ static int csvGenRowTagData(char* buf, int size, SSuperTable* stb, int64_t index
}
// tbname
int pos = snprintf(buf, size, "\'%s%"PRId64"\'", stb->childTblPrefix, index);
int pos = snprintf(buf, size, ",'%s%"PRId64"'", stb->childTblPrefix, index);
// tags
pos += csvGenRowFields(buf + pos, size - pos, stb, GEN_ROW_FIELDS_TAG, k);
@ -968,6 +971,7 @@ static void* csvGenStbThread(void* arg) {
slice_cur_ts = cur_ts;
slice_end_ts = MIN(cur_ts + write_meta->ts_step, write_meta->end_ts);
file_rows = 0;
pre_print_ts = toolsGetTimestampMs();
infoPrint("thread[%zu] begin to write csv file: %s.\n", thread_meta->thread_id, fullname);
@ -1000,7 +1004,7 @@ static void* csvGenStbThread(void* arg) {
}
if (!g_arguments->terminate) {
if (g_arguments->terminate) {
csvClose(fhdl);
goto end;
}