Function PythonSessionCtx_Unlink

plugins/python/redisgears_python.c:703–719

}

static void PythonSessionCtx_Unlink(PythonSessionCtx* session){
    /* Unlink requirements if we are the only owner */
    for(size_t i = 0 ; i < array_len(session->requirements) ; ++i){
        PythonRequirementCtx* req = session->requirements[i];
        if (req->refCount == 2) {
            /* We are the only owner together with the requiremnets dictionary */
            Gears_dictDelete(RequirementsDict, req->installName);
            req->isInRequirementsDict = false;
            PythonRequirementCtx_Free(req);
        }
    }
    pthread_mutex_lock(&PySessionsLock);
    PythonSessionCtx_Del(session);
    Gears_listAddNodeTail(DeadSessionsList, session);
    session->deadNode = Gears_listLast(DeadSessionsList);
    pthread_mutex_unlock(&PySessionsLock);
}

static void PythonSessionCtx_Free(PythonSessionCtx* session){
    pthread_mutex_lock(&PySessionsLock);