@@ -835,7 +835,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)
835835MtmUnlock ();
836836MtmResetTransaction (x );
837837}else {
838- time_t transTimeout = Max (MSEC_TO_USEC (Mtm2PCMinTimeout ), (ts -> csn - ts -> snapshot )* Mtm2PCPrepareRatio /100 );/* usec->msec and percents */
838+ time_t transTimeout = Max (MSEC_TO_USEC (Mtm2PCMinTimeout ), (ts -> csn - ts -> snapshot )* Mtm2PCPrepareRatio /100 );
839839int result = 0 ;
840840int nConfigChanges = Mtm -> nConfigChanges ;
841841
@@ -1343,6 +1343,7 @@ bool MtmRefreshClusterStatus(bool nowait)
13431343nodemask_t mask ,clique ;
13441344nodemask_t matrix [MAX_NODES ];
13451345int clique_size ;
1346+ MtmTransState * ts ;
13461347int i ;
13471348
13481349if (!MtmUseRaftable || !MtmBuildConnectivityMatrix (matrix ,nowait )) {
@@ -1378,6 +1379,16 @@ bool MtmRefreshClusterStatus(bool nowait)
13781379}
13791380}
13801381MtmCheckQuorum ();
1382+ /* Interrupt voting for active transaction and abort them */
1383+ for (ts = Mtm -> transListHead ;ts != NULL ;ts = ts -> next ) {
1384+ if (!ts -> votingCompleted ) {
1385+ if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
1386+ MTM_LOG1 ("Rollback active transaction %d:%d" ,ts -> gtid .node ,ts -> gtid .xid );
1387+ MtmAbortTransaction (ts );
1388+ }
1389+ MtmWakeUpBackend (ts );
1390+ }
1391+ }
13811392MtmUnlock ();
13821393if (BIT_CHECK (Mtm -> disabledNodeMask ,MtmNodeId - 1 )) {
13831394if (Mtm -> status == MTM_ONLINE ) {