diff --git a/src/test/recovery/t/001_stream_rep.pl b/src/test/recovery/t/001_stream_rep.pl index 15ace5f51c..3590516425 100644 --- a/src/test/recovery/t/001_stream_rep.pl +++ b/src/test/recovery/t/001_stream_rep.pl @@ -220,9 +220,9 @@ 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'); -($xmin, $catalog_xmin) = get_slot_xmins($node_standby_1, $slotname_2); -isnt($xmin, '', 'xmin of cascaded slot non-null with hs feedback'); -is($catalog_xmin, '', 'catalog xmin of cascaded slot still null with hs_feedback'); +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'); note "doing some work to advance xmin"; $node_master->safe_psql('postgres', q{ @@ -245,16 +245,16 @@ $node_master->safe_psql('postgres', 'CHECKPOINT;'); wait_slot_xmins($node_master, $slotname_1, "xmin <> '$xmin'"); my ($xmin2, $catalog_xmin2) = get_slot_xmins($node_master, $slotname_1); -note "new xmin $xmin2, old xmin $xmin"; +note "master slot's new xmin $xmin2, old xmin $xmin"; isnt($xmin2, $xmin, 'xmin of non-cascaded slot with hs feedback has changed'); is($catalog_xmin2, '', 'catalog xmin of non-cascaded slot still null with hs_feedback unchanged'); -wait_slot_xmins($node_standby_1, $slotname_2, "xmin <> '$xmin'"); +wait_slot_xmins($node_standby_1, $slotname_2, "xmin <> '$xmin1'"); ($xmin2, $catalog_xmin2) = get_slot_xmins($node_standby_1, $slotname_2); -note "new xmin $xmin2, old xmin $xmin"; -isnt($xmin2, $xmin, 'xmin of cascaded slot with hs feedback has changed'); +note "standby_1 slot's new xmin $xmin2, old xmin $xmin1"; +isnt($xmin2, $xmin1, 'xmin of cascaded slot with hs feedback has changed'); is($catalog_xmin2, '', 'catalog xmin of cascaded slot still null with hs_feedback unchanged');