Clarify existing slot wording on cluster start
This commit is contained in:
parent
edca2b14d2
commit
6a7a32a806
@ -3289,14 +3289,13 @@ int verifyClusterConfigWithData(void) {
|
|||||||
update_config++;
|
update_config++;
|
||||||
/* Case A: slot is unassigned. Take responsability for it. */
|
/* Case A: slot is unassigned. Take responsability for it. */
|
||||||
if (server.cluster->slots[j] == NULL) {
|
if (server.cluster->slots[j] == NULL) {
|
||||||
redisLog(REDIS_WARNING, "I've keys about slot %d that is "
|
redisLog(REDIS_WARNING, "I have keys for unassigned slot %d. "
|
||||||
"unassigned. Taking responsability "
|
"Taking responsibility for it.",j);
|
||||||
"for it.",j);
|
|
||||||
clusterAddSlot(myself,j);
|
clusterAddSlot(myself,j);
|
||||||
} else {
|
} else {
|
||||||
redisLog(REDIS_WARNING, "I've keys about slot %d that is "
|
redisLog(REDIS_WARNING, "I have keys for slot %d, but the slot is "
|
||||||
"already assigned to a different node. "
|
"assigned to another node. "
|
||||||
"Setting it in importing state.",j);
|
"Setting it to importing state.",j);
|
||||||
server.cluster->importing_slots_from[j] = server.cluster->slots[j];
|
server.cluster->importing_slots_from[j] = server.cluster->slots[j];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user