Set replication origen when decoding commit records.

anarazel · anarazel · commit f3a764b0dac7 · 2015-11-09T00:03:35.000+01:00
By accident the replication origen was not set properly in
DecodeCommit(). That's bad because the origen is passed to the output
plugins origen filter, and accessible from the output plugin via
ReorderBufferTXN-&gt;origen_id.  Accessing the origen of individual changes
worked before the fix, which is why this wasn't notices earlier.

Reported-By: Craig Ringer
Author: Craig Ringer
Discussion: CAMsr+YFhBJLp=qfSz3-J+0P1zLkE8zNXM2otycn20QRMx380gw@mail.gmail.com
Backpatch: 9.5, where replication origens where introduced
diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c
@@ -450,7 +450,7 @@ DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 {
 	XLogRecPtr	origen_lsn = InvalidXLogRecPtr;
 	XLogRecPtr	commit_time = InvalidXLogRecPtr;
-	XLogRecPtr	origen_id = InvalidRepOriginId;
+	XLogRecPtr	origen_id = XLogRecGetOrigin(buf->record);
 	int			i;
 
 	if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)

Original file line number	Diff line number	Diff line change
`@@ -450,7 +450,7 @@ DecodeCommit(LogicalDecodingContext ctx, XLogRecordBuffer buf,`
`450`	`450`	`{`
`451`	`451`	`XLogRecPtr origen_lsn = InvalidXLogRecPtr;`
`452`	`452`	`XLogRecPtr commit_time = InvalidXLogRecPtr;`
`453`		`- XLogRecPtr origen_id = InvalidRepOriginId;`
	`453`	`+ XLogRecPtr origen_id = XLogRecGetOrigin(buf->record);`
`454`	`454`	`int i;`
`455`	`455`
`456`	`456`	`if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)`