Commit1801ced

committed

origin info in commit messages

1 parent9189353 commit1801cedCopy full SHA for 1801ced

File tree

+14

-2

lines changed

+14

-2

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -48,6 +48,6 @@ DROP TABLE test_prepared2;`
`48`	`48`	`SELECT dataFROM pg_logical_slot_peek_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1');`
`49`	`49`
`50`	`50`	`-- same but with twophase decoding`
`51`		`-SELECT dataFROM pg_logical_slot_peek_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1','twophase-decoding','1');`
	`51`	`+SELECT dataFROM pg_logical_slot_peek_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1','twophase-decoding','1');`
`52`	`52`
`53`	`53`	`SELECT pg_drop_replication_slot('regression_slot');`

Lines changed: 13 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -651,6 +651,12 @@ DecodePrepare(LogicalDecodingContext ctx, XLogRecordBuffer buf,`
`651`	`651`	`inti;`
`652`	`652`	`TransactionIdxid=parsed->twophase_xid;`
`653`	`653`
	`654`	`+if (parsed->xinfo&XACT_XINFO_HAS_ORIGIN)`
	`655`	`+{`
	`656`	`+origin_lsn=parsed->origin_lsn;`
	`657`	`+commit_time=parsed->origin_timestamp;`
	`658`	`+}`
	`659`	`+`
`654`	`660`	`/*`
`655`	`661`	`* Process invalidation messages, even if we're not interested in the`
`656`	`662`	`* transaction's contents, since the various caches need to always be`
`@@ -703,9 +709,15 @@ DecodeAbort(LogicalDecodingContext ctx, XLogRecordBuffer buf,`
`703`	`709`	`{`
`704`	`710`	`inti;`
`705`	`711`	`XLogRecPtrorigin_lsn=InvalidXLogRecPtr;`
`706`		`-XLogRecPtrcommit_time=InvalidXLogRecPtr;`
	`712`	`+TimestampTzcommit_time=0;`
`707`	`713`	`XLogRecPtrorigin_id=XLogRecGetOrigin(buf->record);`
`708`	`714`
	`715`	`+if (parsed->xinfo&XACT_XINFO_HAS_ORIGIN)`
	`716`	`+{`
	`717`	`+origin_lsn=parsed->origin_lsn;`
	`718`	`+commit_time=parsed->origin_timestamp;`
	`719`	`+}`
	`720`	`+`
`709`	`721`	`/*`
`710`	`722`	`* If that is ROLLBACK PREPARED than send that to callbacks.`
`711`	`723`	`*/`

Comments

(0)