509318396 ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ U UV @sdddlmZmZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z GdddeZdS))absolute_importdivisionN)LockBase LockFailed NotLocked NotMyLock LockTimeout AlreadyLockedc@sDeZdZdZdddZdddZdd Zd d Zd d ZddZ dS) MkdirLockFilez"Lock file by creating a directory.TNcCs6t||||tj|jd|j|j|jf|_ dS)zs >>> lock = MkdirLockFile('somefile') >>> lock = MkdirLockFile('somefile', threaded=False) z%s.%s%sN) r__init__ospathjoin lock_filehostnametnamepid unique_name)selfrZthreadedtimeoutrG/opt/alt/python38/lib/python3.8/site-packages/lockfile/mkdirlockfile.pyr s zMkdirLockFile.__init__cCs|dk r |n|j}t}|dk r2|dkr2||7}|dkr@d}ntd|d}zt|jWntk rtd}|j t j krtj |j rYdS|dk rt|kr|dkrtd|j ntd|j t|ntd|jYqNXt|j ddSqNdS) Nrg? rz&Timeout waiting to acquire lock for %sz%s is already lockedzfailed to create %swb)rtimemaxr mkdirrOSErrorsysexc_infoerrnoEEXISTrexistsrr r sleepropenclose)rrend_timewaiterrrrracquires4   zMkdirLockFile.acquirecCsP|std|jntj|js4td|jt|jt|j dS)Nz%s is not lockedz%s is locked, but not by me) is_lockedrrr r#rrunlinkrmdirrrrrrreleaseAs  zMkdirLockFile.releasecCstj|jSN)r rr#rr.rrrr+IszMkdirLockFile.is_lockedcCs|otj|jSr0)r+r rr#rr.rrr i_am_lockingLs zMkdirLockFile.i_am_lockingcCsFtj|jrBt|jD]}ttj|j|qt|jdSr0)r rr#rlistdirr,rr-)rnamerrr break_lockPszMkdirLockFile.break_lock)TN)N) __name__ __module__ __qualname____doc__r r*r/r+r1r4rrrrr s &r ) __future__rrrr rr!rrrrr r r rrrrs