From fa9fafb42f6ed98594ffd74973a55c409ab36dc6 Mon Sep 17 00:00:00 2001 From: Bharath Rupireddy Date: Tue, 7 Dec 2021 12:40:34 +0000 Subject: [PATCH v3] add log messages for recovery --- src/backend/access/transam/xlog.c | 15 ++++++++++++++- src/backend/access/transam/xlogarchive.c | 2 +- 2 files changed, 15 insertions(+), 2 deletions(-) diff --git a/src/backend/access/transam/xlog.c b/src/backend/access/transam/xlog.c index d894af310a..bbdb93db61 100644 --- a/src/backend/access/transam/xlog.c +++ b/src/backend/access/transam/xlog.c @@ -3776,6 +3776,7 @@ XLogFileRead(XLogSegNo segno, int emode, TimeLineID tli, char activitymsg[MAXFNAMELEN + 16]; char path[MAXPGPATH]; int fd; + char srcname[MAXFNAMELEN]; XLogFileName(xlogfname, tli, segno, wal_segment_size); @@ -3787,16 +3788,25 @@ XLogFileRead(XLogSegNo segno, int emode, TimeLineID tli, xlogfname); set_ps_display(activitymsg); + ereport(LOG, + (errmsg("waiting for WAL segment \"%s\" from archive", + xlogfname))); + if (!RestoreArchivedFile(path, xlogfname, "RECOVERYXLOG", wal_segment_size, InRedo)) return -1; + + snprintf(srcname, MAXFNAMELEN, "archive"); break; case XLOG_FROM_PG_WAL: + snprintf(srcname, MAXFNAMELEN, "pg_wal"); + /* fall through */ case XLOG_FROM_STREAM: XLogFilePath(path, tli, segno, wal_segment_size); + snprintf(srcname, MAXFNAMELEN, "stream"); break; default: @@ -3829,6 +3839,10 @@ XLogFileRead(XLogSegNo segno, int emode, TimeLineID tli, xlogfname); set_ps_display(activitymsg); + ereport(LOG, + (errmsg("recovering WAL segment \"%s\" from source \"%s\"", + xlogfname, srcname))); + /* Track source of data in assorted state variables */ readSource = source; XLogReceiptSource = source; @@ -3919,7 +3933,6 @@ XLogFileReadAnyTLI(XLogSegNo segno, int emode, XLogSource source) XLOG_FROM_ARCHIVE, true); if (fd != -1) { - elog(DEBUG1, "got WAL segment from archive"); if (!expectedTLEs) expectedTLEs = tles; return fd; diff --git a/src/backend/access/transam/xlogarchive.c b/src/backend/access/transam/xlogarchive.c index 4ddeac1fb9..1f724f4acf 100644 --- a/src/backend/access/transam/xlogarchive.c +++ b/src/backend/access/transam/xlogarchive.c @@ -214,7 +214,7 @@ RestoreArchivedFile(char *path, const char *xlogfname, else { ereport(LOG, - (errmsg("restored log file \"%s\" from archive", + (errmsg("restored WAL segment \"%s\" from archive", xlogfname))); strcpy(path, xlogpath); return true; -- 2.25.1