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 @@ -1690,7 +1690,7 @@ static void MtmBroadcastPollMessage(MtmTransState* ts)
16901690
16911691 for (i = 0 ; i < Mtm -> nAllNodes ; i ++ )
16921692 {
1693- if (BIT_CHECK (ts -> participantsMask & ~ Mtm -> disabledNodeMask , i ))
1693+ if (BIT_CHECK (ts -> participantsMask , i ))
16941694 {
16951695 msg .node = i + 1 ;
16961696 MTM_LOG3 ("Send request for transaction %s to node %d" , msg .gid , msg .node );
@@ -1734,7 +1734,7 @@ static void MtmLoadPreparedTransactions(void)
17341734 ts -> gtid .xid = xid ;
17351735 ts -> nSubxids = 0 ;
17361736 ts -> votingCompleted = true;
1737- ts -> participantsMask = (((nodemask_t )1 << Mtm -> nAllNodes ) - 1 ) & ~Mtm -> disabledNodeMask & ~ ((nodemask_t )1 << (MtmNodeId - 1 ));
1737+ ts -> participantsMask = (((nodemask_t )1 << Mtm -> nAllNodes ) - 1 ) & ~((nodemask_t )1 << (MtmNodeId - 1 ));
17381738 ts -> nConfigChanges = Mtm -> nConfigChanges ;
17391739 ts -> votedMask = 0 ;
17401740 strcpy (ts -> gid , gid );
You can’t perform that action at this time.
0 commit comments