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

Cluster: on resharding upgrade version of receiving node.

Browse Source 
The node receiving the hash slot needs to have a version that wins over
the other versions in order to force the ownership of the slot.

However the current code is far from perfect since a failover can happen
during the manual resharding. The fix is a work in progress but the
bottom line is that the new version must either be voted as usually,
set by redis-trib manually after it makes sure can't be used by other
nodes, or reserved configEpochs could be used for manual operations (for
example odd versions could be never used by slaves and are always used
by CLUSTER SETSLOT NODE).
This commit is contained in:
antirez 2014-02-11 00:32:39 +01:00
parent 6dc26795aa
commit a1349728ea
1 changed files with 8 additions and 4 deletions

12
src/cluster.c

@ -3169,11 +3169,15 @@ void clusterCommand(redisClient *c) {
clusterNode *old_owner = clusterNode *old_owner =
server.cluster->importing_slots_from[slot]; server.cluster->importing_slots_from[slot];
/* This slot was manually migrated, set this node configEpoch /* This slot was manually migrated, set this node configEpoch
* at least to the value of the configEpoch of the old owner * to a new epoch so that the new version can be propagated
* so that its old replicas, or some of its old message pending * by the cluster.
* on the cluster bus, can't claim our slot. */ *
* FIXME: the new version should be agreed otherwise a race
* is possible if while a manual resharding is in progress
* the master is failed over by a slave. */
if (old_owner->configEpoch > myself->configEpoch) { if (old_owner->configEpoch > myself->configEpoch) {
myself->configEpoch = old_owner->configEpoch; server.cluster->currentEpoch++;
myself->configEpoch = server.cluster->currentEpoch;
clusterDoBeforeSleep(CLUSTER_TODO_FSYNC_CONFIG); clusterDoBeforeSleep(CLUSTER_TODO_FSYNC_CONFIG);
} }
server.cluster->importing_slots_from[slot] = NULL; server.cluster->importing_slots_from[slot] = NULL;