Commit c39e34d0 authored by antirez's avatar antirez
Browse files

Cluster: when slave changes master, remove it from the old master.

parent 70091a2f
...@@ -933,6 +933,8 @@ int clusterProcessPacket(clusterLink *link) { ...@@ -933,6 +933,8 @@ int clusterProcessPacket(clusterLink *link) {
/* Master node changed for this slave? */ /* Master node changed for this slave? */
if (sender->slaveof != master) { if (sender->slaveof != master) {
if (sender->slaveof)
clusterNodeRemoveSlave(sender->slaveof,sender);
clusterNodeAddSlave(master,sender); clusterNodeAddSlave(master,sender);
sender->slaveof = master; sender->slaveof = master;
} }
......
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