Skip to content

Commit ca758de

Browse files
committed
Rewrite storing origin in prepared record
1 parent 7fea40d commit ca758de

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/backend/access/transam/twophase.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1276,6 +1276,7 @@ ParsePrepareRecord(uint8 info, char *xlrec, xl_xact_parsed_prepare *parsed)
12761276

12771277
parsed->origin_lsn = hdr->xl_origin.origin_lsn;
12781278
parsed->origin_timestamp = hdr->xl_origin.origin_timestamp;
1279+
parsed->xinfo = hdr->xl_origin.origin_lsn != InvalidXLogRecPtr ? XACT_XINFO_HAS_ORIGIN : 0;
12791280

12801281
strncpy(parsed->twophase_gid, bufptr, hdr->gidlen);
12811282
bufptr += MAXALIGN(hdr->gidlen);
@@ -1285,7 +1286,7 @@ ParsePrepareRecord(uint8 info, char *xlrec, xl_xact_parsed_prepare *parsed)
12851286
parsed->nsubxacts = hdr->nsubxacts;
12861287
parsed->nrels = hdr->ncommitrels;
12871288
parsed->nmsgs = hdr->ninvalmsgs;
1288-
1289+
12891290
parsed->subxacts = (TransactionId *) bufptr;
12901291
bufptr += MAXALIGN(hdr->nsubxacts * sizeof(TransactionId));
12911292

0 commit comments

Comments
 (0)