*vhDddlZGddeZGddZdS)NceZdZdZdS) DeadlockErrorz6Error raised if DeadlockDetectingLock detects deadlockN)__name__ __module__ __qualname____doc__f/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/internals/deadlock_detecting_lock.pyrrs@@@@r rc*eZdZdZdZdZdZdZdS)DeadlockDetectingLockzp Lock that detects deadlock when it is about to be acquired by the same task that already holds it. cDtj|_d|_dSN)asyncioLock_lock_ownerselfs r __init__zDeadlockDetectingLock.__init__s\^^  r c4|jSr)rlockedrs r rzDeadlockDetectingLock.lockedsz  """r cKtj}|j|krt|jd{V||_|Sr)r current_taskrrracquire)r curr_tasks r __aenter__z DeadlockDetectingLock.__aenter__s](** ;) # #// !j  """""""""  r cJKd|_|jdSr)rrrelease)rexc_typeexctbs r __aexit__zDeadlockDetectingLock.__aexit__s'  r N)rrrrrrrr#r r r r r sZ ###r r )r Exceptionrr r r r r%srAAAAAIAAAr