Lines Matching refs:listLength
3535 int consistent = (listLength(cluster_manager.nodes) <= 1); in clusterManagerIsConfigConsistent()
3721 if (listLength(slot_nodes) > 1) in clusterManagerFixSlotsCoverage()
3729 key, listLength(slot_nodes), slot_nodes_str); in clusterManagerFixSlotsCoverage()
3747 switch (listLength(nodes)){ in clusterManagerFixSlotsCoverage()
3756 if (listLength(none) > 0) { in clusterManagerFixSlotsCoverage()
3783 if (listLength(single) > 0) { in clusterManagerFixSlotsCoverage()
3814 if (listLength(multi) > 0) { in clusterManagerFixSlotsCoverage()
3918 if (listLength(owners) == 1) owner = listFirst(owners)->value; in clusterManagerFixOpenSlot()
3928 char *sep = (listLength(migrating) == 0 ? "" : ","); in clusterManagerFixOpenSlot()
3941 char *sep = (listLength(importing) == 0 ? "" : ","); in clusterManagerFixOpenSlot()
3961 char *sep = (listLength(importing) == 0 ? "" : ","); in clusterManagerFixOpenSlot()
4017 if (listLength(owners) > 1) { in clusterManagerFixOpenSlot()
4043 if (listLength(migrating) == 1 && listLength(importing) == 1) { in clusterManagerFixOpenSlot()
4056 else if (listLength(migrating) == 0 && listLength(importing) > 0) { in clusterManagerFixOpenSlot()
4091 else if (listLength(migrating) == 1 && listLength(importing) > 1) { in clusterManagerFixOpenSlot()
4149 int try_to_close_slot = (listLength(importing) == 0 && in clusterManagerFixOpenSlot()
4150 listLength(migrating) == 1); in clusterManagerFixOpenSlot()
4199 assert(listLength(owners) > 1); in clusterManagerFixMultipleSlotOwners()
4369 if (listLength(owners) > 1) { in clusterManagerCheckCluster()
4372 slot, listLength(owners)); in clusterManagerCheckCluster()
4420 int src_count = listLength(sources), i = 0, tot_slots = 0, j; in clusterManagerComputeReshardTable()
4441 if (count >= max || (int)listLength(moved) >= numslots) break; in clusterManagerComputeReshardTable()
5056 if (cluster_manager.errors && listLength(cluster_manager.errors) > 0) { in clusterManagerCommandReshard()
5108 printf("Source node #%lu: ", listLength(sources) + 1); in clusterManagerCommandReshard()
5177 if (listLength(sources) == 0) { in clusterManagerCommandReshard()
5289 if (cluster_manager.errors && listLength(cluster_manager.errors) > 0) { in clusterManagerCommandRebalance()
5380 int table_len = (int) listLength(table); in clusterManagerCommandRebalance()