We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see ourdocumentation.
There was an error while loading.Please reload this page.
1 parentca70781 commit22303c4Copy full SHA for 22303c4
contrib/mmts/multimaster.c
@@ -1690,7 +1690,7 @@ static void MtmBroadcastPollMessage(MtmTransState* ts)
1690
1691
for (i=0;i<Mtm->nAllNodes;i++)
1692
{
1693
-if (BIT_CHECK(ts->participantsMask& ~Mtm->disabledNodeMask,i))
+if (BIT_CHECK(ts->participantsMask,i))
1694
1695
msg.node=i+1;
1696
MTM_LOG3("Send request for transaction %s to node %d",msg.gid,msg.node);
@@ -1734,7 +1734,7 @@ static voidMtmLoadPreparedTransactions(void)
1734
ts->gtid.xid=xid;
1735
ts->nSubxids=0;
1736
ts->votingCompleted= true;
1737
-ts->participantsMask= (((nodemask_t)1 <<Mtm->nAllNodes)-1)& ~Mtm->disabledNodeMask& ~((nodemask_t)1 << (MtmNodeId-1));
+ts->participantsMask= (((nodemask_t)1 <<Mtm->nAllNodes)-1)& ~((nodemask_t)1 << (MtmNodeId-1));
1738
ts->nConfigChanges=Mtm->nConfigChanges;
1739
ts->votedMask=0;
1740
strcpy(ts->gid,gid);