Method processChanges

src/db.cpp:2930–2981

}

bool redisDbPersistentData::processChanges(bool fSnapshot)
{
    serverAssert(GlobalLocksAcquired());

    --m_fTrackingChanges;
    serverAssert(m_fTrackingChanges >= 0);

    if (m_spstorage != nullptr)
    {
        if (!m_fAllChanged && dictSize(m_dictChanged) == 0 && m_cnewKeysPending == 0)
            return false;
        m_spstorage->beginWriteBatch();
        serverAssert(m_pdbSnapshotStorageFlush == nullptr);
        if (fSnapshot && !m_fAllChanged && dictSize(m_dictChanged) > 100)
        {
            // Do a snapshot based process if possible
            m_pdbSnapshotStorageFlush = createSnapshot(getMvccTstamp(), true /* optional */);
            if (m_pdbSnapshotStorageFlush)
            {
                if (m_dictChangedStorageFlush)
                    dictRelease(m_dictChangedStorageFlush);
                m_dictChangedStorageFlush = m_dictChanged;
                m_dictChanged = dictCreate(&dictChangeDescType, nullptr);
            }
        }
        
        if (m_pdbSnapshotStorageFlush == nullptr)
        {
            if (m_fAllChanged)
            {
                if (dictSize(m_pdict) > 0 || m_spstorage->count() > 0) { // in some cases we may have pre-sized the StorageCache's dict, and we don't want clear to ruin it
                    m_spstorage->clearAsync();
                    storeDatabase();
                }
                m_fAllChanged = 0;
            }
            else
            {
                dictIterator *di = dictGetIterator(m_dictChanged);
                dictEntry *de;
                while ((de = dictNext(di)) != nullptr)
                {
                    serializeAndStoreChange(m_spstorage.get(), this, (const char*)dictGetKey(de), (bool)dictGetVal(de));
                }
                dictReleaseIterator(di);
            }
        }
        dictEmpty(m_dictChanged, nullptr);
        m_cnewKeysPending = 0;
    }
    return (m_spstorage != nullptr);
}

void redisDbPersistentData::processChangesAsync(std::atomic<int> &pendingJobs)
{