Lines Matching refs:cluster_manager

1900 } cluster_manager;  variable
2151 if (cluster_manager.nodes != NULL) { in freeClusterManager()
2152 listRewind(cluster_manager.nodes,&li); in freeClusterManager()
2157 listRelease(cluster_manager.nodes); in freeClusterManager()
2158 cluster_manager.nodes = NULL; in freeClusterManager()
2160 if (cluster_manager.errors != NULL) { in freeClusterManager()
2161 listRewind(cluster_manager.errors,&li); in freeClusterManager()
2166 listRelease(cluster_manager.errors); in freeClusterManager()
2167 cluster_manager.errors = NULL; in freeClusterManager()
2296 if (cluster_manager.nodes == NULL) return NULL; in clusterManagerNodeByName()
2303 listRewind(cluster_manager.nodes, &li); in clusterManagerNodeByName()
2321 if (cluster_manager.nodes == NULL) return NULL; in clusterManagerNodeByAbbreviatedName()
2328 listRewind(cluster_manager.nodes, &li); in clusterManagerNodeByAbbreviatedName()
2429 int node_len = cluster_manager.nodes->len; in clusterManagerGetAntiAffinityScore()
2474 listRewind(cluster_manager.nodes, &li); in clusterManagerGetAntiAffinityScore()
2501 int node_len = cluster_manager.nodes->len; in clusterManagerOptimizeAntiAffinity()
2526 listRewind(cluster_manager.nodes, &li); in clusterManagerOptimizeAntiAffinity()
2684 listRewind(cluster_manager.nodes, &li); in clusterManagerShowNodes()
2698 listRewind(cluster_manager.nodes, &li); in clusterManagerShowClusterInfo()
2710 listRewind(cluster_manager.nodes, &ri); in clusterManagerShowClusterInfo()
3088 listRewind(cluster_manager.nodes, &li); in clusterManagerMoveSlot()
3370 if (cluster_manager.nodes != NULL) { in clusterManagerLoadInfoFromNode()
3371 listRewind(cluster_manager.nodes, &li); in clusterManagerLoadInfoFromNode()
3374 listRelease(cluster_manager.nodes); in clusterManagerLoadInfoFromNode()
3376 cluster_manager.nodes = listCreate(); in clusterManagerLoadInfoFromNode()
3377 listAddNodeTail(cluster_manager.nodes, node); in clusterManagerLoadInfoFromNode()
3391 listAddNodeTail(cluster_manager.nodes, friend); in clusterManagerLoadInfoFromNode()
3406 listRewind(cluster_manager.nodes, &li); in clusterManagerLoadInfoFromNode()
3534 if (cluster_manager.nodes == NULL) return 0; in clusterManagerIsConfigConsistent()
3535 int consistent = (listLength(cluster_manager.nodes) <= 1); in clusterManagerIsConfigConsistent()
3541 listRewind(cluster_manager.nodes, &li); in clusterManagerIsConfigConsistent()
3562 if (cluster_manager.errors == NULL) in clusterManagerOnError()
3563 cluster_manager.errors = listCreate(); in clusterManagerOnError()
3564 listAddNodeTail(cluster_manager.errors, err); in clusterManagerOnError()
3572 if (cluster_manager.nodes == NULL) return 0; in clusterManagerGetCoveredSlots()
3575 listRewind(cluster_manager.nodes, &li); in clusterManagerGetCoveredSlots()
3649 listRewind(cluster_manager.nodes, &li); in clusterManagerNodeWithLeastReplicas()
3668 listRewind(cluster_manager.nodes, &li); in clusterManagerNodeMasterRandom()
3677 listRewind(cluster_manager.nodes, &li); in clusterManagerNodeMasterRandom()
3706 listRewind(cluster_manager.nodes, &li); in clusterManagerFixSlotsCoverage()
3899 listRewind(cluster_manager.nodes, &li); in clusterManagerFixOpenSlot()
3919 listRewind(cluster_manager.nodes, &li); in clusterManagerFixOpenSlot()
3979 owner = clusterManagerGetNodeWithMostKeysInSlot(cluster_manager.nodes, in clusterManagerFixOpenSlot()
4073 listRewind(cluster_manager.nodes, &li); in clusterManagerFixOpenSlot()
4210 listRewind(cluster_manager.nodes, &li); in clusterManagerFixMultipleSlotOwners()
4234 listNode *ln = listFirst(cluster_manager.nodes); in clusterManagerCheckCluster()
4255 listRewind(cluster_manager.nodes, &li); in clusterManagerCheckCluster()
4356 listRewind(cluster_manager.nodes, &li); in clusterManagerCheckCluster()
4567 cluster_manager.nodes = NULL; in clusterManagerMode()
4582 cluster_manager.nodes = listCreate(); in clusterManagerCommandCreate()
4623 listAddNodeTail(cluster_manager.nodes, node); in clusterManagerCommandCreate()
4625 int node_len = cluster_manager.nodes->len; in clusterManagerCommandCreate()
4646 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCreate()
4753 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCreate()
4771 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCreate()
4783 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCreate()
4813 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCreate()
4829 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCreate()
4836 listEmpty(cluster_manager.nodes); in clusterManagerCommandCreate()
4918 clusterManagerNode *first = listFirst(cluster_manager.nodes)->value; in clusterManagerCommandAddNode()
4919 listAddNodeTail(cluster_manager.nodes, new_node); in clusterManagerCommandAddNode()
4984 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandDeleteNode()
5056 if (cluster_manager.errors && listLength(cluster_manager.errors) > 0) { in clusterManagerCommandReshard()
5168 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandReshard()
5271 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandRebalance()
5289 if (cluster_manager.errors && listLength(cluster_manager.errors) > 0) { in clusterManagerCommandRebalance()
5445 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandSetTimeout()
5547 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandImport()
5639 listRewind(cluster_manager.nodes, &li); in clusterManagerCommandCall()