Commit fdb57233 authored by antirez's avatar antirez
Browse files

Cluster: always use cluster(Add|Del)Slot to modify the cluster slots table.

parent 786b8d6c
...@@ -46,6 +46,7 @@ sds clusterGenNodesDescription(void); ...@@ -46,6 +46,7 @@ sds clusterGenNodesDescription(void);
clusterNode *clusterLookupNode(char *name); clusterNode *clusterLookupNode(char *name);
int clusterNodeAddSlave(clusterNode *master, clusterNode *slave); int clusterNodeAddSlave(clusterNode *master, clusterNode *slave);
int clusterAddSlot(clusterNode *n, int slot); int clusterAddSlot(clusterNode *n, int slot);
int clusterDelSlot(int slot);
/* ----------------------------------------------------------------------------- /* -----------------------------------------------------------------------------
* Initialization * Initialization
...@@ -669,7 +670,8 @@ int clusterProcessPacket(clusterLink *link) { ...@@ -669,7 +670,8 @@ int clusterProcessPacket(clusterLink *link) {
if (server.cluster->slots[j] == NULL || if (server.cluster->slots[j] == NULL ||
server.cluster->slots[j]->flags & REDIS_NODE_FAIL) server.cluster->slots[j]->flags & REDIS_NODE_FAIL)
{ {
server.cluster->slots[j] = sender; clusterDelSlot(j);
clusterAddSlot(sender,j);
update_state = update_config = 1; update_state = update_config = 1;
} }
} }
......
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