Commit69d8dd9

authored and

committed

Fix sending commit of prepared transaction

1 parentb8c0a63 commit69d8dd9Copy full SHA for 69d8dd9

File tree

-6

lines changed

-6

lines changed

Lines changed: 1 addition & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -125,9 +125,6 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,`
`125`	`125`	`{`
`126`	`126`	`uint8flags=0;`
`127`	`127`
`128`		`-if (MtmIsFilteredTxn) {`
`129`		`-return;`
`130`		`-}`
`131`	`128`	`if (txn->xact_action==XLOG_XACT_COMMIT)`
`132`	`129`	`flags=PGLOGICAL_COMMIT;`
`133`	`130`	`elseif (txn->xact_action==XLOG_XACT_PREPARE)`
`@@ -139,9 +136,8 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,`
`139`	`136`	`else`
`140`	`137`	`Assert(false);`
`141`	`138`
`142`		`-#if0`
`143`	`139`	`if (flags==PGLOGICAL_COMMIT\|\|flags==PGLOGICAL_PREPARE) {`
`144`		`-if (mm->isLocal) {`
	`140`	`+if (MtmIsFilteredTxn) {`
`145`	`141`	`return;`
`146`	`142`	`}`
`147`	`143`	`}else {`
`@@ -151,7 +147,6 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,`
`151`	`147`	`return;`
`152`	`148`	`}`
`153`	`149`	`}`
`154`		`-#endif`
`155`	`150`
`156`	`151`	`pq_sendbyte(out,'C');/* sending COMMIT */`
`157`	`152`

Comments

(0)