diff options
| author | Simon Riggs <simon@2ndQuadrant.com> | 2017-09-01 14:55:44 +0100 |
|---|---|---|
| committer | Simon Riggs <simon@2ndQuadrant.com> | 2017-09-01 14:55:44 +0100 |
| commit | 4f27c674fd9fb5ba1f2952e2db53886bb5954e8b (patch) | |
| tree | 2106cb7a1a6d8323b02015bfe603ff7fe598476c /src | |
| parent | be7161566db247fd519e1a888ea8cd36b3c72088 (diff) | |
| download | postgresql-4f27c674fd9fb5ba1f2952e2db53886bb5954e8b.tar.gz postgresql-4f27c674fd9fb5ba1f2952e2db53886bb5954e8b.zip | |
Avoid race condition in logical replication test
Wait for slot to become inactive before continuing.
Author: Petr Jelinek
Diffstat (limited to 'src')
| -rw-r--r-- | src/test/recovery/t/006_logical_decoding.pl | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/test/recovery/t/006_logical_decoding.pl b/src/test/recovery/t/006_logical_decoding.pl index 4a90e9ac7e2..8b35bc84381 100644 --- a/src/test/recovery/t/006_logical_decoding.pl +++ b/src/test/recovery/t/006_logical_decoding.pl @@ -78,6 +78,11 @@ chomp($stdout_recv); is($stdout_recv, $expected, 'got same expected output from pg_recvlogical decoding session'); +$node_master->poll_query_until('postgres', +"SELECT EXISTS (SELECT 1 FROM pg_replication_slots WHERE slot_name = 'test_slot' AND active_pid IS NULL)" +) + or die "slot never became inactive"; + $stdout_recv = $node_master->pg_recvlogical_upto( 'postgres', 'test_slot', $endpos, 10, 'include-xids' => '0', |