Commitca758de

committed

Rewrite storing origin in prepared record

1 parent7fea40d commitca758deCopy full SHA for ca758de

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1276,6 +1276,7 @@ ParsePrepareRecord(uint8 info, char xlrec, xl_xact_parsed_prepare parsed)`
`1276`	`1276`
`1277`	`1277`	`parsed->origin_lsn=hdr->xl_origin.origin_lsn;`
`1278`	`1278`	`parsed->origin_timestamp=hdr->xl_origin.origin_timestamp;`
	`1279`	`+parsed->xinfo=hdr->xl_origin.origin_lsn!=InvalidXLogRecPtr ?XACT_XINFO_HAS_ORIGIN :0;`
`1279`	`1280`
`1280`	`1281`	`strncpy(parsed->twophase_gid,bufptr,hdr->gidlen);`
`1281`	`1282`	`bufptr+=MAXALIGN(hdr->gidlen);`
`@@ -1285,7 +1286,7 @@ ParsePrepareRecord(uint8 info, char xlrec, xl_xact_parsed_prepare parsed)`
`1285`	`1286`	`parsed->nsubxacts=hdr->nsubxacts;`
`1286`	`1287`	`parsed->nrels=hdr->ncommitrels;`
`1287`	`1288`	`parsed->nmsgs=hdr->ninvalmsgs;`
`1288`		`-`
	`1289`	`+`
`1289`	`1290`	`parsed->subxacts= (TransactionId*)bufptr;`
`1290`	`1291`	`bufptr+=MAXALIGN(hdr->nsubxacts*sizeof(TransactionId));`
`1291`	`1292`

Comments

(0)