Commit22303c4

committed

send PollMessages to disabled nodes too

1 parentca70781 commit22303c4Copy full SHA for 22303c4

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

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 voidMtmLoadPreparedTransactions(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);`

Comments

(0)