Viewing File: /opt/alt/python35/lib/python3.5/site-packages/lockfile/__pycache__/mkdirlockfile.cpython-35.pyc
ùýUV ã @ sŽ d d l m Z m Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m
Z
m Z m Z m
Z
Gd d „ d e ƒ Z d S)é )Úabsolute_importÚdivisionNé )ÚLockBaseÚ
LockFailedÚ NotLockedÚ NotMyLockÚ LockTimeoutÚ
AlreadyLockedc @ sg e Z d Z d Z d d d d „ Z d d d „ Z d d „ Z d
d „ Z d d
„ Z d d „ Z d S)Ú
MkdirLockFilez"Lock file by creating a directory.TNc C sK t j | | | | ƒ t j j | j d | j | j | j f ƒ | _ d S)zs
>>> lock = MkdirLockFile('somefile')
>>> lock = MkdirLockFile('somefile', threaded=False)
z%s.%s%sN)
r Ú__init__ÚosÚpathÚjoinÚ lock_fileÚhostnameZtnameÚpidÚ unique_name)Úselfr ZthreadedÚtimeout© r ú/mkdirlockfile.pyr s
zMkdirLockFile.__init__c C sp | d k r | n | j } t j ƒ } | d k rI | d k rI | | 7} | d k r^ d } n t d | d ƒ } xø y t j | j ƒ Wnà t k
rMt j ƒ d } | j t j
k r6t j j | j
ƒ rÓ d S| d k r&t j ƒ | k r&| d k rt d | j ƒ ‚ n t d | j ƒ ‚ t j | ƒ n t d | j ƒ ‚ Yqt Xt | j
d ƒ j ƒ d Sqt Wd S) Nr gš™™™™™¹?é
r z&Timeout waiting to acquire lock for %sz%s is already lockedzfailed to create %sÚwb)r ÚtimeÚmaxr
Úmkdirr ÚOSErrorÚsysÚexc_infoÚerrnoÚEEXISTr Úexistsr r r
Úsleepr ÚopenÚclose)r r Úend_timeÚwaitÚerrr r r Úacquire s2
zMkdirLockFile.acquirec C sn | j ƒ s" t d | j ƒ ‚ n( t j j | j ƒ sJ t d | j ƒ ‚ t j | j ƒ t j | j ƒ d S)Nz%s is not lockedz%s is locked, but not by me)
Ú is_lockedr r r
r" r r ÚunlinkÚrmdirr )r r r r ÚreleaseA s zMkdirLockFile.releasec C s t j j | j ƒ S)N)r
r r" r )r r r r r* I s zMkdirLockFile.is_lockedc C s | j ƒ o t j j | j ƒ S)N)r* r
r r" r )r r r r Ú i_am_lockingL s zMkdirLockFile.i_am_lockingc C se t j j | j ƒ ra x9 t j | j ƒ D]% } t j t j j | j | ƒ ƒ q( Wt j | j ƒ d S)N)r
r r" r Úlistdirr+ r r, )r Únamer r r Ú
break_lockP s #zMkdirLockFile.break_lock)
Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r) r- r* r. r1 r r r r r s
& r )Z
__future__r r r r
r r Ú r r r r r r
r r r r r Ú<module> s .
Back to Directory
File Manager