+jfUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZmZddlmZddlmZddlmZmZddlmZdd lmZdd lmZdd lmZdd l m!Z!erdd l"m#Z#m$Z$edZ%dZ&dZ'e(eddZ)e(eddZ*e j+dko ej,ej-vZ.eZ/de0d<e j1a2da3da4edGddZ5eGddZ6edGddZ7eGdd Z8Gd!d"e9Z:Gd#d$e:%Z;Gd&d'e j<Z=dd(dDd0Z>dd(dEd2Z?dFd6Z@dd(dGd;ZAdd(dHd<ZBdd(dHd=ZCdId?ZDdJd@ZEdKdAZFdKdBZGdKdCZHd$gZIdS)LzZCross-process and cross-host reader/writer lock built on :class:`SoftFileLock` primitives.) annotationsN)contextmanagersuppress) dataclass)Path) TYPE_CHECKINGLiteral)WeakValueDictionary)AcquireReturnProxy)Timeout) SoftFileLock)ensure_directory_exists)Callable Generator)readwritez.breaki O_NOFOLLOW O_NONBLOCKwin32,WeakValueDictionary[Path, SoftReadWriteLock]_all_instancesFT)frozenc.eZdZUded<ded<ded<dS)_PathsstrstaterreadersN__name__ __module__ __qualname____annotations__[/home/wildlama/visual-decline/.venv/lib/python3.11/site-packages/filelock/_soft_rw/_sync.pyrr.s+JJJJJJLLLLLr$rc.eZdZUded<ded<ded<dS)_Locksthreading.Lockinternal transactionr rNrr#r$r%r'r'5s6r$r'c.eZdZUded<ded<ded<dS) _MarkerInfortokenintpidhostnameNrr#r$r%r,r,<s+JJJ HHHMMMMMr$r,cdeZdZUdZded<ded<ded<ded <d ed <ded <d ed<ded<dS)_HoldzYEverything that exists only while a lock is held; ``None`` when the instance has no lock.r.level_Modemode int | Nonewrite_thread_idr marker_namebool is_readerr-_HeartbeatThreadheartbeat_threadthreading.Eventheartbeat_stopN)rr r!__doc__r"r#r$r%r2r2CslccJJJKKKOOOJJJ&&&&######r$r2cHeZdZUded<ded< dddddd d dfdZxZS) _SoftRWMetar _instancesr(_instances_lockT>@N?blocking is_singletonheartbeat_intervalstale_threshold poll_interval lock_filestr | os.PathLike[str]timeoutfloatrHr9rIrJrK float | NonerLreturnSoftReadWriteLockc |s(t|||||||St|}|j5|j|} | 3t|||||||} | |j|<n=| j|ks | j|kr'd| jd| jd|d|} t| | cdddS#1swxYwYdS)NrGz$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=) super__call__rresolverCrBgetrOrH ValueError) clsrMrOrHrIrJrKrL normalizedinstancemsg __class__s r%rVz_SoftRWMeta.__call__Us 77##!)#5 /+$ )__,,..    ~))*55H 77++%!-'9$3"/,.6z**!W,,0AX0M0MT8;KTTX`XiTT5<TTIQTT!oo%'                  sBC//C36C3rD)rMrNrOrPrHr9rIr9rJrPrKrQrLrPrRrS)rr r!r"rV __classcell__r^s@r%rArAQs|<<<<#### * !$((,#************r$rAcbeZdZUdZeZded<ejZ d>dddddd d?dZ e d@dddAdZ e d@dddAdZ d@dddBdZd@dddBdZdCd Zd!d"dDd$Ze d>dddEd%ZdFd(ZdGd+ZdHd,ZdId1ZdId2ZdJd5ZdCd6ZdKd7ZdLd9ZdMd;ZdKd<ZdCd=ZdS)NrSu Cross-process and cross-host reader/writer lock built on :class:`SoftFileLock` primitives. Use this class instead of :class:`~filelock.ReadWriteLock` when the lock file lives on a network filesystem (NFS, Lustre with ``-o flock``, HPC cluster shared storage). ``ReadWriteLock`` is backed by SQLite and cannot run on NFS because SQLite's ``fcntl`` locking is unreliable there. Layout on disk for a lock at ``foo.lock``: - ``foo.lock.state`` — a :class:`SoftFileLock` taken only during state transitions (microseconds). - ``foo.lock.write`` — writer marker; its presence means a writer is claiming or holding the lock. - ``foo.lock.readers/..`` — one file per reader. Each marker stores a random token (``secrets.token_hex(16)``), the holder's pid, and the holder's hostname. A daemon heartbeat thread refreshes ``mtime`` on every held marker. A marker whose mtime has not advanced in ``stale_threshold`` seconds may be evicted by any process on any host, giving correct behavior when a compute node crashes with a lock held. Writer acquire is two-phase and writer-preferring: phase 1 claims ``.write`` (blocking any new reader), phase 2 waits for existing readers to drain. Writer starvation is impossible. Reentrancy, upgrade/downgrade rules, thread pinning, and singleton caching by resolved path match :class:`~filelock.ReadWriteLock`. Forking while holding a lock invalidates the inherited instance in the child so the child cannot double-own the lock with its parent; ``release()`` on a fork-invalidated instance is a no-op, and the child must re-acquire if it needs a lock. Trust boundary: protects against same-UID non-cooperating processes (one host or cross-host) and same-host different-UID users via ``0o600`` / ``0o700`` permissions. Does not protect against root compromise, NTP tampering on same-UID cross-host nodes, or multi-tenant mounts where hostile co-tenants share the UID. :param lock_file: path to the lock file; sidecar state/write/readers live next to it :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately on contention :param is_singleton: if ``True``, reuse existing instances for the same resolved path :param heartbeat_interval: seconds between heartbeat refreshes; default 30 s :param stale_threshold: seconds of ``mtime`` inactivity before a marker is stale; defaults to ``3 * heartbeat_interval``, matching etcd's ``LeaseKeepAlive`` convention :param poll_interval: seconds between acquire retries under contention; default 0.25 s .. versionadded:: 3.27.0 rrBrDTrENrFrGrMrNrOrPrHr9rIrJrKrQrLrRNonecJ|dkrd|}t|||dz}||krd|d|d}t||dkrd|}t|tj||_||_||_||_||_||_t|jd|jd |jd  |_ t|jttjtjt|j jd |_d|_d|_d|_d|_t,5|t.t1|j<t5ddddS#1swxYwYdS)Nrz)heartbeat_interval must be positive, got z0stale_threshold must exceed heartbeat_interval (z <= )z$poll_interval must be positive, got z.statez.writez.readers)rrrrDrOr)r*rF)rYosfspathrMrOrHrJrKrLr_pathsrr' threadingLockr r_locks_readers_dir_fd_hold_fork_invalidated_closed_all_instances_lockrrrW_register_hooks) selfrMrOrHrIrJrKrLr]s r%__init__zSoftReadWriteLock.__init__s  " "R>PRRCS// !  "014O 0 0 0o_ooZloooCS// ! A  HHHCS// ! i 22% & );&5$1^+++^+++~///    ///^%%!((t{0"===    ,0#' ',"   =AN4//7799 :                      s=FFFrH bool | NoneGenerator[None]c#K||| dV|dS#|wxYw)a Context manager that acquires and releases a shared read lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds rwN) acquire_readreleaserurOrHs r% read_lockzSoftReadWriteLock.read_locksR 'H555  EEE LLNNNNNDLLNNNN 5A c#K||| dV|dS#|wxYw)a@ Context manager that acquires and releases an exclusive write lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :raises RuntimeError: if a read lock is already held, or a write lock is held by a different thread :raises Timeout: if the lock cannot be acquired within *timeout* seconds rwN) acquire_writer|r}s r% write_lockzSoftReadWriteLock.write_locksR 7X666  EEE LLNNNNNDLLNNNNrr c2|d||S)uf Acquire a shared read lock. If this instance already holds a read lock, the lock level is incremented (reentrant). Attempting to acquire a read lock while holding a write lock raises :class:`RuntimeError` (downgrade not allowed). On the 0→1 transition a daemon heartbeat thread is started that refreshes the reader marker's ``mtime`` every ``heartbeat_interval`` seconds so peers on other hosts do not evict the marker as stale. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable; ``None`` uses the instance default :returns: a proxy that can be used as a context manager to release the lock :raises RuntimeError: if a write lock is already held on this instance, if this instance was invalidated by :func:`os.fork`, or if :meth:`close` was called :raises Timeout: if the lock cannot be acquired within *timeout* seconds rrw_acquirer}s r%r{zSoftReadWriteLock.acquire_reads*}}VWx}@@@r$c2|d||S)a Acquire an exclusive write lock. If this instance already holds a write lock from the same thread, the lock level is incremented (reentrant). Attempting to acquire a write lock while holding a read lock raises :class:`RuntimeError` (upgrade not allowed). Write locks are pinned to the acquiring thread: a different thread trying to re-enter also raises :class:`RuntimeError`. Writer acquisition runs in two phases. Phase 1 atomically claims ``.write`` via ``O_CREAT | O_EXCL``, which immediately blocks any new reader on any host. Phase 2 waits for existing readers to drain. Writer starvation is impossible: new readers see ``.write`` during phase 2 and wait behind the pending writer. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable; ``None`` uses the instance default :returns: a proxy that can be used as a context manager to release the lock :raises RuntimeError: if a read lock is already held, if a write lock is held by a different thread, if this instance was invalidated by :func:`os.fork`, or if :meth:`close` was called :raises Timeout: if the lock cannot be acquired within *timeout* seconds rrwrr}s r%rzSoftReadWriteLock.acquire_write%s2}}Wg}AAAr$cZ|d|jj5|jr ddddSd|_|jLt t 5tj|jdddn #1swxYwYd|_ddddS#1swxYwYdS)u Release any held lock and release internal filesystem resources. Idempotent. After calling this method the instance can no longer acquire locks — subsequent acquires raise :class:`RuntimeError`. A fork-invalidated instance is closed without raising. TforceN) r|rnr)rrrorOSErrorricloserus r%rzSoftReadWriteLock.close@sL 4    [ ! , ,|  , , , , , , , , DL#/g&&33HT1222333333333333333'+$ , , , , , , , , , , , , , , , , , ,s: B "B B5 B B B B B  B$'B$Frrch|jj5|jrd|_ ddddS|j}|:|r ddddSd|jdt |d}t ||rd|_n|xjdzc_|jdkr ddddSd|_dddn #1swxYwY|j |j |j dz|j rt|j|j dSt|jdS) a8 Release one level of the current lock. When the lock level reaches zero the heartbeat thread is stopped and the held marker file is unlinked. On a fork-invalidated instance (that is, the child of a :func:`os.fork` call made while the parent held a lock) this method is a no-op so inherited ``with`` blocks can unwind cleanly in the child. :param force: if ``True``, release the lock completely regardless of the current lock level :raises RuntimeError: if no lock is currently held and *force* is ``False`` NzCannot release a lock on (lock id: z) that is not heldrg?rgdir_fd)rnr)rqrprMid RuntimeErrorr3r>setr<joinrJr:_unlinkr8ro)rurholdr]s r%r|zSoftReadWriteLock.releaseQs[ !  % !           :D|        j$.iiRPTXXiii"3'''   a zA~~!        "DJ#               , !!! ""4+BS+H"III > & D$T-A B B B B B B D$ % % % % %s#B3 B3AB3 B33B7:B7c||||S)a Return the singleton :class:`SoftReadWriteLock` for *lock_file*. :param lock_file: path to the lock file; sidecar state/write/readers live next to it :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: the singleton lock instance :raises ValueError: if an instance already exists for this path with different *timeout* or *blocking* values rwr#)rZrMrOrHs r%get_lockzSoftReadWriteLock.get_lock{s(s9g9999r$r5r4c,||jn|}||jn|}|jj5|jrd|jd}t ||jrd|jd}t ||j!| |cdddS dddn #1swxYwYtj }|s!|jj d}nH|dkr!|jj d}n!|jj d|}|st|jd ||||||jj S#|jj wxYw) NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFrwrDT)rHrO)rOrHrnr)rqrMrrrrp_validate_reentranttime perf_counterr*acquirer _do_acquire_innerr|)rur5rOrHr]startacquireds r%rzSoftReadWriteLock._acquires#*/$,,w$,$44==( [ ! 6 6% (rdnrrr"3'''| (NdnNNN"3'''z%//55 6 6 6 6 6 6 6 6& 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6!## W{.666FFHH ]]{.666EEHH{.66g6VVH 4$.))t 3 .))$)RR K # + + - - - -DK # + + - - - -sABB"B<E33 Feffective_timeoutrc |jj5|j!||cdddS dddn #1swxYwY|dkrdn||z}t jd}|dkr||||\}}n||||\}}tj } t|j |j | dt|d} |jj5td||dkrtjnd|||| | |_dddn #1swxYwY| t#| S) NrDrdeadlinerHzfilelock-heartbeat-x)refreshinterval stop_eventnamer)r3r5r7r8r:r-r<r>lock)rnr)rprsecrets token_hex_acquire_writer_slot_acquire_reader_slotrlEventr;_refresh_markerrJrr2 get_identrr ) rur5rrrHrr-r8r:r heartbeats r%rz#SoftReadWriteLock._do_acquire_inners+[ ! 6 6z%//55 6 6 6 6 6 6 6 6% 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6-2244@Q8Q!"%% 7??%)%>%>uxbj%>%k%k "K%)%>%>uxbj%>%k%k "K_&& $(,!3r$xx333    [ !  9= 3 5 5 5d'#!*)   DJ                !t,,,,s#AA A96D;;D?D?c |j}|J|j|krG|dkrdnd}|dkrdnd}d|d|jdt|d|d |d }t ||dkrRt jx}|jkr4d |jdt|d |d |j}t ||xjdz c_t|S)Nrr downgradeupgradezCannot acquire z lock on rz): already holding a z lock (z not allowed)zCannot acquire write lock on z) from thread z while it is held by thread rr) rpr5rMrrrlrr7r3r )rur5ropposite directionr]curs r%rz%SoftReadWriteLock._validate_reentrantsYz 9  "&&..wwfH'+v~~ 9IO$OOOOBtHHOO%-OO6?OOO s## # 7??y':'<'< <AUUUWWW2d88WW"WW@D@TWW s## # a !t,,,,r$r-rrtuple[str, bool]cdfd }dfd }||| |||n(#t$rtjjwxYwjjdfS)NrRr9ctjj5tjjjt jtjjr ddddS tjjn#t$rYddddSwxYw dddn #1swxYwYdS)NrKnowFT) rnr_break_stale_markerrkrrKr _file_exists_atomic_create_markerFileExistsError)rur-sr%try_claim_writerz@SoftReadWriteLock._acquire_writer_slot..try_claim_writers:" ! !#DK$5tG[aeajalalmmmm 122!  ! ! ! ! ! ! ! !!)$+*;UCCCC&!!!  ! ! ! ! ! ! ! ! !D  ! ! ! ! ! ! ! ! ! ! ! ! ! ! !4s6A B-)BB- BB-BB--B14B1cPjj5tt5t jjdddn #1swxYwYtj cdddS#1swxYwYdSN) rnrrr_touchrkr_break_stale_readersr _any_readersrsr%readers_drained_touchingzHSoftReadWriteLock._acquire_writer_slot..readers_drained_touchings" / /g&&..4;,---...............))$)++666,,...  / / / / / / / / / / / / / / / / / /s3BA  B A BA =BB"BrFrRr9)_open_readers_dir _wait_forr rrkr)rur-rrHrrs`` r%rz&SoftReadWriteLock._acquire_writer_slots            / / / / / / '(XNNN  NN3hQYN Z Z Z Z    DK% & & &  { %''s A%A;cDtjjdt jjttj j z dfd } |||ndfS)N.rRr9cPjj5tjjjt jtjjr ddddStnt ddddS#1swxYwYdS)NrFrT) rnrrrkrrKrrr)rfull_reader_path reader_namerur-sr%try_claim_readerz@SoftReadWriteLock._acquire_reader_slot..try_claim_reader!s "  #DK$5tG[aeajalalmmmm 122!         %)+uVLLLLL)*:EBBB                  sA B(&BB"BrTr) ruuiduuid4hexrigetpidrorrrkrr)rur-rrHrrrrs`` @@@r%rz&SoftReadWriteLock._acquire_reader_slots    )99BIKK99 %tDK$788;FGG           '(XNNN%1 7G$NNr$ predicateCallable[[], bool]c$ |rdStj}|st|j|||krt|j|j}|!t |t ||z d}tj|)NTg)rrr rMrLminmaxsleep)rurrrHr sleep_fors r%rzSoftReadWriteLock._wait_for/s "y{{ #%%C .dn---#xdn---*I# 3x#~s+C+CDD Jy ! ! ! "r$cZt|jj}tt5|ddddn #1swxYwYt j|jj}tj |j stj |j s|jjd}t||j XtrSt jt!t ddzt"z}t j|jj||_ dSdSdS)Ni)r5zB exists but is not a directory or is a symlink; refusing to use it O_DIRECTORYr)rrkrrrmkdirrilstatstatS_ISLNKst_modeS_ISDIRrro_SUPPORTS_DIR_FDO_RDONLYgetattr _O_NOFOLLOWopen)ru readers_pathstr]flagss r%rz#SoftReadWriteLock._open_readers_dirCsEDK/00 o & & + +   E  * * * + + + + + + + + + + + + + + +Xdk) * * < # # $4< +C+C $[(lllCs## #   ',< 'K'"mQ"?"??+ME#%74;+>#F#FD  ( ' ' 'sAAAc8|D]}dSdS)NTF)_iter_reader_entries)ru_s r%rzSoftReadWriteLock._any_readersQs)**,,  A44ur$Generator[tuple[str, bool]]c#K|jXtj|j5}|D]!}t|js |jdfV" dddn #1swxYwYdSt |jj}tj|5}|D]1}t|jst||jz dfV2 ddddS#1swxYwYdS)a# Yield ``(name, dirfd_relative)`` pairs for every live reader marker. ``dirfd_relative`` is ``True`` when *name* should be passed to ``dir_fd=``-aware syscalls; ``False`` when *name* is a full path because dirfd-relative I/O is unavailable on this platform. NTF) roriscandir_is_housekeeping_namerrrkrr)ruitentryrs r%rz&SoftReadWriteLock._iter_reader_entriesVs   +D011 /R//E0<</#j$..../ / / / / / / / / / / / / / / / FDK/00 Z % % @ @ @,UZ88@lUZ788%???? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @s#%AAA5CCCrcg} |D]%\}}|||r|jndf&n#t$rYdSwxYw|D]\}}t ||j||dS)N)rKrr)rappendrorrrK)rurnamesrdirfd_relativefds r%rz&SoftReadWriteLock._break_stale_readersis.0 (,(A(A(C(C W W$n dN$TD$8$8PTUVVVV W    FF  ` `HD" d6JPS\^ _ _ _ _ _ ` `s:? A  A cp|jj5|j}| ddddS|j}|j}|jr|jnd}dddn #1swxYwYt||}|dS|\}}|tj |j|sdS t||n#t$rYdSwxYwdS)NFrT) rnr)rpr8r-r:ro _read_markerhmaccompare_digestrFileNotFoundError)rurr8r-r read_resultinfo_mtimes r%rz!SoftReadWriteLock._refresh_markerss` [ ! F F:D| F F F F F F F F*KJE-1^ET))F  F F F F F F F F F F F F F F F#;v>>>  5" f  d4000 !%r$c|j|jsP|s|jdS|j|jNdSdSr)rwaitrrrrs r%runz_HeartbeatThread.runsx"''77 ==??  $$&&&"''77     r$) rrrrPrr=rrrRrcr)rr r!rvrr`ras@r%r;r;sQ & & & & & &r$r;rrrr-rr6rRrcctjtjztjztz}t r|tj||d|}ntj||d} |dtjdtj d d}tj ||tj |dS#tj |wxYw)Nir ascii) riO_CREATO_EXCLO_WRONLYrrrrsocket gethostnameencoderr)rr-rrrcontents r%rrs J "R[ 0; >E)F. WT5% 7 7 7 WT5% ( (EEbikkEEV-?-A-AEEELLWUU W   s (ACC)'tuple[_MarkerInfo | None, float] | Nonectjtztz} tr|tj|||ntj||}n#t $rYdSwxYw tj|}tj|tdz}n%#t $rYtj |dSwxYw tj |n#tj |wxYwt||j fS)Nrr) rirr _O_NONBLOCKrrrfstatr_MAX_MARKER_SIZEr_parse_marker_bytesst_mtime)rrrrrdatas r%rrs K+ % 3E4D uI[RWT5 0 0 0 0acahimotauau tt "B72/!344DD          t $ $bk 11s;5A A"!A"'1BC B;#C:B;;CC*r%bytes_MarkerInfo | NonecJ|rt|tkrdS |d}n#t$rYdSwxYwt jd|tj}|dSt|dd}|dkrdSt|d||dS) Nru \A # start of string (?P [0-9a-f]{32} ) \n # 128-bit hex token (?P [1-9][0-9]{0,9} ) \n # decimal pid: no leading zero, ≤ 10 digits (?P [\x21-\x7e]{1,253}) # printable non-whitespace ASCII (RFC 1123 hostname limit) \n* # tolerate sloppy writers that append extra newlines \Z # end of string r/ ir-r0)r-r/r0) lenr"decodeUnicodeDecodeErrorrematchVERBOSEr.r,)r%textr.r/s r%r#r#s 3t99///t{{7## tt H     E }t eElB  C Yt U7^uZ?P Q Q QQs4 AArKrPrr9cbt||}|dS|\}}||z |krdS|t||dS|tdtjdt jd} tr|tj||||n"t||n#t$rYdSwxYwt||}|dS|\} } | t||dStj |j | j sdS| |krdSt||dS)NrFTrr) src_dir_fd dst_dir_fd)rr _BREAK_SUFFIXrirrrrrenamerrrrr-) rrKrrr info_before mtime_before break_name read_after info_after mtime_afters r%rrstF333Ku +K \_,,uV$$$$tO-OO")++OO8I"8M8MOOJ  * 2 IdJ6f M M M M M JJ  j ) ) ) uuj888Ju(J  6****t  {0*2B C Cu\!!u Jv&&&& 4s0AB55 CCctt5tr|tj||n!t |ddddS#1swxYwYdSNr)rrrriunlinkrrrs r%rrs # $ $    2 Id6 * * * * * JJ                        sAA$$A(+A(cttr|tj|d|dStj|ddSr=)rriutimer?s r%rr#sDF. tF++++++ tr$pathc tj|}n#t$rYdSwxYwtj|jS)NF)rirrrS_ISREGr)rBrs r%rr*sJ Xd^^ uu < # ##s  %%c>|dpt|vS)Nr) startswithr4)rs r%rr2s ??3   8=D#88r$ctjattD]}|dSr)rlrmrslistrvaluesrr\s r%_reset_all_after_forkrK6sT $.**..0011..++----..r$cttD]D}tt5|ddddn #1swxYwYEdS)NTr)rHrrIr Exceptionr|rJs r%_cleanup_all_instancesrN@s..0011)) i  ) )   4  ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )))sA  A$ 'A$ ctstjtdats3t t dr t jtdadSdSdS)NTregister_at_fork)after_in_child) _atexit_registeredatexitregisterrN_fork_registeredhasattrrirPrKr#r$r%rtrtFsp ".///!  ,> ? ?  +@AAAA    r$)rrr-rrr6rRrc)rrrr6rRr)r%r&rRr') rrrKrPrrPrr6rRr9)rrrr6rRrc)rBrrRr9)rrrRr9r)Jr? __future__rrSrrir-rrrsysrlrr contextlibrr dataclassesrpathlibrtypingrr weakrefr filelock._apir filelock._errorr filelock._softr filelock._utilrcollections.abcrrr4r4r"rrr platformrsupports_dir_fdrrr"rmrsrRrUrr'r,r2typerArSThreadr;rrr#rrrrrrKrNrt__all__r#r$r%rhs```""""""   ////////!!!!!!))))))))'''''',,,,,,######''''''222222433333333   gb,** gb,** <7*Lrw":L/L?R?R?T?TTTTT$in&& $     $   $ $ $ $ $ $ $  $.....$...bS&S&S&S&S&+S&S&S&S&ly'(JN      59222222(RRRRF ******Z04      /3$$$$9999....))))      r$