fix 2pc decoding: match snapbuilder logic for DecodePrepare and DecodeCommit

kelvich · kelvich · commit 105010670352 · 2018-02-09T17:25:46.000+03:00
diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c
@@ -673,6 +673,9 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 		ReorderBufferXidSetCatalogChanges(ctx->reorder, xid, buf->origptr);
 	}
 
+	SnapBuildCommitTxn(ctx->snapshot_builder, buf->origptr, xid,
+					   parsed->nsubxacts, parsed->subxacts);
+
 	if (SnapBuildXactNeedsSkip(ctx->snapshot_builder, buf->origptr) ||
 		(parsed->dbId != InvalidOid && parsed->dbId != ctx->slot->data.database) ||
 		FilterByOrigin(ctx, origin_id))

Original file line number	Diff line number	Diff line change
`@@ -673,6 +673,9 @@ DecodePrepare(LogicalDecodingContext ctx, XLogRecordBuffer buf,`
`673`	`673`	`ReorderBufferXidSetCatalogChanges(ctx->reorder, xid, buf->origptr);`
`674`	`674`	`}`
`675`	`675`
	`676`	`+ SnapBuildCommitTxn(ctx->snapshot_builder, buf->origptr, xid,`
	`677`	`+ parsed->nsubxacts, parsed->subxacts);`
	`678`	`+`
`676`	`679`	`if (SnapBuildXactNeedsSkip(ctx->snapshot_builder, buf->origptr) \|\|`
`677`	`680`	`(parsed->dbId != InvalidOid && parsed->dbId != ctx->slot->data.database) \|\|`
`678`	`681`	`FilterByOrigin(ctx, origin_id))`