From a6a5fe3525c40dcee0e1a04c713d24cbf142d99b Mon Sep 17 00:00:00 2001 From: xiepy Date: Mon, 19 Apr 2021 11:03:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96gs=5Fprobackup=E5=A4=87?= =?UTF-8?q?=E6=9C=BA=E5=A4=87=E4=BB=BD=E4=BC=9A=E6=89=93=E5=8D=B0=E5=BE=88?= =?UTF-8?q?=E5=A4=9A=E9=87=8D=E5=A4=8Dlog=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/bin/pg_probackup/backup.cpp | 10 ++++++++++ src/bin/pg_probackup/parsexlog.cpp | 5 +++-- 2 files changed, 13 insertions(+), 2 deletions(-) diff --git a/src/bin/pg_probackup/backup.cpp b/src/bin/pg_probackup/backup.cpp index 0ed9e774e..5ac9a924d 100644 --- a/src/bin/pg_probackup/backup.cpp +++ b/src/bin/pg_probackup/backup.cpp @@ -1223,10 +1223,20 @@ void tryToFindCompressedWALFile(bool *file_exists, char *gz_wal_segment_path, ch #ifdef HAVE_LIBZ *file_exists = fileExists(gz_wal_segment_path, FIO_BACKUP_HOST); if (*file_exists) + { elog(LOG, "Found compressed WAL segment: %s", wal_segment_path); + if (current.from_replica) + { + elog(INFO, "Wait a few minutes to get the target LSN or the last valid record prior to the target LSN"); + } + } #endif } else { elog(LOG, "Found WAL segment: %s", wal_segment_path); + if (current.from_replica) + { + elog(INFO, "Wait a few minutes to get the target LSN or the last valid record prior to the target LSN"); + } } } diff --git a/src/bin/pg_probackup/parsexlog.cpp b/src/bin/pg_probackup/parsexlog.cpp index ae4ee2b63..644ee5f13 100644 --- a/src/bin/pg_probackup/parsexlog.cpp +++ b/src/bin/pg_probackup/parsexlog.cpp @@ -1054,8 +1054,9 @@ static int switch_next_wal_segment(XLogReaderData *reader_data, bool *isreturn) if (fileExists(reader_data->xlogpath, FIO_LOCAL_HOST)) { - elog(LOG, "Thread [%d]: Opening WAL segment \"%s\"", - reader_data->thread_num, reader_data->xlogpath); + if (!current.from_replica) + elog(LOG, "Thread [%d]: Opening WAL segment \"%s\"", + reader_data->thread_num, reader_data->xlogpath); reader_data->xlogexists = true; reader_data->xlogfile = fio_open(reader_data->xlogpath,