caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 16:48:27 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

ClusterManager: fixed --cluster-from 'all' parsing

Browse Source
This commit is contained in:
artix 2018-03-02 17:06:50 +01:00
parent ce14d23740
commit d518733073
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/redis-cli.c
View File

@ -3137,12 +3137,12 @@ static clusterManagerNode *clusterNodeForResharding(char *id,
int *raise_err) int *raise_err)
{ {
clusterManagerNode *node = NULL; clusterManagerNode *node = NULL;
const char *invalid_node_msg = "*** The specified node is not known or " const char *invalid_node_msg = "*** The specified node (%s) is not known "
"not a master, please retry.\n"; "or not a master, please retry.\n";
node = clusterManagerNodeByName(id); node = clusterManagerNodeByName(id);
*raise_err = 0; *raise_err = 0;
if (!node || node->flags & CLUSTER_MANAGER_FLAG_SLAVE) { if (!node || node->flags & CLUSTER_MANAGER_FLAG_SLAVE) {
clusterManagerLogErr(invalid_node_msg); clusterManagerLogErr(invalid_node_msg, id);
*raise_err = 1; *raise_err = 1;
return NULL; return NULL;
} else if (node != NULL && target != NULL) { } else if (node != NULL && target != NULL) {
@ -3700,6 +3700,8 @@ static int clusterManagerCommandReshard(int argc, char **argv) {
} }
/* Check if there's still another source to process. */ /* Check if there's still another source to process. */
if (!all && strlen(from) > 0) { if (!all && strlen(from) > 0) {
if (!strcmp(from, "all")) all = 1;
if (!all) {
clusterManagerNode *src = clusterManagerNode *src =
clusterNodeForResharding(from, target, &raise_err); clusterNodeForResharding(from, target, &raise_err);
if (src != NULL) listAddNodeTail(sources, src); if (src != NULL) listAddNodeTail(sources, src);
@ -3709,6 +3711,7 @@ static int clusterManagerCommandReshard(int argc, char **argv) {
} }
} }
} }
}
listIter li; listIter li;
listNode *ln; listNode *ln;
if (all) { if (all) {