Commit392ddde

committed

Allow precommit to be sent in workers pool when preserve_commit_order=false

1 parent515af13 commit392dddeCopy full SHA for 392ddde

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -576,7 +576,8 @@ pglogical_receiver_main(Datum main_arg)`
`576`	`576`	`elog(WARNING,"Commit of prepared transaction takes %lld usec, flags=%x",stop-start,stmt[1]);`
`577`	`577`	`}`
`578`	`578`	`}else {`
`579`		`-Assert(stmt[1]==PGLOGICAL_PREPARE\|\|stmt[1]==PGLOGICAL_COMMIT);/* all other commits should be applied in place */`
	`579`	`+/* all other commits should be applied in place */`
	`580`	`+Assert(stmt[1]==PGLOGICAL_PREPARE\|\|stmt[1]==PGLOGICAL_COMMIT\|\|stmt[1]==PGLOGICAL_PRECOMMIT_PREPARED);`
`580`	`581`	`MtmExecute(buf.data,buf.used);`
`581`	`582`	`}`
`582`	`583`	`}`

Comments

(0)