Function RedisGearsPy_DumpSingleSession

plugins/python/redisgears_python.c:6310–6356

}

static void RedisGearsPy_DumpSingleSession(RedisModuleCtx *ctx, PythonSessionCtx* s, int verbose){
    RedisModule_ReplyWithArray(ctx, 16);
    RedisModule_ReplyWithCString(ctx, "ID");
    RedisModule_ReplyWithCString(ctx, s->sessionId);
    RedisModule_ReplyWithCString(ctx, "sessionDescription");
    if (s->sessionDesc) {
        RedisModule_ReplyWithCString(ctx, s->sessionDesc);
    } else {
        RedisModule_ReplyWithNull(ctx);
    }
    RedisModule_ReplyWithCString(ctx, "refCount");
    RedisModule_ReplyWithLongLong(ctx, s->refCount);
    RedisModule_ReplyWithCString(ctx, "linked");
    RedisModule_ReplyWithCString(ctx, s->linkedTo == LinkedTo_None ? "None" : s->linkedTo == LinkedTo_PrimaryDict ? "primary" : "temprary");
    RedisModule_ReplyWithCString(ctx, "dead");
    RedisModule_ReplyWithCString(ctx, s->deadNode ? "true" : "false");
    RedisModule_ReplyWithCString(ctx, "requirementInstallationNeeded");
    RedisModule_ReplyWithLongLong(ctx, s->isInstallationNeeded);
    RedisModule_ReplyWithCString(ctx, "requirements");
    RedisModule_ReplyWithArray(ctx, array_len(s->requirements));
    for(size_t i = 0 ; i < array_len(s->requirements) ; ++i) {
        PythonRequirementCtx* req = s->requirements[i];
        if (verbose) {
            RedisGearsPy_SendReqMetaData(ctx, req);
        } else {
            RedisModule_ReplyWithCString(ctx, req->installName);
        }
    }
    RedisModule_ReplyWithCString(ctx, "registrations");

    PythonSessionCtx_RunWithRegistrationsLock(s, {
        RedisModule_ReplyWithArray(ctx, array_len(s->registrations));
        for(size_t i = 0 ; i < array_len(s->registrations) ; ++i) {
            const char *registrationId = s->registrations[i];
            if (verbose) {
                FlatExecutionPlan *fep = RedisGears_GetFepById(registrationId);
                if (!fep) {
                    RedisModule_ReplyWithCString(ctx, registrationId);
                } else {
                    RedisGears_DumpRegistration(ctx, fep, REGISTRATION_DUMP_NO_PD);
                }
            } else {
                RedisModule_ReplyWithCString(ctx, registrationId);
            }
        }
    });
}

static int RedisGearsPy_DumpSessions(RedisModuleCtx *ctx, RedisModuleString **argv, int argc){
    pthread_mutex_lock(&PySessionsLock);