Abort active transactions if not is not online any more

knizhnik · knizhnik · commit 31d659a7ce67 · 2016-06-24T17:54:44.000+03:00
diff --git a/contrib/mmts/multimaster.c b/contrib/mmts/multimaster.c
@@ -840,7 +840,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)
 
 		timestamp_t start = MtmGetSystemTime();	
 		/* wait votes from all nodes */
-		while (!ts->votingCompleted && ts->status != TRANSACTION_STATUS_ABORTED && start + transTimeout >= MtmGetSystemTime()) 
+		while (!ts->votingCompleted && Mtm->status == MTM_ONLINE && ts->status != TRANSACTION_STATUS_ABORTED && start + transTimeout >= MtmGetSystemTime()) 
 		{
 			MtmUnlock();
 			result = WaitLatch(&MyProc->procLatch, WL_LATCH_SET|WL_TIMEOUT, MtmHeartbeatRecvTimeout);

Original file line number	Diff line number	Diff line change
`@@ -840,7 +840,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`840`	`840`
`841`	`841`	`timestamp_t start = MtmGetSystemTime();`
`842`	`842`	`/* wait votes from all nodes */`
`843`		`- while (!ts->votingCompleted && ts->status != TRANSACTION_STATUS_ABORTED && start + transTimeout >= MtmGetSystemTime())`
	`843`	`+ while (!ts->votingCompleted && Mtm->status == MTM_ONLINE && ts->status != TRANSACTION_STATUS_ABORTED && start + transTimeout >= MtmGetSystemTime())`
`844`	`844`	`{`
`845`	`845`	`MtmUnlock();`
`846`	`846`	`result = WaitLatch(&MyProc->procLatch, WL_LATCH_SET\|WL_TIMEOUT, MtmHeartbeatRecvTimeout);`