Skip to content

Commit 22303c4

Browse files
committed
send PollMessages to disabled nodes too
1 parent ca70781 commit 22303c4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

contrib/mmts/multimaster.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff 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);

0 commit comments

Comments
 (0)