We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see ourdocumentation.
There was an error while loading.Please reload this page.
1 parentb4e31d3 commitf8617e2Copy full SHA for f8617e2
src/backend/replication/logical/decode.c
@@ -545,6 +545,7 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
545
XLogRecPtrorigin_id=XLogRecGetOrigin(buf->record);
546
inti;
547
TransactionIdxid=parsed->twophase_xid;
548
+strcpy(ctx->reorder->gid,parsed->twophase_gid);
549
550
/*
551
* Process invalidation messages, even if we're not interested in the
@@ -561,8 +562,6 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
561
562
SnapBuildCommitTxn(ctx->snapshot_builder,buf->origptr,xid,
563
parsed->nsubxacts,parsed->subxacts);
564
-
565
566
if (SnapBuildXactNeedsSkip(ctx->snapshot_builder,buf->origptr)||
567
(parsed->dbId!=InvalidOid&&parsed->dbId!=ctx->slot->data.database)||
568
FilterByOrigin(ctx,origin_id))