Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit22303c4

Browse files
committed
send PollMessages to disabled nodes too
1 parentca70781 commit22303c4

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

[8]ページ先頭

©2009-2025 Movatter.jp