diff options
| -rw-r--r-- | src/test/recovery/t/001_stream_rep.pl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/test/recovery/t/001_stream_rep.pl b/src/test/recovery/t/001_stream_rep.pl index 35905164256..840af66f756 100644 --- a/src/test/recovery/t/001_stream_rep.pl +++ b/src/test/recovery/t/001_stream_rep.pl @@ -220,9 +220,13 @@ isnt($xmin, '', 'xmin of non-cascaded slot non-null with hs feedback'); is($catalog_xmin, '', 'catalog xmin of non-cascaded slot still null with hs_feedback'); +wait_slot_xmins($node_standby_1, $slotname_2, + "xmin IS NOT NULL AND catalog_xmin IS NULL"); + my ($xmin1, $catalog_xmin1) = get_slot_xmins($node_standby_1, $slotname_2); isnt($xmin1, '', 'xmin of cascaded slot non-null with hs feedback'); -is($catalog_xmin1, '', 'catalog xmin of cascaded slot still null with hs_feedback'); +is($catalog_xmin1, '', + 'catalog xmin of cascaded slot still null with hs_feedback'); note "doing some work to advance xmin"; $node_master->safe_psql('postgres', q{ @@ -297,6 +301,8 @@ $node_standby_2->safe_psql('postgres', 'ALTER SYSTEM SET hot_standby_feedback = off;'); $node_standby_2->stop; +wait_slot_xmins($node_standby_1, $slotname_2, "xmin IS NOT NULL"); + ($xmin, $catalog_xmin) = get_slot_xmins($node_standby_1, $slotname_2); isnt($xmin, '', 'xmin of cascaded slot non-null with postgres shut down'); |