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