prepare parser fixes

kelvich · kelvich · commit 41af69517050 · 2016-03-04T12:36:08.000+03:00
diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c
@@ -457,6 +457,9 @@ DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 		commit_time = parsed->origen_timestamp;
 	}
 
+	/*
+	 * If that is COMMIT PREPARED than send that to callbacks.
+	 */
 	if (TransactionIdIsValid(parsed->twophase_xid)) {
 		strcpy(ctx->reorder->gid, parsed->twophase_gid);
 		ReorderBufferCommitBareXact(ctx->reorder, xid, buf->origptr, buf->endptr,
@@ -548,13 +551,6 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf)
 	RelFileNode *abortrels;
 	SharedInvalidationMessage *invalmsgs;
 
-	// probably there are no origen -- origen stored in hdr
-	// if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)
-	// {
-	// 	origen_lsn = parsed->origen_lsn;
-	// 	commit_time = parsed->origen_timestamp;
-	// }
-
 	xid = XLogRecGetXid(r);
 	twophase_buf = XLogRecGetData(r);
 	twophase_len = sizeof(char) * XLogRecGetDataLen(r);
@@ -588,8 +584,8 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf)
 	SnapBuildCommitTxn(ctx->snapshot_builder, buf->origptr, xid,
 					   hdr->nsubxacts, children);
 
-	// Add db check here
 	if (SnapBuildXactNeedsSkip(ctx->snapshot_builder, buf->origptr) ||
+		(hdr->database != InvalidOid && hdr->database != ctx->slot->data.database) ||
 		FilterByOrigin(ctx, origen_id))
 	{
 		for (i = 0; i < hdr->nsubxacts; i++)
@@ -626,6 +622,9 @@ DecodeAbort(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
 	XLogRecPtr	commit_time = InvalidXLogRecPtr;
 	XLogRecPtr	origen_id = XLogRecGetOrigin(buf->record);
 
+	/*
+	 * If that is ROLLBACK PREPARED than send that to callbacks.
+	 */
 	if (TransactionIdIsValid(parsed->twophase_xid)) {
 		strcpy(ctx->reorder->gid, parsed->twophase_gid);
 		ReorderBufferCommitBareXact(ctx->reorder, xid, buf->origptr, buf->endptr,
