diff options
Diffstat (limited to 'src/bin/pg_rewind/t')
| -rw-r--r-- | src/bin/pg_rewind/t/007_standby_source.pl | 8 | ||||
| -rw-r--r-- | src/bin/pg_rewind/t/008_min_recovery_point.pl | 6 |
2 files changed, 5 insertions, 9 deletions
diff --git a/src/bin/pg_rewind/t/007_standby_source.pl b/src/bin/pg_rewind/t/007_standby_source.pl index 62254344f68..df2e72912b4 100644 --- a/src/bin/pg_rewind/t/007_standby_source.pl +++ b/src/bin/pg_rewind/t/007_standby_source.pl @@ -74,7 +74,7 @@ $node_a->safe_psql('postgres', "INSERT INTO tbl1 values ('in A, before promotion')"); $node_a->safe_psql('postgres', 'CHECKPOINT'); -my $lsn = $node_a->lsn('insert'); +my $lsn = $node_a->lsn('write'); $node_a->wait_for_catchup('node_b', 'write', $lsn); $node_b->wait_for_catchup('node_c', 'write', $lsn); @@ -93,8 +93,7 @@ $node_a->safe_psql('postgres', "INSERT INTO tbl1 VALUES ('in A, after C was promoted')"); # make sure it's replicated to B before we continue -$lsn = $node_a->lsn('insert'); -$node_a->wait_for_catchup('node_b', 'replay', $lsn); +$node_a->wait_for_catchup('node_b'); # Also insert a new row in the standby, which won't be present in the # old primary. @@ -161,8 +160,7 @@ in A, after C was promoted $node_a->safe_psql('postgres', "INSERT INTO tbl1 values ('in A, after rewind')"); -$lsn = $node_a->lsn('insert'); -$node_b->wait_for_catchup('node_c', 'replay', $lsn); +$node_b->wait_for_catchup('node_c', 'replay', $node_a->lsn('write')); check_query( 'SELECT * FROM tbl1', diff --git a/src/bin/pg_rewind/t/008_min_recovery_point.pl b/src/bin/pg_rewind/t/008_min_recovery_point.pl index 9ad7e6b62bb..8240229230d 100644 --- a/src/bin/pg_rewind/t/008_min_recovery_point.pl +++ b/src/bin/pg_rewind/t/008_min_recovery_point.pl @@ -69,8 +69,7 @@ $node_3->init_from_backup($node_1, $backup_name, has_streaming => 1); $node_3->start; # Wait until node 3 has connected and caught up -my $lsn = $node_1->lsn('insert'); -$node_1->wait_for_catchup('node_3', 'replay', $lsn); +$node_1->wait_for_catchup('node_3'); # # Swap the roles of node_1 and node_3, so that node_1 follows node_3. @@ -106,8 +105,7 @@ $node_2->restart(); # # make sure node_1 is full caught up with node_3 first -$lsn = $node_3->lsn('insert'); -$node_3->wait_for_catchup('node_1', 'replay', $lsn); +$node_3->wait_for_catchup('node_1'); $node_1->promote; # Force a checkpoint after promotion, like earlier. |