Function launchRdbSaveThread

src/rdb.cpp:1636–1673

}

int launchRdbSaveThread(pthread_t &child, rdbSaveInfo *rsi)
{
    if (cserver.fForkBgSave) {
        return rdbSaveBackgroundFork(rsi);
    } else
    {
        rdbSaveThreadArgs *args = (rdbSaveThreadArgs*)zcalloc(sizeof(rdbSaveThreadArgs) + ((cserver.dbnum-1)*sizeof(redisDbPersistentDataSnapshot*)), MALLOC_LOCAL);
        args = new (args) rdbSaveThreadArgs();
        rdbSaveInfo rsiT;
        if (rsi == nullptr)
            rsi = &rsiT;
        args->rsi = *rsi;
        memcpy(&args->rsi.repl_id, g_pserver->replid, sizeof(g_pserver->replid));
        args->rsi.master_repl_offset = g_pserver->master_repl_offset;
            
        for (int idb = 0; idb < cserver.dbnum; ++idb)
            args->rgpdb[idb] = g_pserver->db[idb]->createSnapshot(getMvccTstamp(), false /* fOptional */);

        g_pserver->rdbThreadVars.tmpfileNum++;
        g_pserver->rdbThreadVars.fRdbThreadCancel = false;
        pthread_attr_t tattr;
        pthread_attr_init(&tattr);
        pthread_attr_setstacksize(&tattr, 1 << 23); // 8 MB
        openChildInfoPipe();
        if (pthread_create(&child, &tattr, rdbSaveThread, args)) {
            pthread_attr_destroy(&tattr);
            for (int idb = 0; idb < cserver.dbnum; ++idb)
                g_pserver->db[idb]->endSnapshot(args->rgpdb[idb]);
            args->~rdbSaveThreadArgs();
            zfree(args);
            closeChildInfoPipe();
            return C_ERR;
        }
        pthread_attr_destroy(&tattr);
        g_pserver->child_type = CHILD_TYPE_RDB;
    }
    return C_OK;
}


int rdbSaveBackground(rdbSaveInfo *rsi) {