Abort active transactions if not is not online any more

knizhnik · kelvich · commit cbe3845ab1ec · 2017-11-13T00:17:09.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -839,7 +839,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
`@@ -839,7 +839,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`839`	`839`
`840`	`840`	`timestamp_t start = MtmGetSystemTime();`
`841`	`841`	`/* wait votes from all nodes */`
`842`		`- while (!ts->votingCompleted && ts->status != TRANSACTION_STATUS_ABORTED && start + transTimeout >= MtmGetSystemTime())`
	`842`	`+ while (!ts->votingCompleted && Mtm->status == MTM_ONLINE && ts->status != TRANSACTION_STATUS_ABORTED && start + transTimeout >= MtmGetSystemTime())`
`843`	`843`	`{`
`844`	`844`	`MtmUnlock();`
`845`	`845`	`result = WaitLatch(&MyProc->procLatch, WL_LATCH_SET\|WL_TIMEOUT, MtmHeartbeatRecvTimeout);`