blob: b143bc4e1d4e72d235df3b7a8c1288cec1ea229d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
# Copyright (c) 2024-2025, PostgreSQL Global Development Group
# Test restartpoints during archive recovery.
use strict;
use warnings;
use PostgreSQL::Test::Cluster;
use PostgreSQL::Test::Utils;
use Test::More;
my $archive_max_mb = 320;
my $wal_segsize = 1;
# Initialize primary node
my $node_primary = PostgreSQL::Test::Cluster->new('primary');
$node_primary->init(
has_archiving => 1,
allows_streaming => 1,
extra => [ '--wal-segsize' => $wal_segsize ]);
$node_primary->start;
my $backup_name = 'my_backup';
$node_primary->backup($backup_name);
$node_primary->safe_psql('postgres',
('DO $$BEGIN FOR i IN 1..' . $archive_max_mb / $wal_segsize)
. ' LOOP CHECKPOINT; PERFORM pg_switch_wal(); END LOOP; END$$;');
# Force archiving of WAL file containing recovery target
my $until_lsn = $node_primary->lsn('write');
$node_primary->safe_psql('postgres', "SELECT pg_switch_wal()");
$node_primary->stop;
# Archive recovery
my $node_restore = PostgreSQL::Test::Cluster->new('restore');
$node_restore->init_from_backup($node_primary, $backup_name,
has_restoring => 1);
$node_restore->append_conf('postgresql.conf',
"recovery_target_lsn = '$until_lsn'");
$node_restore->append_conf('postgresql.conf',
'recovery_target_action = pause');
$node_restore->append_conf('postgresql.conf',
'max_wal_size = ' . 2 * $wal_segsize);
$node_restore->append_conf('postgresql.conf', 'log_checkpoints = on');
$node_restore->start;
# Wait until restore has replayed enough data
my $caughtup_query =
"SELECT '$until_lsn'::pg_lsn <= pg_last_wal_replay_lsn()";
$node_restore->poll_query_until('postgres', $caughtup_query)
or die "Timed out while waiting for restore to catch up";
$node_restore->stop;
ok(1, 'restore caught up');
done_testing();
|
