Function RedisGearsPy_Lock

plugins/python/redisgears_python.c:1155–1174

}

void RedisGearsPy_Lock(PythonExecutionCtx* pectx){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();

    PythonSessionCtx* oldSession = ptctx->currSession;
    ExecutionCtx* oldEctx = ptctx->currEctx;
    pectx->pyfutureCreated = ptctx->pyfutureCreated;

    ptctx->currSession = pectx->sCtx;
    ptctx->currEctx = pectx->eCtx;
    ptctx->pyfutureCreated = NULL;

    pectx->sCtx = oldSession;
    pectx->eCtx = oldEctx;

    if(ptctx->lockCounter == 0){
        PyGILState_STATE oldState = PyGILState_Ensure();
        RedisModule_Assert(oldState == PyGILState_UNLOCKED);
    }
    ++ptctx->lockCounter;
}

void RedisGearsPy_Unlock(PythonExecutionCtx* oldectx){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();