@@ -1171,7 +1171,8 @@ void MtmPrecommitTransaction(char const* gid)
11711171ts -> status = TRANSACTION_STATUS_UNKNOWN ;
11721172ts -> csn = MtmAssignCSN ();
11731173MtmAdjustSubtransactions (ts );
1174- MtmSend2PCMessage (ts ,MSG_PRECOMMITTED );
1174+ if (Mtm -> status != MTM_RECOVERY )// XXXX why?
1175+ MtmSend2PCMessage (ts ,MSG_PRECOMMITTED );
11751176MtmUnlock ();
11761177Assert (replorigin_session_origin != InvalidRepOriginId );
11771178if (!IsTransactionState ()) {
@@ -1615,10 +1616,13 @@ void MtmSend2PCMessage(MtmTransState* ts, MtmMessageCode cmd)
16151616memcpy (msg .gid ,ts -> gid ,MULTIMASTER_MAX_GID_SIZE );
16161617
16171618Assert (!MtmIsCoordinator (ts ));/* All broadcasts are now done through logical decoding */
1618- MTM_TXTRACE (ts ,"MtmSend2PCMessage sending %s message to node %d" ,MtmMessageKindMnem [cmd ],ts -> gtid .node );
1619- msg .node = ts -> gtid .node ;
1620- msg .dxid = ts -> gtid .xid ;
1621- MtmSendMessage (& msg );
1619+ if (!BIT_CHECK (Mtm -> disabledNodeMask ,ts -> gtid .node - 1 ))
1620+ {
1621+ MTM_TXTRACE (ts ,"MtmSend2PCMessage sending %s message to node %d" ,MtmMessageKindMnem [cmd ],ts -> gtid .node );
1622+ msg .node = ts -> gtid .node ;
1623+ msg .dxid = ts -> gtid .xid ;
1624+ MtmSendMessage (& msg );
1625+ }
16221626}
16231627
16241628/*
@@ -1729,11 +1733,6 @@ void MtmJoinTransaction(GlobalTransactionId* gtid, csn_t globalSnapshot, nodemas
17291733if (globalSnapshot != INVALID_CSN ) {
17301734MtmLock (LW_EXCLUSIVE );
17311735
1732- if (BIT_CHECK (Mtm -> disabledNodeMask ,gtid -> node - 1 )) {
1733- MtmUnlock ();
1734- MTM_ELOG (ERROR ,"Ignore transaction %llu from disabled node %d" , (long64 )gtid -> xid ,gtid -> node );
1735- }
1736-
17371736liveMask = (((nodemask_t )1 <<Mtm -> nAllNodes )- 1 )& ~Mtm -> disabledNodeMask ;
17381737BIT_SET (participantsMask ,gtid -> node - 1 );
17391738if (liveMask & ~participantsMask ) {