!SSKrSSKrSSKrSSKrSSKrSSKrSSKJr \R"\ 5r Sr "SS\ 5r "SS\ 5r"SS \ 5r\R S :XaSSKr\rOSSKr\rS rg) N)_utilsc.[R"U5 g![aqnUR[R:Xa*[R R U5(deSnAgUR[R:XaSnAgeSnAff=f)z^Create a directory (and any ancestor directories required). :param path: Directory to create TNF)osmakedirsOSErrorerrnoEEXISTpathisdirEISDIR)r es )lib/third_party/fasteners/process_lock.py _ensure_treersi  D   77ell "77==&& WW $  s! BAB+BBBc\rSrSrSrSrSr\RS4Sjr Sr Sr S \\S4S jr S r S rS rSrSrSrSrSrg)_InterProcessLock4a An interprocess locking implementation. This is a lock implementation which allows multiple locks, working around issues like http://bugs.debian.org/cgi-bin/bugreport.cgi?bug=632857 and does not require any cleanup. Since the lock is always held on a file descriptor rather than outside of the process, the lock gets dropped automatically if the process crashes, even if ``__exit__`` is not executed. There are no guarantees regarding usage by multiple threads in a single process here. This lock works only between processes. Note these locks are released when the descriptor is closed, so it's not safe to close the file descriptor while another thread holds the lock. Just opening and closing the lock file can break synchronization, so lock files must be accessed only using this abstraction. g?g{Gz?NcxSUlXlSUlX l[R "U[ 5Ulg)NF)lockfiler acquired sleep_funcrpick_first_not_noneLOGlogger)selfr rrs r__init___InterProcessLock.__init__Us.   $00= c^UR5 g![anUR[R[R4;a6U(aUR 5(aSnAg[ R"5e[R"SURUS.-5eSnAff=f)NTFz9Unable to acquire lock on `%(path)s` due to %(exception)s)r exception) trylockIOErrorrEACCESEAGAINexpiredr RetryAgain threading ThreadErrorr )rblockingwatchr s r _try_acquire_InterProcessLock._try_acquire\s  LLN  /ww5<<665==??  ++--++-=9= =>-.-.// /s B,A B',;B''B,cf[RRUR5nU(a=[U5nU(a+URR [ RSU5 URbURR(a[URS5Ulgg)NzCreated lock base path `%s`a) rr dirnamerrlogrBLATHERrclosedopen)rbasedir made_basedirs r_do_open_InterProcessLock._do_openpss''//$)), '0L  =wH == DMM$8$8 C0DM%9rTc US:a [S5eUbUS:a [S5eX#:aUnUR5 [R"US9n[R"X#UR US9nU U"UR X5nSSS5 W(dSUlgSUlURR[RS URUR5UR5 g!,(df  Nt=f) a~Attempt to acquire the given lock. :param blocking: whether to wait forever to try to acquire the lock :type blocking: bool :param delay: when blocking this is the delay time in seconds that will be added after each failed acquisition :type delay: int/float :param max_delay: the maximum delay to have (this limits the accumulated delay(s) added after each failed acquisition) :type max_delay: int/float :param timeout: an optional timeout (limits how long blocking will occur for) :type timeout: int/float :returns: whether or not the acquisition succeeded :rtype: bool rz+Delay must be greater than or equal to zeroNz-Timeout must be greater than or equal to zero)duration)rr)FTzHAcquired file lock `%s` after waiting %0.3fs [%s attempts were required]) ValueErrorr5r StopWatchRetryrr*rrr/r0r elapsedattempts)rr(delay max_delaytimeoutr)rgottens racquire_InterProcessLock.acquire}s( 19JK K  7Q;LM M  I   '2 LL$(OO5 B t(((:F!DM DM KKOOFNN78< !MMOQZZ 9Us 3C55 DcbURb"URR5 SUlggN)rclosers r _do_close_InterProcessLock._do_closes( == $ MM   ! DM %rc&UR5 U$rF)rCrHs r __enter___InterProcessLock.__enter__s  rcUR(d[R"S5eUR5 SUlUR 5 UR R [RSUR5 g![a) UR RSUR5 gf=f![a) UR RSUR5 gf=f)z%Release the previously acquired lock.z$Unable to release an unacquired lockFz*Unlocked and closed file lock open on `%s`z.Could not close the file handle opened on `%s`z1Could not unlock the acquired lock opened on `%s`N) rr&r'unlockrIrr/rr0r r!rrHs rrelease_InterProcessLock.releases}}'')01 1 4 KKM "DM 4  !()-4  D %%'89=D D 9 KK ! !#-.2ii 9 9s#B=B0B:9B:=0C0/C0c$UR5 grF)rP)rexc_typeexc_valexc_tbs r__exit___InterProcessLock.__exit__s  rcT[RRUR5$)z( 1 $%)V! 4,)$$rrc$\rSrSrSrSrSrSrg) _WindowsLockz?Interprocess lock implementation that works on windows systems.c[R"URR5[RS5 gN)msvcrtlockingrfilenoLK_NBLCKrHs rr _WindowsLock.trylock#t}}++-vBrc[R"URR5[RS5 grq)rsrtrruLK_UNLCKrHs rrO_WindowsLock.unlockrxrrlNrbrcrdrerfr rOrkrlrrrnrnsICCrrnc$\rSrSrSrSrSrSrg) _FcntlLockz=Interprocess lock implementation that works on posix systems.c[R"UR[R[R-5 grF)fcntllockfrLOCK_EXLOCK_NBrHs rr _FcntlLock.trylocks! DMM5==5==#@Arcb[R"UR[R5 grF)rrrLOCK_UNrHs rrO_FcntlLock.unlocks DMM5==1rrlNr|rlrrr~r~sGB2rr~ntc*^[U5mU4SjnU$)zLAcquires & releases a interprocess lock around call into decorated function.cJ>^[R"T5UU4Sj5nU$)NcN>T T"U0UD6sSSS5 $!,(df  g=frFrl)argskwargsflocks rwrapper7interprocess_locked..decorator..wrappers$)&)s $)sixwraps)rrrs` r decorator&interprocess_locked..decorators$ 1 *  *r)InterProcessLock)r rrs @rinterprocess_lockedrs D !D r)rloggingrr&rir fastenersr getLoggerrbrrobjectrrnr~namersrrrrlrrrs$    !*^$^$BC$C2"277d?#!r