Commitbae9b80

committed

Force synchronous commit in new-ish test_decoding test.

This was missed ina924c32 ff.

1 parent490e9a9 commitbae9b80Copy full SHA for bae9b80

File tree

-0

lines changed

-0

lines changed

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,5 @@`
	`1`	`+-- predictability`
	`2`	`+SET synchronous_commit = on;`
`1`	`3`	`SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_p', 'test_decoding');`
`2`	`4`	`?column?`
`3`	`5`	`----------`
`@@ -31,6 +33,7 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t2', 'tes`
`31`	`33`	`-- here we want to start a new session and wait till old one is gone`
`32`	`34`	`select pg_backend_pid() as oldpid \gset`
`33`	`35`	`\c -`
	`36`	`+SET synchronous_commit = on;`
`34`	`37`	`do 'declare c int = 0;`
`35`	`38`	`begin`
`36`	`39`	`while (select count(*) from pg_replication_slots where active_pid = '`

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,6 @@`
	`1`	`+-- predictability`
	`2`	`+SET synchronous_commit=on;`
	`3`	`+`
`1`	`4`	`SELECT'init'FROM pg_create_logical_replication_slot('regression_slot_p','test_decoding');`
`2`	`5`	`SELECT'init'FROM pg_create_logical_replication_slot('regression_slot_t','test_decoding', true);`
`3`	`6`
`@@ -9,6 +12,8 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot_t2', 'tes`
`9`	`12`	`-- here we want to start a new session and wait till old one is gone`
`10`	`13`	`select pg_backend_pid()as oldpid \gset`
`11`	`14`	`\c-`
	`15`	`+SET synchronous_commit=on;`
	`16`	`+`
`12`	`17`	`do'declare c int = 0;`
`13`	`18`	`begin`
`14`	`19`	`while (select count(*) from pg_replication_slots where active_pid ='`

Comments

(0)