Ij=DddlmZddlZddlZddlZddlZddlmZddlZddl Z ddl m Z ddl m Z ddl m Z ddlmZddlmZdd lmZejeZd ZGd d ZGd dZde eeffdZde eeffdZde eeffdZdS))contextmanagerN)Path)Callable)Optional)Union)_utils)_interprocess_mechanism)%_interprocess_reader_writer_mechanismc tj|dS#t$r\}|jtjkr&tj|sYd}~dS|jtjkrYd}~dSd}~wwxYw)zfCreate a directory (and any ancestor directories required). :param path: Directory to create TNF)osmakedirsOSErrorerrnoEEXISTpathisdirEISDIR)res `/workspace/show-city-briefing-agent/.venv/lib/python3.11/site-packages/fasteners/process_lock.py _ensure_treer%s  Dt     7el " "7==&& uuuuu W $ $55555  s  A>5A9A98A99A>c eZdZdZdZdZejdfdee e fde e gdfde ejfdZd Zd Z dd ed e de de e def dZdZdZdZdZdZdZdZdS)InterProcessLockzAn interprocess lock.皙?{Gz?Nr sleep_funcloggercd|_tj||_d|_||_tj|t|_dS)a args: path: Path to the file that will be used for locking. sleep_func: Optional function to use for sleeping. logger: Optional logger to use for logging. NF) lockfilercanonicalize_pathracquiredrpick_first_not_noneLOGrselfrrrs r__init__zInterProcessLock.__init__@sC ,T22  $0== c< |dS#ttf$rr}|jtjtjfvr/|r|rYd}~dStjtj d|j |dzd}~wwxYw)NTFz9Unable to acquire lock on `%(path)s` due to %(exception)s)r exception) trylockIOErrorrrEACCESEAGAINexpiredr RetryAgain threading ThreadErrorr)r$blockingwatchrs r _try_acquirezInterProcessLock._try_acquireSs  LLNNN 4! / / /w5<666.5==??. 55555 +---+-=9= =>-.-.-./// /sB5B$2BBctj|j}|r7t|}|r&|jt jd||j |jj rt|jd|_dSdS)NCreated lock base path `%s`a) r rdirnamerrlogrBLATHERrclosedopenr$basedir made_basedirs r_do_openzInterProcessLock._do_opengs'//$),,  H'00L H  =wHHH = DM$8  C00DMMM ! r&Tr1delay max_delaytimeoutreturnc|dkrtd||dkrtd||kr|}|tj|}tj|||j|}|5||j||}dddn #1swxYwY|sdSd|_|j tj d |j | |j dS) a,Attempt to acquire the lock. Args: blocking: Whether to wait to try to acquire the lock. delay: When `blocking`, starting delay as well as the delay increment (in seconds). max_delay: When `blocking` the maximum delay in between attempts to acquire (in seconds). timeout: When `blocking`, maximal waiting time (in seconds). Returns: whether or not the acquisition succeeded r+Delay must be greater than or equal to zeroN-Timeout must be greater than or equal to zerodurationrr2FTHAcquired file lock `%s` after waiting %0.3fs [%s attempts were required]) ValueErrorr?r StopWatchRetryrr3r rr8r9relapsedattempts)r$r1r@rArBr2rgottens racquirezInterProcessLock.acquiretsN, 199JKK K  7Q;;LMM M I  I  '222 L $(O5 B B B  ; ;Qt((E::F ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; 5 DM KOOFN78< !MMOOQZ 9 9 94s=BB #B cX|j"|jd|_dSdSN)rcloser$s r _do_closezInterProcessLock._do_closes1 = $ M   ! ! ! DMMM % $r&cj|}|stjd|jz|S)NFUnable to acquire a file lock on `%s` (when used as a context manager))rRr/r0r)r$rQs r __enter__zInterProcessLock.__enter__sG I')<>Bi)HII I r&c|jstjd |d|_ ||jtjd|j dS#t$r$|j d|j YdSwxYw#t$r=}d|j f}|j |tj||d}~wwxYw)z%Release the previously acquired lock.z#Unable to release an unaquired lockF*Unlocked and closed file lock open on `%s`.Could not close the file handle opened on `%s`1Could not unlock the acquired lock opened on `%s`N) r r/r0unlockrWrr8rr9rr*r( Exception)r$rmsgs rreleasezInterProcessLock.releases1} O'(MNN N 4 KKMMM "DM 4    !()-44444  D D D %%'89=DDDDDD D 4 4 4EtyPC K ! !# & & &',,! 3 4s(B+A::*B('B(+ C258C--C2c.|dSrT)rb)r$exc_typeexc_valexc_tbs r__exit__zInterProcessLock.__exit__s r&cJtj|jSrT)r rexistsrVs rrizInterProcessLock.existssw~~di(((r&c8tj|jdSrT)r r)rrVs rr)zInterProcessLock.trylocks' 66666r&c8tj|jdSrT)r r_rrVs rr_zInterProcessLock.unlocks&t}55555r&TrrN)__name__ __module__ __qualname____doc__ MAX_DELAYDELAY_INCREMENTtimesleeprrstrrfloatrloggingLoggerr%r3r?boolrRrWrZrbrgrir)r_r&rrr:s]IO8>T3Y'>%ugtm4>"'.1>>>>&( 1 1 1"&##&+/ ****!*"% *59 ****X!!! 444,)))77766666r&rc eZdZdZdZdZejdfdee e fde e gdfde ejfdZedd Zedd Zd Zd Z ddede de de def dZ ddede de de def dZ ddZdZdZdZdS)InterProcessReaderWriterLockz$An interprocess readers writer lock.rrNrrrcd|_tj||_||_tj|t |_dS)a Args: path: Path to the file that will be used for locking. sleep_func: Optional function to use for sleeping. logger: Optional logger to use for logging. N)rrrrrr!r"rr#s rr%z%InterProcessReaderWriterLock.__init__s< ,T22 $0== r&c#K|d||d dV|dS#|wxYw)z&Context manager that grans a read lockTNr1r@rArB)acquire_read_lockrelease_read_lock)r$r@rAs r read_lockz&InterProcessReaderWriterLock.read_lockso E)2D  B B B % EEE  " " $ $ $ $ $D " " $ $ $ $s 7A c#K|d||d}|stjd|jz dV|dS#|wxYw)z'Context manager that grans a write lockTNrrY)acquire_write_lockr/r0rrelease_write_lock)r$r@rArQs r write_lockz'InterProcessReaderWriterLock.write_locks(($e3Bi)HII I & EEE  # # % % % % %D # # % % % %s AA+c tj|j|}n?#t$r2}t jd|j|d}~wwxYw|rdS|r|rdStj )Nz'Unable to acquire lock on {} due to {}!TF) r r)rr`r/r0formatrr-rr.)r$r1r2 exclusiverQrs rr3z)InterProcessReaderWriterLock._try_acquires P:B4=R[\\FF P P P'9@@ANNPP P P  4 5==?? 5!!!s A-AActj|j}|r7t|}|r&|jt jd||j tj |j|_dSdS)Nr5) r rr7rrr8rr9rr get_handler<s rr?z%InterProcessReaderWriterLock._do_opens'//$),,  H'00L H  =wHHH = ALTYWWDMMM ! r&Tr1r@rArBrCc6|||||dS)a3Attempt to acquire a reader's lock. Args: blocking: Whether to wait to try to acquire the lock. delay: When `blocking`, starting delay as well as the delay increment (in seconds). max_delay: When `blocking` the maximum delay in between attempts to acquire (in seconds). timeout: When `blocking`, maximal waiting time (in seconds). Returns: whether or not the acquisition succeeded Fr_acquirer$r1r@rArBs rrz.InterProcessReaderWriterLock.acquire_read_locks ,}}XuiE}RRRr&c6|||||dS)a3Attempt to acquire a writer's lock. Args: blocking: Whether to wait to try to acquire the lock. delay: When `blocking`, starting delay as well as the delay increment (in seconds). max_delay: When `blocking` the maximum delay in between attempts to acquire (in seconds). timeout: When `blocking`, maximal waiting time (in seconds). Returns: whether or not the acquisition succeeded Trrrs rrz/InterProcessReaderWriterLock.acquire_write_lock6s ,}}XuiD}QQQr&c|dkrtd||dkrtd||kr|}|tj|}tj|||j|}|5||j|||}dddn #1swxYwY|sdS|jtj d|j | |j dS) NrrErFrGrIFrJT) rKr?rrLrMrr3rr8r9rrNrO) r$r1r@rArBrr2rPrQs rrz%InterProcessReaderWriterLock._acquireNsZ 199JKK K  7Q;;LMM M I  I  '222 L $(O5 B B B  F FQt((E9EEF F F F F F F F F F F F F F F F 5 KOOFN78< !MMOOQZ 9 9 94s=BB!$B!cX|j"tj|jd|_dSdSrT)rr close_handlerVs rrWz&InterProcessReaderWriterLock._do_closegs0 = $ 1 >t} M M M DMMM % $r&c~ tj|j ||jt jd|jdS#t$r$|j d|jYdSwxYw#t$r$|j d|jYdSwxYw)zRelease the writer's lock.r\r]r^N r r_rrWrr8rr9rr*r(rVs rrz/InterProcessReaderWriterLock.release_write_lockl  4 1 8 G G G  4    !()-44444  D D D %%'89=DDDDDD D  9 9 9 K ! !#-.2i 9 9 9 9 9 9 9"BA*B  B *B<;B<c~ tj|j ||jt jd|jdS#t$r$|j d|jYdSwxYw#t$r$|j d|jYdSwxYw)zRelease the reader's lock.r\r]r^NrrVs rrz.InterProcessReaderWriterLock.release_read_lock~rr)rrrl)TrrNT)rmrnrorprqrrrsrtrrrurrvrrwrxr%rrrr3r?ryrrrrWrrrzr&rr|r|s..IO8>T3Y'>%ugtm4>"'.1>>>>$%%%^%&&&^& " " "XXX,0)--0+/ SS$(S!&S&+S$) S59 SSSS2-1*..1,0 RR%)R"'R',R%* R6: RRRR0!%'*)-2!!! 444$44444r&r|rc0t|fd}|S)zAcquires & releases an interprocess **write** lock around the call into the decorated function Args: path: Path to the file used for locking. cJtjfd}|S)Ncp5|i|cdddS#1swxYwYdSrT)rargskwargsflocks rwrapperz=interprocess_write_locked..decorator..wrappers"" * *q$)&)) * * * * * * * * * * * * * * * * * * +// functoolswrapsrrrs` r decoratorz,interprocess_write_locked..decorator>    * * * * *   *r&r|rrrs @rinterprocess_write_lockedr3 ( - -D r&c0t|fd}|S)zAcquires & releases an interprocess **read** lock around the call into the decorated function Args: path: Path to the file used for locking. cJtjfd}|S)Ncp5|i|cdddS#1swxYwYdSrT)rrs rrz.decorator..wrappers!! * *q$)&)) * * * * * * * * * * * * * * * * * *rrrs` rrz+interprocess_read_locked..decoratorrr&rrs @rinterprocess_read_lockedrrr&c0t|fd}|S)zAcquires & releases an interprocess lock around the call to the decorated function. Args: path: Path to the file used for locking. cJtjfd}|S)NcL5|i|cdddS#1swxYwYdSrTrzrs rrz7interprocess_locked..decorator..wrappers * *q$)&)) * * * * * * * * * * * * * * * * * *s rrs` rrz&interprocess_locked..decoratorrr&)rrs @rinterprocess_lockedrs3 D ! !D r&) contextlibrrrrwr pathlibrr/rstypingrrr fastenersrfasteners.process_mechanismr r getLoggerrmr"rrr|rurrrrzr&rrs$&%%%%%   ??????MMMMMMg!!*T6T6T6T6T6T6T6T6n}4}4}4}4}4}4}4}4@E$)$4(5s#3(eD#I.r&