@@ -1128,12 +1128,12 @@ MtmPrePrepareTransaction(MtmCurrentTrans* x)
11281128/*
11291129 * Invalid CSN prevent replication of transaction by logical replication
11301130 */
1131- ts -> isLocal = x -> isReplicated || !x -> containsDML ;
11321131ts -> snapshot = x -> snapshot ;
11331132ts -> csn = MtmAssignCSN ();
11341133ts -> procno = MyProc -> pgprocno ;
11351134ts -> votingCompleted = false;
11361135ts -> participantsMask = (((nodemask_t )1 <<Mtm -> nAllNodes )- 1 )& ~Mtm -> disabledNodeMask & ~((nodemask_t )1 << (MtmNodeId - 1 ));
1136+ ts -> isLocal = x -> isReplicated || !x -> containsDML || (ts -> participantsMask == 0 );
11371137ts -> nConfigChanges = Mtm -> nConfigChanges ;
11381138ts -> votedMask = 0 ;
11391139ts -> nSubxids = xactGetCommittedChildren (& subxids );
@@ -1384,6 +1384,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)
13841384if (!ts -> isLocal ) {
13851385Mtm2PCVoting (x ,ts );
13861386}else {
1387+ ts -> status = TRANSACTION_STATUS_UNKNOWN ;
13871388ts -> votingCompleted = true;
13881389}
13891390if (x -> isTwoPhase ) {
@@ -2373,8 +2374,8 @@ static void MtmInitialize()
23732374Mtm -> oldestXid = FirstNormalTransactionId ;
23742375Mtm -> nLiveNodes = 0 ;//MtmNodes;
23752376Mtm -> nAllNodes = MtmNodes ;
2376- Mtm -> disabledNodeMask = 7 ; //XXXX
2377- Mtm -> clique = 7 ; // XXXX ! should be inverted !
2377+ Mtm -> disabledNodeMask = ((( nodemask_t ) 1 << MtmNodes ) - 1 );
2378+ Mtm -> clique = 0 ;
23782379Mtm -> stalledNodeMask = 0 ;
23792380Mtm -> stoppedNodeMask = 0 ;
23802381Mtm -> deadNodeMask = 0 ;