Function slotToKeyUpdateKeyCore

src/db.cpp:2469–2495

}

void slotToKeyUpdateKeyCore(const char *key, size_t keylen, int add) {
    serverAssert(GlobalLocksAcquired());

    unsigned int hashslot = keyHashSlot(key,keylen);
    g_pserver->cluster->slots_keys_count[hashslot] += add ? 1 : -1;

    if (g_pserver->m_pstorageFactory == nullptr) {
        unsigned char buf[64];
        unsigned char *indexed = buf;

        if (keylen+2 > 64) indexed = (unsigned char*)zmalloc(keylen+2, MALLOC_SHARED);
        indexed[0] = (hashslot >> 8) & 0xff;
        indexed[1] = hashslot & 0xff;
        memcpy(indexed+2,key,keylen);
        int fModified = false;
        if (add) {
            fModified = raxInsert(g_pserver->cluster->slots_to_keys,indexed,keylen+2,NULL,NULL);
        } else {
            fModified = raxRemove(g_pserver->cluster->slots_to_keys,indexed,keylen+2,NULL);
        }
        // This assert is disabled when a snapshot depth is >0 because prepOverwriteForSnapshot will add in a tombstone,
        //  this prevents ensure from adding the key to the dictionary which means the caller isn't aware we're already tracking
        //  the key.
        serverAssert(fModified || g_pserver->db[0]->snapshot_depth() > 0);
        if (indexed != buf) zfree(indexed);
    }
}

void slotToKeyAdd(sds key) {
    slotToKeyUpdateKey(key,1);