Lines Matching refs:CLUSTER_SLOTS

121     maxline = 1024+CLUSTER_SLOTS*128;  in clusterLoadConfig()
506 for (j = 0; j < CLUSTER_SLOTS; j++) clusterDelSlot(j); in clusterReset()
869 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterDelNode()
1452 uint16_t dirty_slots[CLUSTER_SLOTS]; in clusterUpdateSlotsConfigWith()
1465 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterUpdateSlotsConfigWith()
1849 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterProcessPacket()
2541 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterSendFailoverAuthIfNeeded()
2677 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterFailoverReplaceYourMaster()
3442 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterDelNodeSlots()
3495 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterUpdateState()
3603 for (j = 0; j < CLUSTER_SLOTS; j++) { in verifyClusterConfigWithData()
3724 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterGenNodeDescription()
3730 if (start != -1 && (!bit || j == CLUSTER_SLOTS-1)) { in clusterGenNodeDescription()
3731 if (bit && j == CLUSTER_SLOTS-1) j++; in clusterGenNodeDescription()
3746 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterGenNodeDescription()
3798 slot < 0 || slot >= CLUSTER_SLOTS) in getSlotOrReply()
3831 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterReplyMultiBulkSlots()
3837 if (start != -1 && (!bit || j == CLUSTER_SLOTS-1)) { in clusterReplyMultiBulkSlots()
3841 if (bit && j == CLUSTER_SLOTS-1) j++; in clusterReplyMultiBulkSlots()
3932 unsigned char *slots = zmalloc(CLUSTER_SLOTS); in clusterCommand()
3935 memset(slots,0,CLUSTER_SLOTS); in clusterCommand()
3959 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterCommand()
4087 for (j = 0; j < CLUSTER_SLOTS; j++) { in clusterCommand()
4151 if (slot < 0 || slot >= CLUSTER_SLOTS) { in clusterCommand()
4167 if (slot < 0 || slot >= CLUSTER_SLOTS || maxkeys < 0) { in clusterCommand()