diff --git a/src/bin/pg_basebackup/receivelog.cpp b/src/bin/pg_basebackup/receivelog.cpp index 945bd2250..2f970bff8 100644 --- a/src/bin/pg_basebackup/receivelog.cpp +++ b/src/bin/pg_basebackup/receivelog.cpp @@ -494,12 +494,12 @@ static int DoWALWrite(const char* wal_buf, int len, XLogRecPtr& block_pos, const suspendHeartBeatTimer(); return DO_WAL_DATA_WRITE_ERROR; } - lastFlushPosition = block_pos; /* Write was successful, advance our position */ bytes_written += bytes_to_write; bytes_left -= bytes_to_write; XLByteAdvance(block_pos, bytes_to_write); xlogoff += bytes_to_write; + lastFlushPosition = block_pos; /* Did we reach the end of a WAL segment? */ if (block_pos % XLogSegSize == 0) {