Remove temporary WAL and history files at the end of archive recovery
authorMichael Paquier <michael@paquier.xyz>
Wed, 2 Oct 2019 06:53:07 +0000 (15:53 +0900)
committerMichael Paquier <michael@paquier.xyz>
Wed, 2 Oct 2019 06:53:07 +0000 (15:53 +0900)
cbc55da has reworked the order of some actions at the end of archive
recovery.  Unfortunately this overlooked the fact that the startup
process needs to remove RECOVERYXLOG (for temporary WAL segment newly
recovered from archives) and RECOVERYHISTORY (for temporary history
file) at this step, leaving the files around even after recovery ended.

Backpatch to 9.5, like the previous commit.

Author: Sawada Masahiko
Reviewed-by: Fujii Masao, Michael Paquier
Discussion: https://postgr.es/m/CAD21AoBO_eDQub6zojFnWtnmutRBWvYf7=cW4Hsqj+U_R26w3Q@mail.gmail.com
Backpatch-through: 9.5

src/backend/access/transam/xlog.c
src/test/recovery/t/002_archiving.pl

index 61ba6b852e6623f3065cfc0404a88605ed2d3fea..790e2c8714dce062079f162189a41cc3758b758b 100644 (file)
@@ -5461,7 +5461,6 @@ validateRecoveryParameters(void)
 static void
 exitArchiveRecovery(TimeLineID endTLI, XLogRecPtr endOfLog)
 {
-   char        recoveryPath[MAXPGPATH];
    char        xlogfname[MAXFNAMELEN];
    XLogSegNo   endLogSegNo;
    XLogSegNo   startLogSegNo;
@@ -5541,17 +5540,6 @@ exitArchiveRecovery(TimeLineID endTLI, XLogRecPtr endOfLog)
    XLogFileName(xlogfname, ThisTimeLineID, startLogSegNo, wal_segment_size);
    XLogArchiveCleanup(xlogfname);
 
-   /*
-    * Since there might be a partial WAL segment named RECOVERYXLOG, get rid
-    * of it.
-    */
-   snprintf(recoveryPath, MAXPGPATH, XLOGDIR "/RECOVERYXLOG");
-   unlink(recoveryPath);       /* ignore any error */
-
-   /* Get rid of any remaining recovered timeline-history file, too */
-   snprintf(recoveryPath, MAXPGPATH, XLOGDIR "/RECOVERYHISTORY");
-   unlink(recoveryPath);       /* ignore any error */
-
    /*
     * Remove the signal files out of the way, so that we don't accidentally
     * re-enter archive recovery mode in a subsequent crash.
@@ -7433,6 +7421,7 @@ StartupXLOG(void)
    if (ArchiveRecoveryRequested)
    {
        char        reason[200];
+       char        recoveryPath[MAXPGPATH];
 
        Assert(InArchiveRecovery);
 
@@ -7489,6 +7478,17 @@ StartupXLOG(void)
         */
        writeTimeLineHistory(ThisTimeLineID, recoveryTargetTLI,
                             EndRecPtr, reason);
+
+       /*
+        * Since there might be a partial WAL segment named RECOVERYXLOG, get
+        * rid of it.
+        */
+       snprintf(recoveryPath, MAXPGPATH, XLOGDIR "/RECOVERYXLOG");
+       unlink(recoveryPath);   /* ignore any error */
+
+       /* Get rid of any remaining recovered timeline-history file, too */
+       snprintf(recoveryPath, MAXPGPATH, XLOGDIR "/RECOVERYHISTORY");
+       unlink(recoveryPath);   /* ignore any error */
    }
 
    /* Save the selected TimeLineID in shared memory, too */
index e1bd3c95cca26db51793020c8d9da917bbca36c6..683c33b5100083ee50555191cedcba63de545a90 100644 (file)
@@ -3,7 +3,7 @@ use strict;
 use warnings;
 use PostgresNode;
 use TestLib;
-use Test::More tests => 1;
+use Test::More tests => 3;
 use File::Copy;
 
 # Initialize master node, doing archives
@@ -49,3 +49,26 @@ $node_standby->poll_query_until('postgres', $caughtup_query)
 my $result =
   $node_standby->safe_psql('postgres', "SELECT count(*) FROM tab_int");
 is($result, qq(1000), 'check content from archives');
+
+# Check the presence of temporary files specifically generated during
+# archive recovery.  To ensure the presence of the temporary history
+# file, switch to a timeline large enough to allow a standby to recover
+# a history file from an archive.  As this requires at least two timeline
+# switches, promote the existing standby first.  Then create a second
+# standby based on the promoted one.  Finally, the second standby is
+# promoted.
+$node_standby->promote;
+
+my $node_standby2 = get_new_node('standby2');
+$node_standby2->init_from_backup($node_master, $backup_name,
+   has_restoring => 1);
+$node_standby2->start;
+
+# Now promote standby2, and check that temporary files specifically
+# generated during archive recovery are removed by the end of recovery.
+$node_standby2->promote;
+my $node_standby2_data = $node_standby2->data_dir;
+ok( !-f "$node_standby2_data/pg_wal/RECOVERYHISTORY",
+   "RECOVERYHISTORY removed after promotion");
+ok( !-f "$node_standby2_data/pg_wal/RECOVERYXLOG",
+   "RECOVERYXLOG removed after promotion");