fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-03 16:21:03 +00:00
Code Issues Projects Releases Wiki Activity

Cluster: senderCurrentEpoch == node currentEpoch was too strict.

Browse Source 
We can accept a vote as long as its epoch is >= the epoch at which we
started the voting process. There is no need for it to be exactly the
same.
This commit is contained in:
antirez 2013-10-01 17:21:28 +02:00
parent f1bfd8233b
commit 7970ebd80a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/cluster.c
View File

@ -1191,11 +1191,11 @@ int clusterProcessPacket(clusterLink *link) {
} else if (type == CLUSTERMSG_TYPE_FAILOVER_AUTH_ACK) { } else if (type == CLUSTERMSG_TYPE_FAILOVER_AUTH_ACK) {
if (!sender) return 1; /* We don't know that node. */ if (!sender) return 1; /* We don't know that node. */
/* We consider this vote only if the sender is a master serving /* We consider this vote only if the sender is a master serving
* a non zero number of slots, with the currentEpoch that is equal * a non zero number of slots, and its currentEpoch is greater or
* to our currentEpoch. */ * equal to epoch where this node started the election. */
if (sender->flags & REDIS_NODE_MASTER && if (sender->flags & REDIS_NODE_MASTER &&
sender->numslots > 0 && sender->numslots > 0 &&
senderCurrentEpoch == server.cluster->currentEpoch) senderCurrentEpoch >= server.cluster->failover_auth_epoch)
{ {
server.cluster->failover_auth_count++; server.cluster->failover_auth_count++;
/* Maybe we reached a quorum here, set a flag to make sure /* Maybe we reached a quorum here, set a flag to make sure