Function whileBlockedCron

src/server.cpp:2777–2819

This function fill in the role of serverCron during RDB or AOF loading, and * also during blocked scripts. * It attempts to do its duties at a similar rate as the configured g_pserver->hz, * and updates cronloops variable so that similarly to serverCron, the * run_with_period can be used. */

 * and updates cronloops variable so that similarly to serverCron, the
 * run_with_period can be used. */
void whileBlockedCron() {
    /* Here we may want to perform some cron jobs (normally done g_pserver->hz times
     * per second). */

    /* Since this function depends on a call to blockingOperationStarts, let's
     * make sure it was done. */
    serverAssert(g_pserver->blocked_last_cron);

    /* In case we where called too soon, leave right away. This way one time
     * jobs after the loop below don't need an if. and we don't bother to start
     * latency monitor if this function is called too often. */
    if (g_pserver->blocked_last_cron >= g_pserver->mstime)
        return;

    mstime_t latency;
    latencyStartMonitor(latency);

    /* In some cases we may be called with big intervals, so we may need to do
     * extra work here. This is because some of the functions in serverCron rely
     * on the fact that it is performed every 10 ms or so. For instance, if
     * activeDefragCycle needs to utilize 25% cpu, it will utilize 2.5ms, so we
     * need to call it multiple times. */
    long hz_ms = 1000/g_pserver->hz;
    while (g_pserver->blocked_last_cron < g_pserver->mstime) {

        /* Defrag keys gradually. */
        activeDefragCycle();

        g_pserver->blocked_last_cron += hz_ms;

        /* Increment cronloop so that run_with_period works. */
        g_pserver->cronloops++;
    }

    /* Other cron jobs do not need to be done in a loop. No need to check
     * g_pserver->blocked_last_cron since we have an early exit at the top. */

    /* Update memory stats during loading (excluding blocked scripts) */
    if (g_pserver->loading) cronUpdateMemoryStats();

    latencyEndMonitor(latency);
    latencyAddSampleIfNeeded("while-blocked-cron",latency);
}

extern __thread int ProcessingEventsWhileBlocked;