postgrespro
diff --git a/‎t/001_wal.pl
Copy file name to clipboardExpand all lines: t/001_wal.pl
+2-2Lines changed: 2 additions & 2 deletions b/‎t/001_wal.pl
Copy file name to clipboardExpand all lines: t/001_wal.pl
+2-2Lines changed: 2 additions & 2 deletions
@@ -23,12 +23,12 @@ sub test_index_replay
 	if ($server_version < 100000)
 	{
 		$caughtup_query =
-			"SELECT pg_current_xlog_location() <= write_location FROM pg_stat_replication WHERE application_name = '$applname';";
+			"SELECT pg_current_xlog_location() <= replay_location FROM pg_stat_replication WHERE application_name = '$applname';";
 	}
 	else
 	{
 		$caughtup_query =
-			"SELECT pg_current_wal_lsn() <= write_lsn FROM pg_stat_replication WHERE application_name = '$applname';";
+			"SELECT pg_current_wal_lsn() <= replay_lsn FROM pg_stat_replication WHERE application_name = '$applname';";
 	}
 	$node_master->poll_query_until('postgres', $caughtup_query)
 	  or die "Timed out while waiting for standby 1 to catch up";
Original file line number	Diff line number	Diff line change
`@@ -23,12 +23,12 @@ sub test_index_replay`
`23`	`23`	`if ($server_version < 100000)`
`24`	`24`	`{`
`25`	`25`	`$caughtup_query =`
`26`		`- "SELECT pg_current_xlog_location() <= write_location FROM pg_stat_replication WHERE application_name = '$applname';";`
	`26`	`+ "SELECT pg_current_xlog_location() <= replay_location FROM pg_stat_replication WHERE application_name = '$applname';";`
`27`	`27`	`}`
`28`	`28`	`else`
`29`	`29`	`{`
`30`	`30`	`$caughtup_query =`
`31`		`- "SELECT pg_current_wal_lsn() <= write_lsn FROM pg_stat_replication WHERE application_name = '$applname';";`
	`31`	`+ "SELECT pg_current_wal_lsn() <= replay_lsn FROM pg_stat_replication WHERE application_name = '$applname';";`
`32`	`32`	`}`
`33`	`33`	`$node_master->poll_query_until('postgres', $caughtup_query)`
`34`	`34`	`or die "Timed out while waiting for standby 1 to catch up";`