Method iterate

src/db.cpp:963–1012

}

bool redisDbPersistentData::iterate(std::function<bool(const char*, robj*)> fn)
{
    dictIterator *di = dictGetSafeIterator(m_pdict);
    dictEntry *de = nullptr;
    bool fResult = true;
    while(fResult && ((de = dictNext(di)) != nullptr))
    {
        if (!fn((const char*)dictGetKey(de), (robj*)dictGetVal(de)))
            fResult = false;
    }
    dictReleaseIterator(di);

    if (m_spstorage != nullptr)
    {
        bool fSawAll = fResult && m_spstorage->enumerate([&](const char *key, size_t cchKey, const void *, size_t )->bool{
            sds sdsKey = sdsnewlen(key, cchKey);
            bool fContinue = true;
            if (dictFind(m_pdict, sdsKey) == nullptr)
            {
                ensure(sdsKey, &de);
                fContinue = fn((const char*)dictGetKey(de), (robj*)dictGetVal(de));
                removeCachedValue(sdsKey);
            }
            sdsfree(sdsKey);
            return fContinue;
        });
        return fSawAll;
    }

    if (fResult && m_pdbSnapshot != nullptr)
    {
        fResult = m_pdbSnapshot->iterate_threadsafe([&](const char *key, robj_roptr){
            // Before passing off to the user we need to make sure it's not already in the
            //  the current set, and not deleted
            dictEntry *deCurrent = dictFind(m_pdict, key);
            if (deCurrent != nullptr)
                return true;
            dictEntry *deTombstone = dictFind(m_pdictTombstone, key);
            if (deTombstone != nullptr)
                return true;

            // Alright it's a key in the use keyspace, lets ensure it and then pass it off
            ensure(key);
            deCurrent = dictFind(m_pdict, key);
            return fn(key, (robj*)dictGetVal(deCurrent));
        }, true /*fKeyOnly*/);
    }
    
    return fResult;
}

client *createAOFClient(void);
void freeFakeClient(client *);