Commit b1875177 authored by antirez's avatar antirez
Browse files

Cluster: when upading the configEpoch for a node, save config on disk ASAP.

parent 03ca9039
......@@ -924,8 +924,10 @@ int clusterProcessPacket(clusterLink *link) {
if (senderCurrentEpoch > server.cluster->currentEpoch)
server.cluster->currentEpoch = senderCurrentEpoch;
/* Update the sender configEpoch if it is publishing a newer one. */
if (senderConfigEpoch > sender->configEpoch)
if (senderConfigEpoch > sender->configEpoch) {
sender->configEpoch = senderConfigEpoch;
clusterSaveConfigOrDie();
}
}
/* Process packets by type. */
......
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