diff options
| -rw-r--r-- | contrib/test_decoding/expected/slot.out | 3 | ||||
| -rw-r--r-- | contrib/test_decoding/sql/slot.sql | 5 |
2 files changed, 8 insertions, 0 deletions
diff --git a/contrib/test_decoding/expected/slot.out b/contrib/test_decoding/expected/slot.out index 6dee1436cca..9f5f8a9b766 100644 --- a/contrib/test_decoding/expected/slot.out +++ b/contrib/test_decoding/expected/slot.out @@ -1,3 +1,5 @@ +-- predictability +SET synchronous_commit = on; SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_p', 'test_decoding'); ?column? ---------- @@ -31,6 +33,7 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t2', 'tes -- here we want to start a new session and wait till old one is gone select pg_backend_pid() as oldpid \gset \c - +SET synchronous_commit = on; do 'declare c int = 0; begin while (select count(*) from pg_replication_slots where active_pid = ' diff --git a/contrib/test_decoding/sql/slot.sql b/contrib/test_decoding/sql/slot.sql index 7ca83feac5d..fa9561f54ea 100644 --- a/contrib/test_decoding/sql/slot.sql +++ b/contrib/test_decoding/sql/slot.sql @@ -1,3 +1,6 @@ +-- predictability +SET synchronous_commit = on; + SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_p', 'test_decoding'); SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t', 'test_decoding', true); @@ -9,6 +12,8 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t2', 'tes -- here we want to start a new session and wait till old one is gone select pg_backend_pid() as oldpid \gset \c - +SET synchronous_commit = on; + do 'declare c int = 0; begin while (select count(*) from pg_replication_slots where active_pid = ' |