Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit bae9b80

Browse files
committed
Force synchronous commit in new-ish test_decoding test.
This was missed in a924c32 ff.
1 parent 490e9a9 commit bae9b80

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

contrib/test_decoding/expected/slot.out

+3
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
-- predictability
2+
SET synchronous_commit = on;
13
SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_p', 'test_decoding');
24
?column?
35
----------
@@ -31,6 +33,7 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t2', 'tes
3133
-- here we want to start a new session and wait till old one is gone
3234
select pg_backend_pid() as oldpid \gset
3335
\c -
36+
SET synchronous_commit = on;
3437
do 'declare c int = 0;
3538
begin
3639
while (select count(*) from pg_replication_slots where active_pid = '

contrib/test_decoding/sql/slot.sql

+5
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
-- predictability
2+
SET synchronous_commit = on;
3+
14
SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_p', 'test_decoding');
25
SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t', 'test_decoding', true);
36

@@ -9,6 +12,8 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t2', 'tes
912
-- here we want to start a new session and wait till old one is gone
1013
select pg_backend_pid() as oldpid \gset
1114
\c -
15+
SET synchronous_commit = on;
16+
1217
do 'declare c int = 0;
1318
begin
1419
while (select count(*) from pg_replication_slots where active_pid = '

0 commit comments

Comments
 (0)