Commitc5c69c1

committed

Always pass origin_lsn to rbtxn in DecodePrepare.

twophase.c forgets to set XACT_INFO_HAS_ORIGIN flag in prepare record, sowithout that origin_lsn is lost.

1 parent30d248b commitc5c69c1Copy full SHA for c5c69c1

File tree

-3

lines changed

-3

lines changed

Lines changed: 2 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -705,9 +705,9 @@ static void`
`705`	`705`	`DecodePrepare(LogicalDecodingContextctx,XLogRecordBufferbuf,`
`706`	`706`	`xl_xact_parsed_prepare*parsed)`
`707`	`707`	`{`
`708`		`-XLogRecPtrorigin_lsn=InvalidXLogRecPtr;`
	`708`	`+XLogRecPtrorigin_lsn=parsed->origin_lsn;`
`709`	`709`	`TimestampTzcommit_time=parsed->xact_time;`
`710`		`-XLogRecPtrorigin_id=XLogRecGetOrigin(buf->record);`
	`710`	`+RepOriginIdorigin_id=XLogRecGetOrigin(buf->record);`
`711`	`711`	`inti;`
`712`	`712`	`TransactionIdxid=parsed->twophase_xid;`
`713`	`713`	`constchar*gid=parsed->twophase_gid;`
`@@ -716,7 +716,6 @@ DecodePrepare(LogicalDecodingContext ctx, XLogRecordBuffer buf,`
`716`	`716`
`717`	`717`	`if (parsed->xinfo&XACT_XINFO_HAS_ORIGIN)`
`718`	`718`	`{`
`719`		`-origin_lsn=parsed->origin_lsn;`
`720`	`719`	`commit_time=parsed->origin_timestamp;`
`721`	`720`	`}`
`722`	`721`

Comments

(0)