|
38 | 38 | my$applname_1 =$node_standby_1->name;
|
39 | 39 | my$applname_2 =$node_standby_2->name;
|
40 | 40 | my$caughtup_query =
|
41 |
| -"SELECT pg_current_xlog_location() = write_location FROM pg_stat_replication WHERE application_name = '$applname_1';"; |
| 41 | +"SELECT pg_current_xlog_location()<= write_location FROM pg_stat_replication WHERE application_name = '$applname_1';"; |
42 | 42 | $node_master->poll_query_until('postgres',$caughtup_query)
|
43 | 43 | ordie"Timed out while waiting for standby 1 to catch up";
|
44 | 44 | $caughtup_query =
|
45 |
| -"SELECT pg_last_xlog_replay_location() = write_location FROM pg_stat_replication WHERE application_name = '$applname_2';"; |
| 45 | +"SELECT pg_last_xlog_replay_location()<= write_location FROM pg_stat_replication WHERE application_name = '$applname_2';"; |
46 | 46 | $node_standby_1->poll_query_until('postgres',$caughtup_query)
|
47 | 47 | ordie"Timed out while waiting for standby 2 to catch up";
|
48 | 48 |
|
|