Function RedisGearsPy_LoadRegistrations

plugins/python/redisgears_python.c:7069–7119

}

static int RedisGearsPy_LoadRegistrations(RedisModuleIO *rdb, int encver, int when){
    if(encver > REDISGEARSPY_REQ_DATATYPE_VERSION){
        RedisModule_LogIOError(rdb, "warning", "Give requirement version is not supported, please upgrade to newer RedisGears.");
        return REDISMODULE_ERR;
    }

    RedisGearsPy_ClearAllData();

    char* err = NULL;
    char *data = NULL;
    PythonRequirementCtx* req = NULL;
    while(RedisModule_LoadUnsigned(rdb)){
        size_t len;
        char *data = RedisModule_LoadStringBuffer(rdb, &len);
        Gears_Buffer buff = {
                .buff = data,
                .size = len,
                .cap = len,
        };
        Gears_BufferReader br;
        Gears_BufferReaderInit(&br, &buff);
        req = PythonRequirement_Deserialize(&br, &err);
        if(!req){
            goto error;
        }

        // now we also need to install the requirement
        if(!PythonRequirementCtx_InstallRequirement(req)){
            err = RG_STRDUP("Failed install requirement on shard, check shard log for more info.");
            goto error;
        }

        RedisModule_Free(data);
        PythonRequirementCtx_Free(req);
    }
    return REDISMODULE_OK;

error:
    RedisModule_LogIOError(rdb, "warning", "Failed deserialize requirements (%s)", err ? err : "unknown error");
    if(err){
        RG_FREE(err);
    }
    if(data){
        RedisModule_Free(data);
    }
    if(req){
        PythonRequirementCtx_Free(req);
    }
    RedisGearsPy_ClearRequirements();
    return REDISMODULE_ERR;
}

static void RedisGearsPy_SaveRegistrations(RedisModuleIO *rdb, int when){
    Gears_dictIterator *iter = Gears_dictGetIterator(RequirementsDict);