1905 typedef struct clusterManagerNode {  struct
1929 } clusterManagerNode;  argument
1933     clusterManagerNode **nodes; /* Actual nodes array */
1934     clusterManagerNode **alloc; /* Pointer to the allocated memory */
1941     clusterManagerNode *source;
1959 static clusterManagerNode *clusterManagerNewNode(char *ip, int port);
1960 static clusterManagerNode *clusterManagerNodeByName(const char *name);
1961 static clusterManagerNode *clusterManagerNodeByAbbreviatedName(const char *n);
1962 static void clusterManagerNodeResetSlots(clusterManagerNode *node);
1963 static int clusterManagerNodeIsCluster(clusterManagerNode *node, char **err);
1964 static void clusterManagerPrintNotClusterNodeError(clusterManagerNode *node,
1966 static int clusterManagerNodeLoadInfo(clusterManagerNode *node, int opts,
1968 static int clusterManagerLoadInfoFromNode(clusterManagerNode *node, int opts);
1969 static int clusterManagerNodeIsEmpty(clusterManagerNode *node, char **err);
1971     int ip_count, clusterManagerNode ***offending, int *offending_len);
1974 static sds clusterManagerNodeInfo(clusterManagerNode *node, int indent);
1977 static int clusterManagerFlushNodeConfig(clusterManagerNode *node, char **err);
1987                                          clusterManagerNode **nodeptr);
1989                                        clusterManagerNode *node);
2115 static void freeClusterManagerNode(clusterManagerNode *node) {  in freeClusterManagerNode()
2122             clusterManagerNode *fn = ln->value;  in freeClusterManagerNode()
2154             clusterManagerNode *n = ln->value;  in freeClusterManager()
2173 static clusterManagerNode *clusterManagerNewNode(char *ip, int port) {  in clusterManagerNewNode()
2174     clusterManagerNode *node = zmalloc(sizeof(*node));  in clusterManagerNewNode()
2202 static int clusterManagerCheckRedisReply(clusterManagerNode *n,  in clusterManagerCheckRedisReply()
2219 static int clusterManagerStartTransaction(clusterManagerNode *node) {  in clusterManagerStartTransaction()
2227 static int clusterManagerExecTransaction(clusterManagerNode *node,  in clusterManagerExecTransaction()
2256 static int clusterManagerNodeConnect(clusterManagerNode *node) {  in clusterManagerNodeConnect()
2282                                              clusterManagerNode *node) {  in clusterManagerRemoveNodeFromList()
2295 static clusterManagerNode *clusterManagerNodeByName(const char *name) {  in clusterManagerNodeByName()
2297     clusterManagerNode *found = NULL;  in clusterManagerNodeByName()
2305         clusterManagerNode *n = ln->value;  in clusterManagerNodeByName()
2319 static clusterManagerNode *clusterManagerNodeByAbbreviatedName(const char*name)  in clusterManagerNodeByAbbreviatedName()
2322     clusterManagerNode *found = NULL;  in clusterManagerNodeByAbbreviatedName()
2330         clusterManagerNode *n = ln->value;  in clusterManagerNodeByAbbreviatedName()
2341 static void clusterManagerNodeResetSlots(clusterManagerNode *node) {  in clusterManagerNodeResetSlots()
2347 static redisReply *clusterManagerGetNodeRedisInfo(clusterManagerNode *node,  in clusterManagerGetNodeRedisInfo()
2364 static int clusterManagerNodeIsCluster(clusterManagerNode *node, char **err) {  in clusterManagerNodeIsCluster()
2374 static int clusterManagerNodeIsEmpty(clusterManagerNode *node, char **err) {  in clusterManagerNodeIsEmpty()
2426     int ip_count, clusterManagerNode ***offending, int *offending_len)  in clusterManagerGetAntiAffinityScore()
2430     clusterManagerNode **offending_p = NULL;  in clusterManagerGetAntiAffinityScore()
2432         *offending = zcalloc(node_len * sizeof(clusterManagerNode*));  in clusterManagerGetAntiAffinityScore()
2443             clusterManagerNode *node = node_array->nodes[j];  in clusterManagerGetAntiAffinityScore()
2476                 clusterManagerNode *n = ln->value;  in clusterManagerGetAntiAffinityScore()
2495     clusterManagerNode **offenders = NULL;  in clusterManagerOptimizeAntiAffinity()
2519         clusterManagerNode *first = offenders[rand_idx],  in clusterManagerOptimizeAntiAffinity()
2521         clusterManagerNode **other_replicas = zcalloc((node_len - 1) *  in clusterManagerOptimizeAntiAffinity()
2528             clusterManagerNode *n = ln->value;  in clusterManagerOptimizeAntiAffinity()
2571 static sds clusterManagerNodeFlagString(clusterManagerNode *node) {  in clusterManagerNodeFlagString()
2589 static sds clusterManagerNodeSlotsString(clusterManagerNode *node) {  in clusterManagerNodeSlotsString()
2650 static sds clusterManagerNodeInfo(clusterManagerNode *node, int indent) {  in clusterManagerNodeInfo()
2686         clusterManagerNode *node = ln->value;  in clusterManagerShowNodes()
2700         clusterManagerNode *node = ln->value;  in clusterManagerShowClusterInfo()
2712                 clusterManagerNode *n = rn->value;  in clusterManagerShowClusterInfo()
2743 static int clusterManagerAddSlots(clusterManagerNode *node, char**err)  in clusterManagerAddSlots()
2788 static int clusterManagerSetSlot(clusterManagerNode *node1,  in clusterManagerSetSlot()
2789                                  clusterManagerNode *node2,  in clusterManagerSetSlot()
2811 static int clusterManagerClearSlotStatus(clusterManagerNode *node, int slot) {  in clusterManagerClearSlotStatus()
2819 static int clusterManagerDelSlot(clusterManagerNode *node, int slot,  in clusterManagerDelSlot()
2837 static int clusterManagerAddSlot(clusterManagerNode *node, int slot) {  in clusterManagerAddSlot()
2845 static signed int clusterManagerCountKeysInSlot(clusterManagerNode *node,  in clusterManagerCountKeysInSlot()
2857 static int clusterManagerBumpEpoch(clusterManagerNode *node) {  in clusterManagerBumpEpoch()
2872 static int clusterManagerSetSlotOwner(clusterManagerNode *owner,  in clusterManagerSetSlotOwner()
2892 static redisReply *clusterManagerMigrateKeysInReply(clusterManagerNode *source,  in clusterManagerMigrateKeysInReply()
2893                                                     clusterManagerNode *target,  in clusterManagerMigrateKeysInReply()
2962 static int clusterManagerMigrateKeysInSlot(clusterManagerNode *source,  in clusterManagerMigrateKeysInSlot()
2963                                            clusterManagerNode *target,  in clusterManagerMigrateKeysInSlot()
3057 static int clusterManagerMoveSlot(clusterManagerNode *source,  in clusterManagerMoveSlot()
3058                                   clusterManagerNode *target,  in clusterManagerMoveSlot()
3090             clusterManagerNode *n = ln->value;  in clusterManagerMoveSlot()
3120 static int clusterManagerFlushNodeConfig(clusterManagerNode *node, char **err) {  in clusterManagerFlushNodeConfig()
3166 static int clusterManagerNodeLoadInfo(clusterManagerNode *node, int opts,  in clusterManagerNodeLoadInfo()
3208         clusterManagerNode *currentNode = NULL;  in clusterManagerNodeLoadInfo()
3346 static int clusterManagerLoadInfoFromNode(clusterManagerNode *node, int opts) {  in clusterManagerLoadInfoFromNode()
3373             freeClusterManagerNode((clusterManagerNode *) ln->value);  in clusterManagerLoadInfoFromNode()
3381             clusterManagerNode *friend = ln->value;  in clusterManagerLoadInfoFromNode()
3408         clusterManagerNode *n = ln->value;  in clusterManagerLoadInfoFromNode()
3410             clusterManagerNode *master = clusterManagerNodeByName(n->replicate);  in clusterManagerLoadInfoFromNode()
3429     clusterManagerNode *node1 = *((clusterManagerNode **) n1);  in clusterManagerSlotCountCompareDesc()
3430     clusterManagerNode *node2 = *((clusterManagerNode **) n2);  in clusterManagerSlotCountCompareDesc()
3435     clusterManagerNode *node1 = *((clusterManagerNode **) n1);  in clusterManagerCompareNodeBalance()
3436     clusterManagerNode *node2 = *((clusterManagerNode **) n2);  in clusterManagerCompareNodeBalance()
3440 static sds clusterManagerGetConfigSignature(clusterManagerNode *node) {  in clusterManagerGetConfigSignature()
3543         clusterManagerNode *node = ln->value;  in clusterManagerIsConfigConsistent()
3578         clusterManagerNode *node = ln->value;  in clusterManagerGetCoveredSlots()
3605 static clusterManagerNode * clusterManagerGetNodeWithMostKeysInSlot(list *nodes,  in clusterManagerGetNodeWithMostKeysInSlot()
3609     clusterManagerNode *node = NULL;  in clusterManagerGetNodeWithMostKeysInSlot()
3616         clusterManagerNode *n = ln->value;  in clusterManagerGetNodeWithMostKeysInSlot()
3644 static clusterManagerNode *clusterManagerNodeWithLeastReplicas() {  in clusterManagerNodeWithLeastReplicas()
3645     clusterManagerNode *node = NULL;  in clusterManagerNodeWithLeastReplicas()
3651         clusterManagerNode *n = ln->value;  in clusterManagerNodeWithLeastReplicas()
3663 static clusterManagerNode *clusterManagerNodeMasterRandom() {  in clusterManagerNodeMasterRandom()
3670         clusterManagerNode *n = ln->value;  in clusterManagerNodeMasterRandom()
3679         clusterManagerNode *n = ln->value;  in clusterManagerNodeMasterRandom()
3708                 clusterManagerNode *n = ln->value;  in clusterManagerFixSlotsCoverage()
3767                 clusterManagerNode *n = clusterManagerNodeMasterRandom();  in clusterManagerFixSlotsCoverage()
3798                 clusterManagerNode *n = fn->value;  in clusterManagerFixSlotsCoverage()
3828                 clusterManagerNode *target =  in clusterManagerFixSlotsCoverage()
3848                     clusterManagerNode *src = nln->value;  in clusterManagerFixSlotsCoverage()
3896     clusterManagerNode *owner = NULL;  in clusterManagerFixOpenSlot()
3901         clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
3921         clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4023             clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4044         clusterManagerNode *src = listFirst(migrating)->value;  in clusterManagerFixOpenSlot()
4045         clusterManagerNode *dst = listFirst(importing)->value;  in clusterManagerFixOpenSlot()
4062             clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4075             clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4093         clusterManagerNode *src = listFirst(migrating)->value;  in clusterManagerFixOpenSlot()
4094         clusterManagerNode *dst = NULL;  in clusterManagerFixOpenSlot()
4108             clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4129                 clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4143                 clusterManagerNode *n = ln->value;  in clusterManagerFixOpenSlot()
4152             clusterManagerNode *n = listFirst(migrating)->value;  in clusterManagerFixOpenSlot()
4169             clusterManagerNode *n = listFirst(migrating)->value;  in clusterManagerFixOpenSlot()
4200     clusterManagerNode *owner = clusterManagerGetNodeWithMostKeysInSlot(owners,  in clusterManagerFixMultipleSlotOwners()
4215         clusterManagerNode *n = ln->value;  in clusterManagerFixMultipleSlotOwners()
4236     clusterManagerNode *node = ln->value;  in clusterManagerCheckCluster()
4259         clusterManagerNode *n = ln->value;  in clusterManagerCheckCluster()
4359                 clusterManagerNode *n = ln->value;  in clusterManagerCheckCluster()
4375                     clusterManagerNode *n = ln->value;  in clusterManagerCheckCluster()
4394 static clusterManagerNode *clusterNodeForResharding(char *id,  in clusterNodeForResharding()
4395                                                     clusterManagerNode *target,  in clusterNodeForResharding()
4398     clusterManagerNode *node = NULL;  in clusterNodeForResharding()
4421     clusterManagerNode **sorted = zmalloc(src_count * sizeof(*sorted));  in clusterManagerComputeReshardTable()
4426         clusterManagerNode *node = ln->value;  in clusterManagerComputeReshardTable()
4430     qsort(sorted, src_count, sizeof(clusterManagerNode *),  in clusterManagerComputeReshardTable()
4433         clusterManagerNode *node = sorted[i];  in clusterManagerComputeReshardTable()
4459         clusterManagerNode *n = item->source;  in clusterManagerShowReshardTable()
4500     array->nodes = zcalloc(alloc_len * sizeof(clusterManagerNode*));  in clusterManagerNodeArrayInit()
4522                                          clusterManagerNode **nodeptr)  in clusterManagerNodeArrayShift()
4535                                        clusterManagerNode *node)  in clusterManagerNodeArrayAdd()
4543 static void clusterManagerPrintNotEmptyNodeError(clusterManagerNode *node,  in clusterManagerPrintNotEmptyNodeError()
4556 static void clusterManagerPrintNotClusterNodeError(clusterManagerNode *node,  in clusterManagerPrintNotClusterNodeError()
4595         clusterManagerNode *node = clusterManagerNewNode(ip, port);  in clusterManagerCommandCreate()
4641     clusterManagerNode **interleaved = zcalloc(node_len*sizeof(**interleaved));  in clusterManagerCommandCreate()
4648         clusterManagerNode *n = ln->value;  in clusterManagerCommandCreate()
4669                 clusterManagerNode *n = NULL;  in clusterManagerCommandCreate()
4675     clusterManagerNode **masters = interleaved;  in clusterManagerCommandCreate()
4682         clusterManagerNode *master = masters[i];  in clusterManagerCommandCreate()
4700     clusterManagerNode *first_node = interleaved[0];  in clusterManagerCommandCreate()
4707         clusterManagerNode *master = masters[i];  in clusterManagerCommandCreate()
4711             clusterManagerNode *found = NULL, *slave = NULL;  in clusterManagerCommandCreate()
4714                 clusterManagerNode *n = interleaved[j];  in clusterManagerCommandCreate()
4755             clusterManagerNode *node = ln->value;  in clusterManagerCommandCreate()
4773             clusterManagerNode *node = ln->value;  in clusterManagerCommandCreate()
4782         clusterManagerNode *first = NULL;  in clusterManagerCommandCreate()
4785             clusterManagerNode *node = ln->value;  in clusterManagerCommandCreate()
4815             clusterManagerNode *node = ln->value;  in clusterManagerCommandCreate()
4830         clusterManagerNode *first_node = NULL;  in clusterManagerCommandCreate()
4832             clusterManagerNode *node = ln->value;  in clusterManagerCommandCreate()
4867     clusterManagerNode *refnode = clusterManagerNewNode(ref_ip, ref_port);  in clusterManagerCommandAddNode()
4873     clusterManagerNode *master_node = NULL;  in clusterManagerCommandAddNode()
4891     clusterManagerNode *new_node = clusterManagerNewNode(ip, port);  in clusterManagerCommandAddNode()
4918     clusterManagerNode *first = listFirst(cluster_manager.nodes)->value;  in clusterManagerCommandAddNode()
4961     clusterManagerNode *ref_node = clusterManagerNewNode(ip, port);  in clusterManagerCommandDeleteNode()
4962     clusterManagerNode *node = NULL;  in clusterManagerCommandDeleteNode()
4986         clusterManagerNode *n = ln->value;  in clusterManagerCommandDeleteNode()
4990             clusterManagerNode *master = clusterManagerNodeWithLeastReplicas();  in clusterManagerCommandDeleteNode()
5022     clusterManagerNode *node = clusterManagerNewNode(ip, port);  in clusterManagerCommandInfo()
5035     clusterManagerNode *node = clusterManagerNewNode(ip, port);  in clusterManagerCommandCheck()
5053     clusterManagerNode *node = clusterManagerNewNode(ip, port);  in clusterManagerCommandReshard()
5097     clusterManagerNode *target = clusterNodeForResharding(to, NULL, &raise_err);  in clusterManagerCommandReshard()
5123                 clusterManagerNode *src =  in clusterManagerCommandReshard()
5140                 clusterManagerNode *src =  in clusterManagerCommandReshard()
5154                 clusterManagerNode *src =  in clusterManagerCommandReshard()
5170             clusterManagerNode *n = ln->value;  in clusterManagerCommandReshard()
5186         clusterManagerNode *src = ln->value;  in clusterManagerCommandReshard()
5239     clusterManagerNode **weightedNodes = NULL;  in clusterManagerCommandRebalance()
5242     clusterManagerNode *node = clusterManagerNewNode(ip, port);  in clusterManagerCommandRebalance()
5255             clusterManagerNode *n = clusterManagerNodeByAbbreviatedName(name);  in clusterManagerCommandRebalance()
5274         clusterManagerNode *n = ln->value;  in clusterManagerCommandRebalance()
5285     weightedNodes = zmalloc(nodes_involved * sizeof(clusterManagerNode *));  in clusterManagerCommandRebalance()
5303         clusterManagerNode *n = ln->value;  in clusterManagerCommandRebalance()
5335             clusterManagerNode *n = ln->value;  in clusterManagerCommandRebalance()
5343     qsort(weightedNodes, nodes_involved, sizeof(clusterManagerNode *),  in clusterManagerCommandRebalance()
5350             clusterManagerNode *n = weightedNodes[i];  in clusterManagerCommandRebalance()
5364         clusterManagerNode *dst = weightedNodes[dst_idx];  in clusterManagerCommandRebalance()
5365         clusterManagerNode *src = weightedNodes[src_idx];  in clusterManagerCommandRebalance()
5437     clusterManagerNode *node = clusterManagerNewNode(ip, port);  in clusterManagerCommandSetTimeout()
5447         clusterManagerNode *n = ln->value;  in clusterManagerCommandSetTimeout()
5506     clusterManagerNode *refnode = clusterManagerNewNode(ip, port);  in clusterManagerCommandImport()
5542     clusterManagerNode  *slots_map[CLUSTER_MANAGER_SLOTS];  in clusterManagerCommandImport()
5549             clusterManagerNode *n = ln->value;  in clusterManagerCommandImport()
5591             clusterManagerNode *target = slots_map[slot];  in clusterManagerCommandImport()
5626     clusterManagerNode *refnode = clusterManagerNewNode(ip, port);  in clusterManagerCommandCall()
5641         clusterManagerNode *n = ln->value;  in clusterManagerCommandCall()