Commitb437b5e

authored and

committed

Fix bug in MtmFinishPreparedTransaction

1 parentbd4d9dc commitb437b5eCopy full SHA for b437b5e

File tree

-4

lines changed

-4

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -2802,14 +2802,14 @@ void MtmRollbackPreparedTransaction(char const* gid)`
`2802`	`2802`
`2803`	`2803`	`voidMtmFinishPreparedTransaction(MtmTransState*ts,boolcommit)`
`2804`	`2804`	`{`
`2805`		`-if (Mtm->nodes[MtmNodeId-1].originId==InvalidRepOriginId) {`
`2806`		`-/* This dummy origin is used for local commits/aborts which should not be replicated */`
`2807`		`-Mtm->nodes[MtmNodeId-1].originId=replorigin_create(psprintf(MULTIMASTER_SLOT_PATTERN,MtmNodeId));`
`2808`		`-}`
`2809`	`2805`	`Assert(ts->votingCompleted);`
`2810`	`2806`	`Assert(!IsTransactionState());`
`2811`	`2807`	`MtmResetTransaction();`
`2812`	`2808`	`StartTransactionCommand();`
	`2809`	`+if (Mtm->nodes[MtmNodeId-1].originId==InvalidRepOriginId) {`
	`2810`	`+/* This dummy origin is used for local commits/aborts which should not be replicated */`
	`2811`	`+Mtm->nodes[MtmNodeId-1].originId=replorigin_create(psprintf(MULTIMASTER_SLOT_PATTERN,MtmNodeId));`
	`2812`	`+}`
`2813`	`2813`	`MtmBeginSession(MtmNodeId);`
`2814`	`2814`	`MtmSetCurrentTransactionCSN(ts->csn);`
`2815`	`2815`	`MtmSetCurrentTransactionGID(ts->gid);`

Comments

(0)