Function delKeysInSlot

src/db.cpp:2557–2591

Remove all the keys in the specified hash slot. * The number of removed items is returned. */

/* Remove all the keys in the specified hash slot.
 * The number of removed items is returned. */
unsigned int delKeysInSlot(unsigned int hashslot) {
    serverAssert(GlobalLocksAcquired());
    if (g_pserver->m_pstorageFactory != nullptr) {
        int j = 0;
        g_pserver->db[0]->getStorageCache()->enumerate_hashslot([&](const char *key, size_t cchKey, const void *, size_t )->bool {
            robj *keyobj = createStringObject(key, cchKey);
            dbDelete(g_pserver->db[0], keyobj);
            decrRefCount(keyobj);
            j++;
            return true;
        }, hashslot);
        return j;
    } else {
        raxIterator iter;
        int j = 0;
        unsigned char indexed[2];

        indexed[0] = (hashslot >> 8) & 0xff;
        indexed[1] = hashslot & 0xff;
        raxStart(&iter,g_pserver->cluster->slots_to_keys);
        while(g_pserver->cluster->slots_keys_count[hashslot]) {
            raxSeek(&iter,">=",indexed,2);
            raxNext(&iter);

            auto count = g_pserver->cluster->slots_keys_count[hashslot];
            robj *key = createStringObject((char*)iter.key+2,iter.key_len-2);
            dbDelete(g_pserver->db[0],key);
            serverAssert(count > g_pserver->cluster->slots_keys_count[hashslot]);   // we should have deleted something or we will be in an infinite loop
            decrRefCount(key);
            j++;
        }
        raxStop(&iter);
        return j;
    }
}

unsigned int countKeysInSlot(unsigned int hashslot) {
    return g_pserver->cluster->slots_keys_count[hashslot];