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: configEpoch assignment in SETNODE improved.

Browse Source 
Avoid to trash a configEpoch for every slot migrated if this node has
already the max configEpoch across the cluster.

Still work to do in this area but this avoids both ending with a very
high configEpoch without any reason and to flood the system with fsyncs.
This commit is contained in:
antirez 2014-02-11 10:06:10 +01:00
parent 72f7abf6a2
commit 4a64286c36
1 changed files with 7 additions and 3 deletions

10
src/cluster.c

@ -3174,9 +3174,13 @@ void clusterCommand(redisClient *c) {
* FIXME: the new version should be agreed otherwise a race * FIXME: the new version should be agreed otherwise a race
* is possible if while a manual resharding is in progress * is possible if while a manual resharding is in progress
* the master is failed over by a slave. */ * the master is failed over by a slave. */
server.cluster->currentEpoch++; uint64_t maxEpoch = clusterGetMaxEpoch();
myself->configEpoch = server.cluster->currentEpoch;
clusterDoBeforeSleep(CLUSTER_TODO_FSYNC_CONFIG); if (myself->configEpoch != maxEpoch) {
server.cluster->currentEpoch++;
myself->configEpoch = server.cluster->currentEpoch;
clusterDoBeforeSleep(CLUSTER_TODO_FSYNC_CONFIG);
}
server.cluster->importing_slots_from[slot] = NULL; server.cluster->importing_slots_from[slot] = NULL;
} }
clusterDelSlot(slot); clusterDelSlot(slot);