Commita961955

committed

Rollback all prepared transaction

1 parent516a531 commita961955Copy full SHA for a961955

File tree

-0

lines changed

-0

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -473,6 +473,7 @@ static int MtmConnectSocket(int node, int port, int timeout)`
`473`	`473`	`if (BIT_CHECK(resp.disabledNodeMask,MtmNodeId-1)) {`
`474`	`474`	`elog(WARNING,"Node %d thinks that I was dead",resp.node);`
`475`	`475`	`BIT_SET(Mtm->disabledNodeMask,MtmNodeId-1);`
	`476`	`+MtmRollbackAllPreparedTransactions();`
`476`	`477`	`MtmSwitchClusterMode(MTM_RECOVERY);`
`477`	`478`	`}`
`478`	`479`	`MtmUnlock();`

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1044,6 +1044,11 @@ void MtmJoinTransaction(GlobalTransactionId* gtid, csn_t globalSnapshot)`
`1044`	`1044`	`}`
`1045`	`1045`	`}`
`1046`	`1046`
	`1047`	`+voidMtmRollbackAllPreparedTransactions(void)`
	`1048`	`+{`
	`1049`	`+}`
	`1050`	`+`
	`1051`	`+`
`1047`	`1052`	`voidMtmSetCurrentTransactionGID(charconst*gid)`
`1048`	`1053`	`{`
`1049`	`1054`	`MTM_LOG3("Set current transaction xid=%d GID %s",MtmTx.xid,gid);`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -281,6 +281,7 @@ extern void MtmUpdateLsnMapping(int nodeId, XLogRecPtr endLsn);`
`281`	`281`	`externXLogRecPtrMtmGetFlushPosition(intnodeId);`
`282`	`282`	`externvoidMtmWatchdog(void);`
`283`	`283`	`externvoidMtmCheckHeartbeat(void);`
	`284`	`+externvoidMtmRollbackAllPreparedTransactions(void);`
`284`	`285`
`285`	`286`
`286`	`287`

Comments

(0)