Rollback all prepared transaction

knizhnik · kelvich · commit 79a860019e36 · 2017-11-13T02:17:29.000+03:00
diff --git a/arbiter.c b/arbiter.c
@@ -473,6 +473,7 @@ static int MtmConnectSocket(int node, int port, int timeout)
 	if (BIT_CHECK(resp.disabledNodeMask, MtmNodeId-1)) { 
 		elog(WARNING, "Node %d thinks that I was dead", resp.node);
 		BIT_SET(Mtm->disabledNodeMask, MtmNodeId-1);
+		MtmRollbackAllPreparedTransactions();
 		MtmSwitchClusterMode(MTM_RECOVERY);
 	}
 	MtmUnlock();
diff --git a/multimaster.c b/multimaster.c
@@ -1043,6 +1043,11 @@ void MtmJoinTransaction(GlobalTransactionId* gtid, csn_t globalSnapshot)
 	}
 }
 
+void MtmRollbackAllPreparedTransactions(void)
+{
+}
+
+
 void  MtmSetCurrentTransactionGID(char const* gid)
 {
 	MTM_LOG3("Set current transaction xid=%d GID %s", MtmTx.xid, gid);
diff --git a/multimaster.h b/multimaster.h
@@ -281,6 +281,7 @@ extern void  MtmUpdateLsnMapping(int nodeId, XLogRecPtr endLsn);
 extern XLogRecPtr MtmGetFlushPosition(int nodeId);
 extern void MtmWatchdog(void);
 extern void MtmCheckHeartbeat(void);
+extern void MtmRollbackAllPreparedTransactions(void);
 
 
 

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();`
Original file line number	Diff line number	Diff line change
`@@ -1043,6 +1043,11 @@ void MtmJoinTransaction(GlobalTransactionId* gtid, csn_t globalSnapshot)`
`1043`	`1043`	`}`
`1044`	`1044`	`}`
`1045`	`1045`
	`1046`	`+void MtmRollbackAllPreparedTransactions(void)`
	`1047`	`+{`
	`1048`	`+}`
	`1049`	`+`
	`1050`	`+`
`1046`	`1051`	`void MtmSetCurrentTransactionGID(char const* gid)`
`1047`	`1052`	`{`
`1048`	`1053`	`MTM_LOG3("Set current transaction xid=%d GID %s", MtmTx.xid, gid);`