diff options
Diffstat (limited to 'src/bin/pg_basebackup/pg_recvlogical.c')
| -rw-r--r-- | src/bin/pg_basebackup/pg_recvlogical.c | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/bin/pg_basebackup/pg_recvlogical.c b/src/bin/pg_basebackup/pg_recvlogical.c index 553ba7b8f4d..bf0246c4266 100644 --- a/src/bin/pg_basebackup/pg_recvlogical.c +++ b/src/bin/pg_basebackup/pg_recvlogical.c @@ -131,8 +131,8 @@ sendFeedback(PGconn *conn, TimestampTz now, bool force, bool replyRequested) if (verbose) pg_log_info("confirming write up to %X/%X, flush to %X/%X (slot %s)", - (uint32) (output_written_lsn >> 32), (uint32) output_written_lsn, - (uint32) (output_fsync_lsn >> 32), (uint32) output_fsync_lsn, + LSN_FORMAT_ARGS(output_written_lsn), + LSN_FORMAT_ARGS(output_fsync_lsn), replication_slot); replybuf[len] = 'r'; @@ -228,12 +228,12 @@ StreamLogicalLog(void) */ if (verbose) pg_log_info("starting log streaming at %X/%X (slot %s)", - (uint32) (startpos >> 32), (uint32) startpos, + LSN_FORMAT_ARGS(startpos), replication_slot); /* Initiate the replication stream at specified location */ appendPQExpBuffer(query, "START_REPLICATION SLOT \"%s\" LOGICAL %X/%X", - replication_slot, (uint32) (startpos >> 32), (uint32) startpos); + replication_slot, LSN_FORMAT_ARGS(startpos)); /* print options if there are any */ if (noptions) @@ -1045,10 +1045,9 @@ prepareToTerminate(PGconn *conn, XLogRecPtr endpos, bool keepalive, XLogRecPtr l { if (keepalive) pg_log_info("end position %X/%X reached by keepalive", - (uint32) (endpos >> 32), (uint32) endpos); + LSN_FORMAT_ARGS(endpos)); else pg_log_info("end position %X/%X reached by WAL record at %X/%X", - (uint32) (endpos >> 32), (uint32) (endpos), - (uint32) (lsn >> 32), (uint32) lsn); + LSN_FORMAT_ARGS(endpos), LSN_FORMAT_ARGS(lsn)); } } |