Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 0df7c52

Browse files
committed
broadcast status poll to all nodes. In case of winner we can be the only one participant
1 parent 10804ed commit 0df7c52

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

multimaster.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1727,17 +1727,17 @@ static void MtmBroadcastPollMessage(MtmTransState* ts)
17271727
int i;
17281728
MtmArbiterMessage msg;
17291729

1730-
MTM_LOG1("MtmBroadcastPollMessage: %s %lld", ts->gid, ts->participantsMask);
17311730
MtmInitMessage(&msg, MSG_POLL_REQUEST);
17321731
memcpy(msg.gid, ts->gid, MULTIMASTER_MAX_GID_SIZE);
17331732
ts->votedMask = 0;
17341733

17351734
for (i = 0; i < Mtm->nAllNodes; i++)
17361735
{
1737-
if (BIT_CHECK(ts->participantsMask, i))
1736+
// if (BIT_CHECK(ts->participantsMask, i))
1737+
if (i + 1 != MtmNodeId)
17381738
{
17391739
msg.node = i+1;
1740-
MTM_LOG3("Send request for transaction %s to node %d", msg.gid, msg.node);
1740+
MTM_LOG1("Sending request for transaction %s to node %d", msg.gid, msg.node);
17411741
MtmSendMessage(&msg);
17421742
}
17431743
}

0 commit comments

Comments
 (0)