Commit e26f4486 authored by antirez's avatar antirez
Browse files

Cluster: update node configEpoch on UPDATE messages.

The UPDATE message contains the configEpoch of the node configuration
advertised in the packet. Update it if needed.
parent a2ff9091
...@@ -1546,6 +1546,10 @@ int clusterProcessPacket(clusterLink *link) { ...@@ -1546,6 +1546,10 @@ int clusterProcessPacket(clusterLink *link) {
/* If in our current config the node is a slave, set it as a master. */ /* If in our current config the node is a slave, set it as a master. */
if (nodeIsSlave(n)) clusterSetNodeAsMaster(n); if (nodeIsSlave(n)) clusterSetNodeAsMaster(n);
/* Update the node's configEpoch. */
n->configEpoch = reportedConfigEpoch;
clusterDoBeforeSleep(CLUSTER_TODO_SAVE_CONFIG|CLUSTER_TODO_FSYNC_CONFIG);
/* Check the bitmap of served slots and udpate our /* Check the bitmap of served slots and udpate our
* config accordingly. */ * config accordingly. */
clusterUpdateSlotsConfigWith(n,reportedConfigEpoch, clusterUpdateSlotsConfigWith(n,reportedConfigEpoch,
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment