Lines Matching refs:slots

418     memset(server.cluster->slots,0, sizeof(server.cluster->slots));  in clusterInit()
663 memset(node->slots,0,sizeof(node->slots)); in createClusterNode()
874 if (server.cluster->slots[j] == delnode) in clusterDelNode()
1442 …usterUpdateSlotsConfigWith(clusterNode *sender, uint64_t senderConfigEpoch, unsigned char *slots) { in clusterUpdateSlotsConfigWith() argument
1466 if (bitmapTestBit(slots,j)) { in clusterUpdateSlotsConfigWith()
1468 if (server.cluster->slots[j] == sender) continue; in clusterUpdateSlotsConfigWith()
1480 if (server.cluster->slots[j] == NULL || in clusterUpdateSlotsConfigWith()
1481 server.cluster->slots[j]->configEpoch < senderConfigEpoch) in clusterUpdateSlotsConfigWith()
1485 if (server.cluster->slots[j] == myself && in clusterUpdateSlotsConfigWith()
1493 if (server.cluster->slots[j] == curmaster) in clusterUpdateSlotsConfigWith()
1817 dirty_slots = memcmp(sender_master->slots, in clusterProcessPacket()
1851 if (server.cluster->slots[j] == sender || in clusterProcessPacket()
1852 server.cluster->slots[j] == NULL) continue; in clusterProcessPacket()
1853 if (server.cluster->slots[j]->configEpoch > in clusterProcessPacket()
1859 sender->name, server.cluster->slots[j]->name); in clusterProcessPacket()
1861 server.cluster->slots[j]); in clusterProcessPacket()
1974 hdr->data.update.nodecfg.slots); in clusterProcessPacket()
2137 memcpy(hdr->myslots,master->slots,sizeof(hdr->myslots)); in clusterBuildMessageHdr()
2399 memcpy(hdr->data.update.nodecfg.slots,node->slots,sizeof(node->slots)); in clusterSendUpdate()
2543 if (server.cluster->slots[j] == NULL || in clusterSendFailoverAuthIfNeeded()
2544 server.cluster->slots[j]->configEpoch <= requestConfigEpoch) in clusterSendFailoverAuthIfNeeded()
2555 (unsigned long long) server.cluster->slots[j]->configEpoch, in clusterSendFailoverAuthIfNeeded()
3378 int old = bitmapTestBit(n->slots,slot); in clusterNodeSetSlotBit()
3379 bitmapSetBit(n->slots,slot); in clusterNodeSetSlotBit()
3403 int old = bitmapTestBit(n->slots,slot); in clusterNodeClearSlotBit()
3404 bitmapClearBit(n->slots,slot); in clusterNodeClearSlotBit()
3411 return bitmapTestBit(n->slots,slot); in clusterNodeGetSlotBit()
3419 if (server.cluster->slots[slot]) return C_ERR; in clusterAddSlot()
3421 server.cluster->slots[slot] = n; in clusterAddSlot()
3429 clusterNode *n = server.cluster->slots[slot]; in clusterDelSlot()
3433 server.cluster->slots[slot] = NULL; in clusterDelSlot()
3496 if (server.cluster->slots[j] == NULL || in clusterUpdateState()
3497 server.cluster->slots[j]->flags & (CLUSTER_NODE_FAIL)) in clusterUpdateState()
3608 if (server.cluster->slots[j] == myself || in verifyClusterConfigWithData()
3617 if (server.cluster->slots[j] == NULL) { in verifyClusterConfigWithData()
3625 server.cluster->importing_slots_from[j] = server.cluster->slots[j]; in verifyClusterConfigWithData()
3932 unsigned char *slots = zmalloc(CLUSTER_SLOTS); in clusterCommand() local
3935 memset(slots,0,CLUSTER_SLOTS); in clusterCommand()
3940 zfree(slots); in clusterCommand()
3943 if (del && server.cluster->slots[slot] == NULL) { in clusterCommand()
3945 zfree(slots); in clusterCommand()
3947 } else if (!del && server.cluster->slots[slot]) { in clusterCommand()
3949 zfree(slots); in clusterCommand()
3952 if (slots[slot]++ == 1) { in clusterCommand()
3955 zfree(slots); in clusterCommand()
3960 if (slots[j]) { in clusterCommand()
3973 zfree(slots); in clusterCommand()
3992 if (server.cluster->slots[slot] != myself) { in clusterCommand()
4003 if (server.cluster->slots[slot] == myself) { in clusterCommand()
4029 if (server.cluster->slots[slot] == myself && n != myself) { in clusterCommand()
4088 clusterNode *n = server.cluster->slots[j]; in clusterCommand()
5026 n = server.cluster->slots[slot]; in getNodeByQuery()
5194 clusterNode *node = server.cluster->slots[slot]; in clusterRedirectBlockedClientIfNeeded()