File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1691,7 +1691,7 @@ static void MtmBroadcastPollMessage(MtmTransState* ts)
16911691
16921692 for (i = 0 ; i < Mtm -> nAllNodes ; i ++ )
16931693 {
1694- if (BIT_CHECK (ts -> participantsMask & ~ Mtm -> disabledNodeMask , i ))
1694+ if (BIT_CHECK (ts -> participantsMask , i ))
16951695 {
16961696 msg .node = i + 1 ;
16971697 MTM_LOG3 ("Send request for transaction %s to node %d" , msg .gid , msg .node );
@@ -1735,7 +1735,7 @@ static void MtmLoadPreparedTransactions(void)
17351735 ts -> gtid .xid = xid ;
17361736 ts -> nSubxids = 0 ;
17371737 ts -> votingCompleted = true;
1738- ts -> participantsMask = (((nodemask_t )1 << Mtm -> nAllNodes ) - 1 ) & ~Mtm -> disabledNodeMask & ~ ((nodemask_t )1 << (MtmNodeId - 1 ));
1738+ ts -> participantsMask = (((nodemask_t )1 << Mtm -> nAllNodes ) - 1 ) & ~((nodemask_t )1 << (MtmNodeId - 1 ));
17391739 ts -> nConfigChanges = Mtm -> nConfigChanges ;
17401740 ts -> votedMask = 0 ;
17411741 strcpy (ts -> gid , gid );
You can’t perform that action at this time.
0 commit comments