diff options
Diffstat (limited to 'contrib/test_decoding/test_decoding.c')
| -rw-r--r-- | contrib/test_decoding/test_decoding.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/contrib/test_decoding/test_decoding.c b/contrib/test_decoding/test_decoding.c index de1b6926581..e5cd84e85e4 100644 --- a/contrib/test_decoding/test_decoding.c +++ b/contrib/test_decoding/test_decoding.c @@ -339,7 +339,7 @@ pg_decode_commit_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, if (data->include_timestamp) appendStringInfo(ctx->out, " (at %s)", - timestamptz_to_str(txn->commit_time)); + timestamptz_to_str(txn->xact_time.commit_time)); OutputPluginWrite(ctx, true); } @@ -382,7 +382,7 @@ pg_decode_prepare_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, if (data->include_timestamp) appendStringInfo(ctx->out, " (at %s)", - timestamptz_to_str(txn->commit_time)); + timestamptz_to_str(txn->xact_time.prepare_time)); OutputPluginWrite(ctx, true); } @@ -404,7 +404,7 @@ pg_decode_commit_prepared_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn if (data->include_timestamp) appendStringInfo(ctx->out, " (at %s)", - timestamptz_to_str(txn->commit_time)); + timestamptz_to_str(txn->xact_time.commit_time)); OutputPluginWrite(ctx, true); } @@ -428,7 +428,7 @@ pg_decode_rollback_prepared_txn(LogicalDecodingContext *ctx, if (data->include_timestamp) appendStringInfo(ctx->out, " (at %s)", - timestamptz_to_str(txn->commit_time)); + timestamptz_to_str(txn->xact_time.commit_time)); OutputPluginWrite(ctx, true); } @@ -853,7 +853,7 @@ pg_decode_stream_prepare(LogicalDecodingContext *ctx, if (data->include_timestamp) appendStringInfo(ctx->out, " (at %s)", - timestamptz_to_str(txn->commit_time)); + timestamptz_to_str(txn->xact_time.prepare_time)); OutputPluginWrite(ctx, true); } @@ -882,7 +882,7 @@ pg_decode_stream_commit(LogicalDecodingContext *ctx, if (data->include_timestamp) appendStringInfo(ctx->out, " (at %s)", - timestamptz_to_str(txn->commit_time)); + timestamptz_to_str(txn->xact_time.commit_time)); OutputPluginWrite(ctx, true); } |