[TD-3143] <fix>: make taosdemo works on windows. fix time shifting.

This commit is contained in:
Shuduo Sang 2021-03-11 12:49:52 +08:00
parent ac56cf52b7
commit 5ae71f5b80
1 changed files with 3 additions and 2 deletions

View File

@ -4179,10 +4179,11 @@ static void* syncWrite(void *sarg) {
winfo->totalAffectedRows = 0; winfo->totalAffectedRows = 0;
for (int tID = winfo->start_table_id; tID <= winfo->end_table_id; tID++) { for (int tID = winfo->start_table_id; tID <= winfo->end_table_id; tID++) {
int64_t tmp_time = time_counter;
for (int i = 0; i < g_args.num_of_DPT;) { for (int i = 0; i < g_args.num_of_DPT;) {
int tblInserted = i; int tblInserted = i;
int64_t tmp_time = time_counter;
char *pstr = buffer; char *pstr = buffer;
pstr += sprintf(pstr, pstr += sprintf(pstr,
@ -4251,7 +4252,7 @@ static void* syncWrite(void *sarg) {
winfo->avgDelay = (double)winfo->totalDelay / winfo->cntDelay; winfo->avgDelay = (double)winfo->totalDelay / winfo->cntDelay;
} }
verbosePrint("%s() LN%d: totalaffectedRows:%"PRId64"\n", __func__, __LINE__, winfo->totalAffectedRows); verbosePrint("%s() LN%d: totalaffectedRows:%"PRId64" tblInserted\n", __func__, __LINE__, winfo->totalAffectedRows, tblInserted);
if (g_args.insert_interval) { if (g_args.insert_interval) {
et = taosGetTimestampMs(); et = taosGetTimestampMs();
} }