NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commitf3a764b

committed

Set replication origin when decoding commit records.

By accident the replication origin was not set properly inDecodeCommit(). That's bad because the origin is passed to the outputplugins origin filter, and accessible from the output plugin viaReorderBufferTXN->origin_id. Accessing the origin of individual changesworked before the fix, which is why this wasn't notices earlier.Reported-By: Craig RingerAuthor: Craig RingerDiscussion: CAMsr+YFhBJLp=qfSz3-J+0P1zLkE8zNXM2otycn20QRMx380gw@mail.gmail.comBackpatch: 9.5, where replication origins where introduced

1 parentfed19f3 commitf3a764bCopy full SHA for f3a764b

File tree

1 file changed

-1

lines changed

src/backend/replication/logical
- decode.c

1 file changed

-1

lines changed

`‎src/backend/replication/logical/decode.c`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -450,7 +450,7 @@ DecodeCommit(LogicalDecodingContext ctx, XLogRecordBuffer buf,`
`450`	`450`	`{`
`451`	`451`	`XLogRecPtrorigin_lsn=InvalidXLogRecPtr;`
`452`	`452`	`XLogRecPtrcommit_time=InvalidXLogRecPtr;`
`453`		`-XLogRecPtrorigin_id=InvalidRepOriginId;`
	`453`	`+XLogRecPtrorigin_id=XLogRecGetOrigin(buf->record);`
`454`	`454`	`inti;`
`455`	`455`
`456`	`456`	`if (parsed->xinfo&XACT_XINFO_HAS_ORIGIN)`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitf3a764b

File tree

1 file changed

1 file changed

`‎src/backend/replication/logical/decode.c`

0 commit comments