Function rdbSaveThread

src/rdb.cpp:1563–1596

};

void *rdbSaveThread(void *vargs)
{
    aeThreadOnline();
    serverAssert(!g_pserver->rdbThreadVars.fDone);
    rdbSaveThreadArgs *args = reinterpret_cast<rdbSaveThreadArgs*>(vargs);
    serverAssert(serverTL == nullptr);
    redisServerThreadVars vars;
    serverTL = &vars;
    vars.gcEpoch = g_pserver->garbageCollector.startEpoch();

    int retval = rdbSave(args->rgpdb, &args->rsi);    
    if (retval == C_OK)
        sendChildCowInfo(CHILD_INFO_TYPE_RDB_COW_SIZE, "RDB");

    // If we were told to cancel the requesting thread holds the lock for us
    ssize_t cbStart = zmalloc_used_memory();
    for (int idb = 0; idb < cserver.dbnum; ++idb)
        g_pserver->db[idb]->endSnapshotAsync(args->rgpdb[idb]);

    args->~rdbSaveThreadArgs();
    zfree(args);
    ssize_t cbDiff = (cbStart - (ssize_t)zmalloc_used_memory());
    g_pserver->garbageCollector.endEpoch(vars.gcEpoch);

    if (cbDiff > 0)
    {
        serverLog(LL_NOTICE,
                "%s: %zd MB of memory used by copy-on-write",
                "RDB",cbDiff/(1024*1024));
    }
    aeThreadOffline();
    g_pserver->rdbThreadVars.fDone = true;
    return (retval == C_OK) ? (void*)0 : (void*)1;
}

int rdbSaveBackgroundFork(rdbSaveInfo *rsi) {
    pid_t childpid;