Cluster: clusterDelNode(): remove node from master's slaves.

0725988a · antirez · 4513d8fc · 0725988a
隐藏空白更改
内联并排

Showing with 5 addition and 1 deletion

src/cluster.c src/cluster.c +5 -1

未找到文件。
--- a/src/cluster.c
+++ b/src/cluster.c
@@ -664,7 +664,11 @@ void clusterDelNode(clusterNode *delnode) {
    }
    dictReleaseIterator(di);

-    /* 3) Free the node, unlinking it from the cluster. */
+    /* 3) Remove this node from its master's slaves if needed. */
+    if (nodeIsSlave(delnode) && delnode->slaveof)
+        clusterNodeRemoveSlave(delnode->slaveof,delnode);
+
+    /* 4) Free the node, unlinking it from the cluster. */
    freeClusterNode(delnode);
 }