Method ProcessWhileBlocked

src/rdb.cpp:2847–2862

    }

    void ProcessWhileBlocked() {
        if ((mstime() - lastPing) > 1000) { // Ping if its been a second or longer
            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);
            }
            lastPing = mstime();
        }

        processEventsWhileBlocked(serverTL - g_pserver->rgthreadvar);
    }

    size_t ckeys() { return ckeysLoaded; }