Function moduleDefragValue

src/module.cpp:9389–9422

Attempt to defrag a module data type value. Depending on complexity, * the operation may happen immediately or be scheduled for later. * * Returns 1 if the operation has been completed or 0 if it needs to * be scheduled for late defrag. */

 * be scheduled for late defrag.
 */
int moduleDefragValue(robj *key, robj *value, long *defragged) {
    moduleValue *mv = (moduleValue*)ptrFromObj(value);
    moduleType *mt = mv->type;

    /* Try to defrag moduleValue itself regardless of whether or not
     * defrag callbacks are provided.
     */
    moduleValue *newmv = (moduleValue*)activeDefragAlloc(mv);
    if (newmv) {
        (*defragged)++;
        value->m_ptr = mv = newmv;
    }

    if (!mt->defrag)
        return 1;

    /* Use free_effort to determine complexity of module value, and if
     * necessary schedule it for defragLater instead of quick immediate
     * defrag.
     */
    if (mt->free_effort) {
        size_t effort = mt->free_effort(key, mv->value);
        if (!effort)
            effort = SIZE_MAX;
        if (effort > cserver.active_defrag_max_scan_fields) {
            return 0;  /* Defrag later */
        }
    }

    RedisModuleDefragCtx defrag_ctx = { 0, 0, NULL };
    mt->defrag(&defrag_ctx, key, &mv->value);
    (*defragged) += defrag_ctx.defragged;
    return 1;
}

/* Call registered module API defrag functions */
long moduleDefragGlobals(void) {