@@ -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 );
@@ -1385,6 +1385,7 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)
13851385if (!ts -> isLocal ) {
13861386Mtm2PCVoting (x ,ts );
13871387}else {
1388+ ts -> status = TRANSACTION_STATUS_UNKNOWN ;
13881389ts -> votingCompleted = true;
13891390}
13901391if (x -> isTwoPhase ) {
@@ -2369,8 +2370,8 @@ static void MtmInitialize()
23692370Mtm -> oldestXid = FirstNormalTransactionId ;
23702371Mtm -> nLiveNodes = 0 ;//MtmNodes;
23712372Mtm -> nAllNodes = MtmNodes ;
2372- Mtm -> disabledNodeMask = 7 ; //XXXX
2373- Mtm -> clique = 7 ; // XXXX ! should be inverted !
2373+ Mtm -> disabledNodeMask = ((( nodemask_t ) 1 << MtmNodes ) - 1 );
2374+ Mtm -> clique = 0 ;
23742375Mtm -> stalledNodeMask = 0 ;
23752376Mtm -> stoppedNodeMask = 0 ;
23762377Mtm -> deadNodeMask = 0 ;