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)
1690
1690
1691
1691
for (i = 0 ; i < Mtm -> nAllNodes ; i ++ )
1692
1692
{
1693
- if (BIT_CHECK (ts -> participantsMask & ~ Mtm -> disabledNodeMask , i ))
1693
+ if (BIT_CHECK (ts -> participantsMask , i ))
1694
1694
{
1695
1695
msg .node = i + 1 ;
1696
1696
MTM_LOG3 ("Send request for transaction %s to node %d" , msg .gid , msg .node );
@@ -1734,7 +1734,7 @@ static void MtmLoadPreparedTransactions(void)
1734
1734
ts -> gtid .xid = xid ;
1735
1735
ts -> nSubxids = 0 ;
1736
1736
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 ));
1738
1738
ts -> nConfigChanges = Mtm -> nConfigChanges ;
1739
1739
ts -> votedMask = 0 ;
1740
1740
strcpy (ts -> gid , gid );
You can’t perform that action at this time.
0 commit comments