Searched refs:hashslot (Results 1 – 5 of 5) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | db.c | 1476 server.cluster->slots_keys_count[hashslot] += add ? 1 : -1; in slotToKeyUpdateKey()
1478 indexed[0] = (hashslot >> 8) & 0xff; in slotToKeyUpdateKey()
1479 indexed[1] = hashslot & 0xff; in slotToKeyUpdateKey()
1512 indexed[0] = (hashslot >> 8) & 0xff; in getKeysInSlot()
1513 indexed[1] = hashslot & 0xff; in getKeysInSlot()
1526 unsigned int delKeysInSlot(unsigned int hashslot) { in delKeysInSlot() argument
1531 indexed[0] = (hashslot >> 8) & 0xff; in delKeysInSlot()
1532 indexed[1] = hashslot & 0xff; in delKeysInSlot()
1534 while(server.cluster->slots_keys_count[hashslot]) { in delKeysInSlot()
1547 unsigned int countKeysInSlot(unsigned int hashslot) { in countKeysInSlot() argument
[all …]
|
| H A D | cluster.h | 286 …etNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashslot, int *ask);
288 void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code);
|
| H A D | server.h | 1850 unsigned int getKeysInSlot(unsigned int hashslot, robj **keys, unsigned int count);
1851 unsigned int countKeysInSlot(unsigned int hashslot);
1852 unsigned int delKeysInSlot(unsigned int hashslot);
|
| H A D | cluster.c | 5452 …yQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashslot, int *error_code)… in getNodeByQuery() argument
5576 if (hashslot) *hashslot = slot; in getNodeByQuery()
5631 void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code) { in clusterRedirectClient() argument
5649 hashslot,n->ip,n->port)); in clusterRedirectClient()
|
| H A D | server.c | 2604 int hashslot; in processCommand() local
2607 &hashslot,&error_code); in processCommand()
2614 clusterRedirectClient(c,n,hashslot,error_code); in processCommand()
|