Function GetPythonThreadCtx

plugins/python/redisgears_python.c:1131–1148

}

static PythonThreadCtx* GetPythonThreadCtx(){
    PythonThreadCtx* ptctx = pthread_getspecific(pythonThreadCtxKey);
    if(!ptctx){
        ptctx = RG_ALLOC(sizeof(*ptctx));
        *ptctx = (PythonThreadCtx){
                .lockCounter = 0,
                .currentCtx = NULL,
                .createdExecution = NULL,
                .doneFunction = onDone,
                .flags = 0,
                .crtCtx = NULL,
                .commandCtx = NULL,
                .pyfutureCreated = NULL,
        };
        pthread_setspecific(pythonThreadCtxKey, ptctx);
    }
    return ptctx;
}

bool RedisGearsPy_IsLockAcquired(){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();