Function rdbLoadProgressCallback

src/rdb.cpp:3044–3090

Track loading progress in order to serve client's from time to time and if needed calculate rdb checksum */

/* Track loading progress in order to serve client's from time to time
   and if needed calculate rdb checksum  */
void rdbLoadProgressCallback(rio *r, const void *buf, size_t len) {
    if (g_pserver->rdb_checksum)
        rioGenericUpdateChecksum(r, buf, len);
    
    if ((g_pserver->loading_process_events_interval_bytes &&
        (r->processed_bytes + len)/g_pserver->loading_process_events_interval_bytes > r->processed_bytes/g_pserver->loading_process_events_interval_bytes) ||
        (g_pserver->loading_process_events_interval_keys &&
        (r->keys_since_last_callback >= g_pserver->loading_process_events_interval_keys)))
    {
        rdbAsyncWorkThread *pwthread = reinterpret_cast<rdbAsyncWorkThread*>(r->chksum_arg);
        mstime_t mstime;
        __atomic_load(&g_pserver->mstime, &mstime, __ATOMIC_RELAXED);
        bool fUpdateReplication = (mstime - r->last_update) > 1000;

        if (fUpdateReplication) {
            listIter li;
            listNode *ln;
            listRewind(g_pserver->masters, &li);
            while ((ln = listNext(&li)))
            {
                struct redisMaster *mi = (struct redisMaster*)listNodeValue(ln);
                if (mi->masterhost && mi->repl_state == REPL_STATE_TRANSFER)
                    replicationSendNewlineToMaster(mi);
            }
        }
        loadingProgress(r->processed_bytes);

        if (pwthread)
            pwthread->pauseExecution();
        processEventsWhileBlocked(serverTL - g_pserver->rgthreadvar);
        if (pwthread)
            pwthread->resumeExecution();

        processModuleLoadingProgressEvent(0);

        if (fUpdateReplication) {
            robj *ping_argv[1];

            ping_argv[0] = createStringObject("PING",4);
            replicationFeedSlaves(g_pserver->slaves, g_pserver->replicaseldb, ping_argv, 1);
            decrRefCount(ping_argv[0]);
        }

        if (fUpdateReplication) r->last_update = g_pserver->mstime;
        r->keys_since_last_callback = 0;
    }
}


/* Load an RDB file from the rio stream 'rdb'. On success C_OK is returned,