Remove useless arguments in ReadCheckpointRecord().

This commit removes two arguments "report" and "whichChkpt"
in ReadCheckpointRecord().

"report" is obviously useless because it's always true, i.e., there are
two callers of the function and they always specify true as "report".
Commit 1d919de5eb removed the only call with "report" = false.

"whichChkpt" indicated where the specified checkpoint location
came from, pg_control or backup_label. This information was used
to report different error messages depending on where the invalid
checkpoint record came from, when it was found.
But ReadCheckpointRecord() doesn't need to do that because
its callers already do that and users can still identify where
the invalid checkpoint record came from, by reading such log messages.
Also when "whichChkpt" was 0, the word "primary checkpoint" was used
in the log message and could confuse users because the concept of
primary and secondary checkpoints was already removed before.
These are why this commit removes "whichChkpt" argument.

Author: Fujii Masao
Reviewed-by: Bharath Rupireddy, Kyotaro Horiguchi
Discussion: https://postgr.es/m/fa2e12eb-81c3-0717-0272-755f8a81c8f2@oss.nttdata.com

diff --git a/src/backend/access/transam/xlogrecovery.c b/src/backend/access/transam/xlogrecovery.c
index 5d6f1b5e4686aaab017e74c66e60a138563979c4..e383c2123a3fd4f922b070b5da97bbe35d7b31c2 100644 (file)
--- a/src/backend/access/transam/xlogrecovery.c
+++ b/src/backend/access/transam/xlogrecovery.c
@@ -422,8 +422,8 @@ static XLogPageReadResult WaitForWALToBecomeAvailable(XLogRecPtr RecPtr,
                                                      XLogRecPtr replayLSN,
                                                      bool nonblocking);
 static int emode_for_corrupt_record(int emode, XLogRecPtr RecPtr);
-static XLogRecord *ReadCheckpointRecord(XLogPrefetcher *xlogprefetcher, XLogRecPtr RecPtr,
-                                       int whichChkpt, bool report, TimeLineID replayTLI);
+static XLogRecord *ReadCheckpointRecord(XLogPrefetcher *xlogprefetcher,
+                                       XLogRecPtr RecPtr, TimeLineID replayTLI);
 static bool rescanLatestTimeLine(TimeLineID replayTLI, XLogRecPtr replayLSN);
 static int XLogFileRead(XLogSegNo segno, int emode, TimeLineID tli,
                         XLogSource source, bool notfoundOk);
@@ -605,7 +605,7 @@ InitWalRecovery(ControlFileData *ControlFile, bool *wasShutdown_ptr,
         * When a backup_label file is present, we want to roll forward from
         * the checkpoint it identifies, rather than using pg_control.
         */
-       record = ReadCheckpointRecord(xlogprefetcher, CheckPointLoc, 0, true,
+       record = ReadCheckpointRecord(xlogprefetcher, CheckPointLoc,
                                      CheckPointTLI);
        if (record != NULL)
        {
@@ -744,7 +744,7 @@ InitWalRecovery(ControlFileData *ControlFile, bool *wasShutdown_ptr,
        CheckPointTLI = ControlFile->checkPointCopy.ThisTimeLineID;
        RedoStartLSN = ControlFile->checkPointCopy.redo;
        RedoStartTLI = ControlFile->checkPointCopy.ThisTimeLineID;
-       record = ReadCheckpointRecord(xlogprefetcher, CheckPointLoc, 1, true,
+       record = ReadCheckpointRecord(xlogprefetcher, CheckPointLoc,
                                      CheckPointTLI);
        if (record != NULL)
        {
@@ -3843,13 +3843,10 @@ emode_for_corrupt_record(int emode, XLogRecPtr RecPtr)
 
 /*
  * Subroutine to try to fetch and validate a prior checkpoint record.
- *
- * whichChkpt identifies the checkpoint (merely for reporting purposes).
- * 1 for "primary", 0 for "other" (backup_label)
  */
 static XLogRecord *
 ReadCheckpointRecord(XLogPrefetcher *xlogprefetcher, XLogRecPtr RecPtr,
-                    int whichChkpt, bool report, TimeLineID replayTLI)
+                    TimeLineID replayTLI)
 {
    XLogRecord *record;
    uint8       info;
@@ -3858,20 +3855,8 @@ ReadCheckpointRecord(XLogPrefetcher *xlogprefetcher, XLogRecPtr RecPtr,
 
    if (!XRecOffIsValid(RecPtr))
    {
-       if (!report)
-           return NULL;
-
-       switch (whichChkpt)
-       {
-           case 1:
-               ereport(LOG,
-                       (errmsg("invalid primary checkpoint link in control file")));
-               break;
-           default:
-               ereport(LOG,
-                       (errmsg("invalid checkpoint link in backup_label file")));
-               break;
-       }
+       ereport(LOG,
+               (errmsg("invalid checkpoint location")));
        return NULL;
    }
 
@@ -3880,67 +3865,28 @@ ReadCheckpointRecord(XLogPrefetcher *xlogprefetcher, XLogRecPtr RecPtr,
 
    if (record == NULL)
    {
-       if (!report)
-           return NULL;
-
-       switch (whichChkpt)
-       {
-           case 1:
-               ereport(LOG,
-                       (errmsg("invalid primary checkpoint record")));
-               break;
-           default:
-               ereport(LOG,
-                       (errmsg("invalid checkpoint record")));
-               break;
-       }
+       ereport(LOG,
+               (errmsg("invalid checkpoint record")));
        return NULL;
    }
    if (record->xl_rmid != RM_XLOG_ID)
    {
-       switch (whichChkpt)
-       {
-           case 1:
-               ereport(LOG,
-                       (errmsg("invalid resource manager ID in primary checkpoint record")));
-               break;
-           default:
-               ereport(LOG,
-                       (errmsg("invalid resource manager ID in checkpoint record")));
-               break;
-       }
+       ereport(LOG,
+               (errmsg("invalid resource manager ID in checkpoint record")));
        return NULL;
    }
    info = record->xl_info & ~XLR_INFO_MASK;
    if (info != XLOG_CHECKPOINT_SHUTDOWN &&
        info != XLOG_CHECKPOINT_ONLINE)
    {
-       switch (whichChkpt)
-       {
-           case 1:
-               ereport(LOG,
-                       (errmsg("invalid xl_info in primary checkpoint record")));
-               break;
-           default:
-               ereport(LOG,
-                       (errmsg("invalid xl_info in checkpoint record")));
-               break;
-       }
+       ereport(LOG,
+               (errmsg("invalid xl_info in checkpoint record")));
        return NULL;
    }
    if (record->xl_tot_len != SizeOfXLogRecord + SizeOfXLogRecordDataHeaderShort + sizeof(CheckPoint))
    {
-       switch (whichChkpt)
-       {
-           case 1:
-               ereport(LOG,
-                       (errmsg("invalid length of primary checkpoint record")));
-               break;
-           default:
-               ereport(LOG,
-                       (errmsg("invalid length of checkpoint record")));
-               break;
-       }
+       ereport(LOG,
+               (errmsg("invalid length of checkpoint record")));
        return NULL;
    }
    return record;