|
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 |
|
|