Commitf9a29ec

committed

send PollMessages to disabled nodes too

1 parent76c96f6 commitf9a29ecCopy full SHA for f9a29ec

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1691,7 +1691,7 @@ static void MtmBroadcastPollMessage(MtmTransState* ts)`
`1691`	`1691`
`1692`	`1692`	`for (i=0;i<Mtm->nAllNodes;i++)`
`1693`	`1693`	`{`
`1694`		`-if (BIT_CHECK(ts->participantsMask& ~Mtm->disabledNodeMask,i))`
	`1694`	`+if (BIT_CHECK(ts->participantsMask,i))`
`1695`	`1695`	`{`
`1696`	`1696`	`msg.node=i+1;`
`1697`	`1697`	`MTM_LOG3("Send request for transaction %s to node %d",msg.gid,msg.node);`
`@@ -1735,7 +1735,7 @@ static voidMtmLoadPreparedTransactions(void)`
`1735`	`1735`	`ts->gtid.xid=xid;`
`1736`	`1736`	`ts->nSubxids=0;`
`1737`	`1737`	`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));`
`1739`	`1739`	`ts->nConfigChanges=Mtm->nConfigChanges;`
`1740`	`1740`	`ts->votedMask=0;`
`1741`	`1741`	`strcpy(ts->gid,gid);`

Comments

(0)