Lines Matching refs:cluster_manager_command
82 #define CLUSTER_MANAGER_MODE() (config.cluster_manager_command.name != NULL)
229 clusterManagerCommand cluster_manager_command; member
1336 config.cluster_manager_command.replicas = atoi(argv[++i]); in parseOptions()
1338 config.cluster_manager_command.master_id = argv[++i]; in parseOptions()
1340 config.cluster_manager_command.from = argv[++i]; in parseOptions()
1342 config.cluster_manager_command.to = argv[++i]; in parseOptions()
1344 if (config.cluster_manager_command.weight != NULL) { in parseOptions()
1361 config.cluster_manager_command.weight = weight; in parseOptions()
1362 config.cluster_manager_command.weight_argc = wargc; in parseOptions()
1366 config.cluster_manager_command.slots = atoi(argv[++i]); in parseOptions()
1368 config.cluster_manager_command.timeout = atoi(argv[++i]); in parseOptions()
1370 config.cluster_manager_command.pipeline = atoi(argv[++i]); in parseOptions()
1372 config.cluster_manager_command.threshold = atof(argv[++i]); in parseOptions()
1374 config.cluster_manager_command.flags |= in parseOptions()
1377 config.cluster_manager_command.flags |= in parseOptions()
1380 config.cluster_manager_command.flags |= in parseOptions()
1383 config.cluster_manager_command.flags |= in parseOptions()
1386 config.cluster_manager_command.flags |= in parseOptions()
1389 config.cluster_manager_command.flags |= in parseOptions()
1392 config.cluster_manager_command.flags |= in parseOptions()
1400 if (config.cluster_manager_command.argc == 0) { in parseOptions()
1404 config.cluster_manager_command.argc = cmd_argc; in parseOptions()
1405 config.cluster_manager_command.argv = argv + i; in parseOptions()
1445 config.cluster_manager_command.flags |= CLUSTER_MANAGER_CMD_FLAG_YES; in parseEnv()
1558 if (config.cluster_manager_command.flags & CLUSTER_MANAGER_CMD_FLAG_YES) { in confirmWithYes()
2042 clusterManagerCommand *cmd = &config.cluster_manager_command; in createClusterManagerCommand()
2054 char *cmdname = config.cluster_manager_command.name; in validateClusterManagerCommand()
2055 int argc = config.cluster_manager_command.argc; in validateClusterManagerCommand()
2969 int replace_existing_keys = (config.cluster_manager_command.flags & in clusterManagerMigrateKeysInSlot()
3067 int pipeline = config.cluster_manager_command.pipeline, in clusterManagerMoveSlot()
3068 timeout = config.cluster_manager_command.timeout, in clusterManagerMoveSlot()
4240 int do_fix = config.cluster_manager_command.flags & in clusterManagerCheckCluster()
4346 int search_multiple_owners = config.cluster_manager_command.flags & in clusterManagerCheckCluster()
4479 (config.cluster_manager_command.flags & CLUSTER_MANAGER_CMD_FLAG_COLOR); in clusterManagerLog()
4565 int argc = config.cluster_manager_command.argc; in clusterManagerMode()
4566 char **argv = config.cluster_manager_command.argv; in clusterManagerMode()
4626 int replicas = config.cluster_manager_command.replicas; in clusterManagerCommandCreate()
4874 if (config.cluster_manager_command.flags & CLUSTER_MANAGER_CMD_FLAG_SLAVE) { in clusterManagerCommandAddNode()
4875 char *master_id = config.cluster_manager_command.master_id; in clusterManagerCommandAddNode()
5045 config.cluster_manager_command.flags |= CLUSTER_MANAGER_CMD_FLAG_FIX; in clusterManagerCommandFix()
5062 int slots = config.cluster_manager_command.slots; in clusterManagerCommandReshard()
5081 char *to = config.cluster_manager_command.to, in clusterManagerCommandReshard()
5082 *from = config.cluster_manager_command.from; in clusterManagerCommandReshard()
5198 if (!(config.cluster_manager_command.flags & in clusterManagerCommandReshard()
5245 if (config.cluster_manager_command.weight != NULL) { in clusterManagerCommandRebalance()
5246 for (i = 0; i < config.cluster_manager_command.weight_argc; i++) { in clusterManagerCommandRebalance()
5247 char *name = config.cluster_manager_command.weight[i]; in clusterManagerCommandRebalance()
5266 int use_empty = config.cluster_manager_command.flags & in clusterManagerCommandRebalance()
5299 float threshold = config.cluster_manager_command.threshold; in clusterManagerCommandRebalance()
5326 config.cluster_manager_command.threshold); in clusterManagerCommandRebalance()
5361 int simulate = config.cluster_manager_command.flags & in clusterManagerCommandRebalance()
5492 if (config.cluster_manager_command.from == NULL) { in clusterManagerCommandImport()
5497 char *src_host[] = {config.cluster_manager_command.from}; in clusterManagerCommandImport()
5560 if (config.cluster_manager_command.flags & CLUSTER_MANAGER_CMD_FLAG_COPY) in clusterManagerCommandImport()
5562 if (config.cluster_manager_command.flags & CLUSTER_MANAGER_CMD_FLAG_REPLACE) in clusterManagerCommandImport()
5567 int cursor = -999, timeout = config.cluster_manager_command.timeout; in clusterManagerCommandImport()
7031 config.cluster_manager_command.name = NULL; in main()
7032 config.cluster_manager_command.argc = 0; in main()
7033 config.cluster_manager_command.argv = NULL; in main()
7034 config.cluster_manager_command.flags = 0; in main()
7035 config.cluster_manager_command.replicas = 0; in main()
7036 config.cluster_manager_command.from = NULL; in main()
7037 config.cluster_manager_command.to = NULL; in main()
7038 config.cluster_manager_command.weight = NULL; in main()
7039 config.cluster_manager_command.weight_argc = 0; in main()
7040 config.cluster_manager_command.slots = 0; in main()
7041 config.cluster_manager_command.timeout = CLUSTER_MANAGER_MIGRATE_TIMEOUT; in main()
7042 config.cluster_manager_command.pipeline = CLUSTER_MANAGER_MIGRATE_PIPELINE; in main()
7043 config.cluster_manager_command.threshold = in main()