Function PythonRequirementCtx_Serialize

plugins/python/redisgears_python.c:623–670

}

static int PythonRequirementCtx_Serialize(PythonRequirementCtx* req, Gears_BufferWriter* bw, char** err){
    if(!req->isDownloaded){
        // requirement is not downloaded yet and so we can not serialized it
        // this can only happened if rdb save was trigger before download
        // completed. In this case rdb will not contains this requirement.
        // It will succeded next time.
        *err = RG_STRDUP("Requirement was not installed yet");
        return REDISMODULE_ERR;
    }
    RedisGears_BWWriteString(bw, req->installName);
    RedisGears_BWWriteString(bw, RedisGears_GetCompiledOs());
    RedisGears_BWWriteLong(bw, req->isInRequirementsDict);
    RedisGears_BWWriteLong(bw, array_len(req->wheels));
    for(size_t i = 0 ; i < array_len(req->wheels) ; ++i){
        char* wheel = req->wheels[i];
        char* filePath;
        RedisGears_ASprintf(&filePath, "%s/%s", req->basePath, wheel);

        FILE *f = fopen(filePath, "rb");
        if(!f){
            RedisGears_ASprintf(err, "Could not open file %s", filePath);
            RG_FREE(filePath);
            RedisModule_Log(staticCtx, "warning", "%s", *err);
            return REDISMODULE_ERR;
        }
        fseek(f, 0, SEEK_END);
        long fsize = ftell(f);
        fseek(f, 0, SEEK_SET);  /* same as rewind(f); */

        char *data = RG_ALLOC(fsize);
        size_t readData = fread(data, 1, fsize, f);
        if(readData != fsize){
            RedisGears_ASprintf(err, "Could read data from file %s", filePath);
            RG_FREE(data);
            RG_FREE(filePath);
            RedisModule_Log(staticCtx, "warning", "%s", *err);
            return REDISMODULE_ERR;
        }
        fclose(f);

        RedisGears_BWWriteString(bw, wheel);
        RedisGears_BWWriteBuffer(bw, data, fsize);

        RG_FREE(data);
        RG_FREE(filePath);
    }
    return REDISMODULE_OK;
}

static int PythonRequirement_Serialize(PythonRequirementCtx* req, Gears_BufferWriter* bw, char** err){
    RedisGears_BWWriteLong(bw, PY_REQ_VERSION);