Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitf4358ea

Browse files
author
Marina Polyakova
committed
Pgbench Fix progress reports and aggregation logs
1 parentabd8ecd commitf4358ea

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

‎src/bin/pgbench/pgbench.c

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -2334,9 +2334,11 @@ doLog(TState *thread, CState *st, instr_time *now,
23342334
while (agg->start_time+agg_interval<INSTR_TIME_GET_DOUBLE(*now))
23352335
{
23362336
/* print aggregated report to logfile */
2337-
fprintf(logfile,"%ld "INT64_FORMAT" %.0f %.0f %.0f %.0f",
2337+
fprintf(logfile,"%ld "INT64_FORMAT""INT64_FORMAT" "INT64_FORMAT"%.0f %.0f %.0f %.0f",
23382338
agg->start_time,
23392339
agg->cnt,
2340+
agg->serialization_failures,
2341+
agg->deadlock_failures,
23402342
agg->latency.sum,
23412343
agg->latency.sum2,
23422344
agg->latency.min,
@@ -2351,8 +2353,6 @@ doLog(TState *thread, CState *st, instr_time *now,
23512353
if (latency_limit)
23522354
fprintf(logfile," "INT64_FORMAT,agg->skipped);
23532355
}
2354-
fprintf(logfile," "INT64_FORMAT" "INT64_FORMAT,
2355-
agg->serialization_failures,agg->deadlock_failures);
23562356
fputc('\n',logfile);
23572357

23582358
/* reset data and move to next interval */
@@ -4651,8 +4651,14 @@ threadRun(void *arg)
46514651
sprintf(tbuf,"%.1f s",total_run);
46524652

46534653
fprintf(stderr,
4654-
"progress: %s, %.1f tps, lat %.3f ms stddev %.3f",
4655-
tbuf,tps,latency,stdev);
4654+
"progress: %s, %.1f tps, "INT64_FORMAT" serialization failures transactions, "INT64_FORMAT" deadlock failures transactions, lat %.3f ms stddev %.3f",
4655+
tbuf,
4656+
tps,
4657+
(cur.serialization_failures-
4658+
last.serialization_failures),
4659+
(cur.deadlock_failures-last.deadlock_failures),
4660+
latency,
4661+
stdev);
46564662

46574663
if (throttle_delay)
46584664
{
@@ -4661,12 +4667,6 @@ threadRun(void *arg)
46614667
fprintf(stderr,", "INT64_FORMAT" skipped",
46624668
cur.skipped-last.skipped);
46634669
}
4664-
fprintf(stderr,", "INT64_FORMAT" serialization failures",
4665-
(cur.serialization_failures-
4666-
last.serialization_failures));
4667-
fprintf(stderr,", "INT64_FORMAT" deadlock failures",
4668-
(cur.deadlock_failures-last.deadlock_failures));
4669-
46704670
fprintf(stderr,"\n");
46714671

46724672
last=cur;

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp