Commit1a23a45

committed

some fixes

1 parent270eee5 commit1a23a45Copy full SHA for 1a23a45

File tree

-8

lines changed

-8

lines changed

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1252,7 +1252,8 @@ ParsePrepareRecord(uint8 info, char xlrec, xl_xact_parsed_prepare parsed)`
`1252`	`1252`	`parsed->twophase_xid=hdr->xid;`
`1253`	`1253`	`parsed->dbId=hdr->database;`
`1254`	`1254`	`parsed->nsubxacts=hdr->nsubxacts;`
`1255`		`-parsed->nrels=hdr->ncommitrels;`
	`1255`	`+parsed->ncommitrels=hdr->ncommitrels;`
	`1256`	`+parsed->nabortrels=hdr->nabortrels;`
`1256`	`1257`	`parsed->nmsgs=hdr->ninvalmsgs;`
`1257`	`1258`
`1258`	`1259`	`strncpy(parsed->twophase_gid,bufptr,hdr->gidlen);`
`@@ -1261,10 +1262,10 @@ ParsePrepareRecord(uint8 info, char xlrec, xl_xact_parsed_prepare parsed)`
`1261`	`1262`	`parsed->subxacts= (TransactionId*)bufptr;`
`1262`	`1263`	`bufptr+=MAXALIGN(hdr->nsubxacts*sizeof(TransactionId));`
`1263`	`1264`
`1264`		`-parsed->xnodes= (RelFileNode*)bufptr;`
	`1265`	`+parsed->commitrels= (RelFileNode*)bufptr;`
`1265`	`1266`	`bufptr+=MAXALIGN(hdr->ncommitrels*sizeof(RelFileNode));`
`1266`	`1267`
`1267`		`-/* Ignoring abortrels? */`
	`1268`	`+parsed->abortrels= (RelFileNode*)bufptr;`
`1268`	`1269`	`bufptr+=MAXALIGN(hdr->nabortrels*sizeof(RelFileNode));`
`1269`	`1270`
`1270`	`1271`	`parsed->msgs= (SharedInvalidationMessage*)bufptr;`

Lines changed: 0 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -289,9 +289,6 @@ DecodeXactOp(LogicalDecodingContext ctx, XLogRecordBuffer buf)`
`289`	`289`	`DecodePrepare(ctx,buf,&parsed);`
`290`	`290`	`break;`
`291`	`291`	`}`
`292`		`-// XXX: do we really need to call that here?`
`293`		`-ReorderBufferProcessXid(reorder,XLogRecGetXid(r),buf->origptr);`
`294`		`-break;`
`295`	`292`	`default:`
`296`	`293`	`elog(ERROR,"unexpected RM_XACT_ID record type: %u",info);`
`297`	`294`	`}`

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -303,8 +303,11 @@ typedef struct xl_xact_parsed_prepare`
`303`	`303`	`intnsubxacts;`
`304`	`304`	`TransactionId*subxacts;`
`305`	`305`
`306`		`-intnrels;`
`307`		`-RelFileNode*xnodes;`
	`306`	`+intncommitrels;`
	`307`	`+RelFileNode*commitrels;`
	`308`	`+`
	`309`	`+intnabortrels;`
	`310`	`+RelFileNode*abortrels;`
`308`	`311`
`309`	`312`	`intnmsgs;`
`310`	`313`	`SharedInvalidationMessage*msgs;`

Comments

(0)