+ 2ja0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI t ^RIt^RIHtHt^RIHt^RIHt^RIHtHt^RIHt^RIHt^R IHt^R IH t ^R I!H"t"]'d ^R I#H$t$H%t%]R=,t&R t'Rt(])!]R^4t*])!]R^4t+] PXR8g;'d]PZ]P\9t/]!4t0R]1R&] Pd!4s3Rs4Rs5]!RR7!RR44t6]!RR44t7]!RR7!RR44t8]!RR44t9!RR ]:4t;!R!R"];R#7t<!R$R%] Pz4t>R&R/R'R(llt?R&R/R)R*llt@R+R,ltAR&R/R-R.lltBR&R/R/R0lltCR&R/R1R2lltDR3R4ltER5R6ltFR7R8ltGR9R:ltHR;R<ltIR".tJR#)>zZCross-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 Generatorz.breaki O_NOFOLLOW O_NONBLOCKwin32,WeakValueDictionary[Path, SoftReadWriteLock]_all_instancesFT)frozenc6]tRt^.t$R]R&R]R&R]R&RtR#)_PathsstrstatewritereadersN__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r7lib/python3.14/site-packages/filelock/_soft_rw/_sync.pyrr.s J J Lr$rc6]tRt^5t$R]R&R]R&R]R&RtR#)_Locksthreading.Lockinternal transactionr rrNrrr$r%r'r'5s r$r'c6]tRt^@stale_thresholdN poll_interval?c8V^8dQhRRRRRRRRRRR R R RR R /#) lock_filestr | os.PathLike[str]timeoutfloatrDr9rErFrH float | NonerIreturnSoftReadWriteLockr)formats"r% __annotate___SoftRWMeta.__annotate__UsZ**)**  *  *"*&** *r$c  <V'g\S V`VVVVVVVR7#\V4P4pVP;_uu_4VP P V4p V f&\S V`VVVVVVVR7p WP V&MOV PV8wgV PV8wd.RV P RV P RV RV 2p \V 4hV uuRRR4# +'giR#;i))rDrErFrHrINz$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=) super__call__rresolverCrBgetrOrD ValueError) clsrMrOrDrErFrHrI normalizedinstancemsg __class__s &&&$$$$$ r%rY_SoftRWMeta.__call__Us7#!)#5 /+$ )_,,.  ~~))*5H 7+%!-'9$3"/,.6z*!!W,0A0AX0M:8;K;K:LKX`XiXiWjk55 r)rrr r!r"rYr# __classcell__ras@r%rArAQsP<<##*  * " *%)*)-* $***r$rAc ]tRt^t$Rt]!4tR]R&]P!4t R8RRRRRRR R R R /R Rlllt ] R9RR /RRlll4t ] R9RR /RRlll4tR9RR /RRllltR9RR /RRllltRRltRR/RRllt]R8RR/RRlll4tRR ltR!R"ltR#R$ltR%R&ltR'R(ltR)R*ltR+R,ltR-R.ltR/R0ltR1R2ltR3R4ltR5R6lt R7t!R #):rSuE 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 rrBrDTrErFrGrHNrIrJc8V^8dQhRRRRRRRRRRR R R RR R /#)rLrMrNrOrPrDr9rErFrHrQrIrRNoner)rTs"r%rUSoftReadWriteLock.__annotate__sZ00)00  0  0"0&00 0r$c  fV^8:dRV 2p\V4hVf V^,pWe8:dRV RV R2p\V4hV^8:dRV 2p\V4h\P!V4VnW nW0nWPnW`nWpn\VP R2VP R2VP R 2R 7Vn \VP4\\P!4\P!4\VPP RR 7R 7VnRVnRVnR VnR Vn\,;_uu_4V\.\1VP4P34&\54RRR4R# +'giR#;i)z)heartbeat_interval must be positive, got Nz0stale_threshold must exceed heartbeat_interval (z <= )z$poll_interval must be positive, got z.statez.writez.readers)rrrrOr)r*rFrd)r\osfspathrMrOrDrFrHrIr_pathsr r' threadingLockr r_locks_readers_dir_fd_hold_fork_invalidated_closed_all_instances_lockrrrZ_register_hooks) selfrMrOrDrErFrHrIr`s &&&$$$$$ r%__init__SoftReadWriteLock.__init__sy  "=>P=QRCS/ !  "014O  0D_DUUYZlYmmnoCS/ ! A 8HCS/ ! ii 2% & );&5$1^^$F+^^$F+~~&h/  /^^%!(t{{00"=  ,0#' '," =AN4/779 :  ! s 5F F0 c$V^8dQhRRRRRR/#rLrOrQrD bool | NonerRzGenerator[None]r)rTs"r%rUrjs";Zir$c# "VPWR7RxVP4R# TP4i;i5i)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 rDN) acquire_readreleaser|rOrDs&&$r% read_lockSoftReadWriteLock.read_locks2 '5   LLNDLLNA,A>Ac$V^8dQhRRRRRR/#rr)rTs"r%rUrjs",Kr$c# "VPWR7RxVP4R# TP4i;i5i)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 rN) acquire_writerrs&&$r% write_lockSoftReadWriteLock.write_locks2 76   LLNDLLNrc$V^8dQhRRRRRR/#rLrOrQrDrrRr r)rTs"r%rUrjs'AALAkA]oAr$c (VPRWR7#)u 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 readr_acquirers&&$r%rSoftReadWriteLock.acquire_reads*}}VW}@@r$c$V^8dQhRRRRRR/#rr)rTs"r%rUrj%s'BB\B{B^pBr$c (VPRWR7#)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 rrrrs&&$r%rSoftReadWriteLock.acquire_write%s2}}Wg}AAr$cV^8dQhRR/#rLrRrir)rTs"r%rUrj@s,,t,r$c  VPRR7VPP;_uu_4VP'd RRR4R#RVnVPeH\ \ 4;_uu_4\P!VP4RRR4RVnRRR4R# +'giL!;i +'giR#;i)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) rrur)ryrvrOSErrorrpcloser|s&r%rSoftReadWriteLock.close@s 4  [[ ! ! !|||" ! DL##/g&&HHT112''+$" ! '& " ! !s)C,C;!B5 C5 C C C rFc V^8dQhRRRR/#)rLrr9rRrir)rTs"r%rUrjQs(&(&(&(&r$c VPP;_uu_4VP'dRVnRRR4R#VPpVf;V'd RRR4R#RVP R\ V4 R2p\ V4hV'd ^VnMV;P^,unVP^8d RRR4R#RVnRRR4XPP4VPPVPR,R7VP'd$\VPVP R7R#\VP4R# +'giL;i)a 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 heldg?rndir_fd)rur)rxrwrMid RuntimeErrorr3r>setr<joinrFr:_unlinkr8rv)r|rholdr`s&$ r%rSoftReadWriteLock.releaseQs#[[ ! ! !%%%!  " ! ::D|" !2$..1ARPTXJVhi"3''  a zzA~!" !"DJ#", ! ""4+B+BS+H"I >>> D$$T-A-A B D$$ %7" !s)E5E5E5'.E53E5E55 F c(V^8dQhRRRRRRRR/#) rLrMrNrOrPrDr9rRrSr)rTs"r%rUrj|s2::)::  :  :r$c V!WVR7#)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 rr)r]rMrOrDs&&&$r%get_lockSoftReadWriteLock.get_lock{s(999r$c(V^8dQhRRRRRRRR/#) rLr5r4rOrQrDrrRr r)rTs"r%rUrjs2 . . . .  .  .r$c Vf VPMTpVf VPMTpVPP;_uu_4VP'dRVP R2p\ V4hVP'dRVP R2p\ V4hVPeVPV4uuRRR4#RRR4\P!4pV'g(VPPPRR7pMUVR8Xd(VPPPRR7pM'VPPPRVR7pV'g\VP 4RhVPWWSR7VPPP!4# +'giL;i TPPP!4i;i) NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFrT)rDrOrd)rOrDrur)rxrMrryrw_validate_reentranttime perf_counterr*acquirer _do_acquire_innerr)r|r5rOrDr`startacquireds&&&$ r%rSoftReadWriteLock._acquires#*/$,,w$,$44==( [[ ! ! !%%%-dnn-==qr"3''|||-dnn-==MN"3''zz%//5" !&"!!#{{..666FH ]{{..666EH{{..66g6VH$..)t 3 .))$)R KK # # + + --" !, KK # # + + -s?F?9F?G? G &G8c ,V^8dQhRRRRRRRRRR /#) rLr5r4effective_timeoutrPrrDr9rRr r)rTs"r%rUrjs<$-$-$-!$- $-  $- $-r$c  VPP;_uu_4VPeVPV4uuRRR4#RRR4VR8XdRMW2,p\P !^4pVR8XdVP WeVR7wrxMVPWeVR7wrx\P!4p \VPVPV R\V4R 2R7p VPP;_uu_4\^TVR8Xd\P!4MRVVVV V R7VnRRR4V P!4\#VR7# +'giEL&;i +'giL@;i) NrdeadlinerDzfilelock-heartbeat-x)refreshinterval stop_eventname)r3r5r7r8r:r-r<r>lockrd)rur)rwrsecrets token_hex_acquire_writer_slot_acquire_reader_slotrsEventr;_refresh_markerrFrr2 get_identrr ) r|r5rrrDrr-r8r:r heartbeats &&&&$ r%r#SoftReadWriteLock._do_acquire_innersM[[ ! ! !zz%//5" !%"-248Q!!"% 7?%)%>%>ubj%>%k "K%)%>%>ubj%>%k "K__& $((,,!&r$xl3  [[ ! ! !9= 3 3 5d'#!*) DJ" !t,,9" ! ! " !sE'5E;' E8 ; F c V^8dQhRRRR/#)rLr5r4rRr r)rTs"r%rUrjs---2D-r$c  VPpVfQhVPV8wdGVR8XdRMRpVR8XdRMRpRV RVP R\V4 RV R V R 2 p\ V4hVR8Xd\\ P !4;qbP8wd7R VP R\V4 R V R VP 2p\ V4hV;P^, un\VR7#)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 r) rwr5rMrrrsrr7r3r )r|r5ropposite directionr`curs&& r%r%SoftReadWriteLock._validate_reentrantszz 99 "&&.wfH'+v~ 9I!$y0@ BtH:V%%-Jgi[ O s# # 7?y':':'< <AUAUU//?{2d8*U"e#?@T@T?UW s# # a !t,,r$c(V^8dQhRRRRRRRR/# rLr-rrrQrDr9rRztuple[str, bool]r)rTs"r%rUrjs2&(&(&( &(  &(  &(r$c (aaSP4RVV3RllpRV3RllpSPWBVR7SPWRVR7SPP R3# \d"\SPP 4hi;i)cV^8dQhRR/#rLrRr9r)rTs"r%rU.__annotate__s  $ r$c<SPP;_uu_4\SPPSP \ P !4R7\SPP4'd RRR4R#\SPPS4RRR4R# \d RRR4R#i;i +'giR#;i)rHnowNFT) rur_break_stale_markerrrrrHr _file_exists_atomic_create_markerFileExistsError)r|r-sr%try_claim_writer@SoftReadWriteLock._acquire_writer_slot..try_claim_writers"""#DKK$5$5tG[G[aeajajalm 1 122 #"!)$++*;*;UC #'! #" ! #"s*A&C B<< CCCC C' cV^8dQhRR/#rr)rTs"r%rUrs / /$ /r$c <SPP;_uu_4\\4;_uu_4\ SP P 4RRR4SP\P!44SP4'*uuRRR4# +'giLS;i +'giR#;iN) rurrr_touchrrr_break_stale_readersr _any_readersrsr%readers_drained_touchingHSoftReadWriteLock._acquire_writer_slot..readers_drained_touchingsw"""g&&4;;,,-'))$))+6,,.. #"'&#""s#B6 B# AB6# B3 .B66 C rF)_open_readers_dir _wait_forr rrrr)r|r-rrDrrsff$$ r%r&SoftReadWriteLock._acquire_writer_slots     / / 'XN  NN3QYN Z {{  %''   DKK%% &  s A%%,Bc(V^8dQhRRRRRRRR/#rr)rTs"r%rUrjs8OOO O  O  Or$c haaaaaSP4\P!4P R\P !4 2oSP o\\SPP4S, 4oRVVVVV3RllpSPWBVR7SeSR3#SR3#).cV^8dQhRR/#rr)rTs"r%rU.__annotate__!s  $ r$c<SPP;_uu_4\SPPSP \ P !4R7\SPP4'd RRR4R#Se\SSSR7M \SS4RRR4R# +'giR#;i)rNFrT) rurrrrrrHrrr)rfull_reader_path reader_namer|r-sr%try_claim_reader@SoftReadWriteLock._acquire_reader_slot..try_claim_reader!s"""#DKK$5$5tG[G[aeajajalm 1 122 #"%)+uVL)*:EB#"""sA&B: B:: C rT) ruuiduuid4hexrpgetpidrvrrrrrr)r|r-rrDrrrrsff$$ @@@r%r&SoftReadWriteLock._acquire_reader_slots  ))*!BIIK=9 %%tDKK$7$78;FG   'XN%1 $NN7G$NNr$c(V^8dQhRRRRRRRR/#) rL predicateCallable[[], bool]rrQrDr9rRrir)rTs"r%rUrj/s2""%" "  "  "r$c LV!4'dR#\P!4pV'g\VP4hVeWB8d\VP4hVPpVe\ V\ W$, R44p\P!V4K)TNg)rrr rMrIminmaxsleep)r|rrrDr sleep_fors&&$$ r%rSoftReadWriteLock._wait_for/s|{{##%Cdnn--#dnn--**I# 3x~s+CD JJy !r$cV^8dQhRR/#rr)rTs"r%rUrjCs G G4 Gr$c \VPP4p\\4;_uu_4VP RR7RRR4\ P!VPP4p\P!VP4'g'\P!VP4'g%VPP R2p\V4hVPfr\'dd\ P\!\ R^4,\",p\ P$!VPPV4Vn R#R#R# +'giEL,;i)i)r5NzB exists but is not a directory or is a symlink; refusing to use it O_DIRECTORY)rrrrrrmkdirrplstatstatS_ISLNKst_modeS_ISDIRrrv_SUPPORTS_DIR_FDO_RDONLYgetattr _O_NOFOLLOWopen)r| readers_pathstr`flagss& r%r#SoftReadWriteLock._open_readers_dirCsDKK//0 o & &   E  *'XXdkk)) * << # #4<< +C+C[[(())klCs# #    ',<,<KK'"mQ"??+ME#%774;;+>+>#FD -= '' & &s E-- E> cV^8dQhRR/#rr)rTs"r%rUrjQsdr$c 6VP4FpR# R#)TF)_iter_reader_entries)r|_s& r%rSoftReadWriteLock._any_readersQs**,A-r$cV^8dQhRR/#)rLrRzGenerator[tuple[str, bool]]r)rTs"r%rUrjVs@@&A@r$c# b"VPej\P!VP4;_uu_4pVF0p\VP4'dK VPR3xK2 RRR4R#\ VP P4p\P!V4;_uu_4pVF?p\VP4'dK \W2P, 4R3xKA RRR4R# +'giR#;i +'giR#;i5i)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) rvrpscandir_is_housekeeping_namerrrrrr)r|itentryrs& r%r&SoftReadWriteLock._iter_reader_entriesVs    +D0011RE0<<#jj$.. 2 DKK//0 ZZ % %,UZZ88lZZ78%??& % 21  % % %sA7D/DD0AD/7D#D= D/ D  D/ D, & D/c V^8dQhRRRR/#)rLrrPrRrir)rTs"r%rUrjis```$`r$c .pVP4F+wr4TPY4'd VPMR34K- TFwr5\ Y0P YR7K R# \dR#i;i)N)rHrr)rappendrvrrrH)r|rnamesrdirfd_relativefds&& r%r&SoftReadWriteLock._break_stale_readersisr.0 (,(A(A(C$ dND$8$8PTUV)DHD 6J6JPS _   s?A'' A65A6cV^8dQhRR/#rr)rTs"r%rUrjssr$c VPP;_uu_4VPpVf RRR4R#VPpVPpVP 'd VP MRpRRR4\XXR7pVfR#VwrgVe(\P!VPX4'gR#\W$R7R# +'giLc;i \dR#\dR#i;i)NFrT) rur)rwr8r-r:rv _read_markerhmaccompare_digestrFileNotFoundErrorr)r|rr8r-r read_resultinfo_mtimes& r%r!SoftReadWriteLock._refresh_markerss [[ ! ! !::D|" !**KJJE-1^^^T))F "#;v>  "  EF. WWT% 7 WWT% (G2biik]"V-?-?-A,B"ELLWU    s AC66Dc$V^8dQhRRRRRR/#)rLrrrr6rRz'tuple[_MarkerInfo | None, float] | Noner)rTs"r%rUrUs"22s2z2=d2r$cF\P\,\,p\'dVe\P !WVR7M\P !W4p\P!T4p\P!T\^,4p\P!T4\T4TP3# \ dR#i;i \ d\P!T4R#i;i \P!T4i;iNr) rprr _O_NONBLOCKrrrfstatr_MAX_MARKER_SIZEr_parse_marker_bytesst_mtime)rrrr.rdatas&$ r%r2r2s KK+ % 3E4D4DI[RWWT 0acahahimau "B772/!34D  t $bkk 11        s: C2C(8C  CC D+DDDD c V^8dQhRRRR/#)rLrbbytesrRz_MarkerInfo | Noner)rTs"r%rUrUsRReR(:Rr$cLV'd\V4\8dR#VPR4p\P !RT\P 4pTfR#\TR,^ 4pTR8dR#\TR,Y2R,R7# \dR#i;i)NrRu \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/r-r0)r-r/r0i) lenr_decodeUnicodeDecodeErrorrematchVERBOSEr.r,)rbtextrjr/s& r%r`r`s 3t9//{{7# HH    E } eElB C Y U7^Z?P QQ' sB B#"B#c ,V^8dQhRRRRRRRRRR /#) rLrrrHrPrrr6rRr9r)rTs"r%rUrUs<** **  *  *  *r$cn\WR7pVfR#VwrVW&, V8:dR#Vf\WR7R#V \ R\P!4 R\ P !^4 2p\'dVe\P!WW3R7M\V4PV4\WsR7pVfR#VwrV f\WsR7R#\P!VPV P4'gR#W8dR#\WsR7R# \dR#i;i)rFTr) src_dir_fd dst_dir_fd)r2r _BREAK_SUFFIXrprrrrrenamerrr3r4r-) rrHrrr6 info_before mtime_before break_name read_after info_after mtime_afters &$$$ r%rrst3K +K _,$6-"))+a8I8I"8M7NOJ   2 IId6 M J  j )j8J(J *   {00*2B2B C C! J&  s0 D%<D%D%% D43D4c$V^8dQhRRRRRR/#rLrrrr6rRrir)rTs"r%rUrU!s!  # *  r$c\\4;_uu_4\'dVe\P!WR7M\ V4P 4RRR4R# +'giR#;ir\)rr5rrpunlinkrrrs&$r%rr!sD # $ $   2 IId * J    % $ $ $s AA$$ A5 c$V^8dQhRRRRRR/#rzr)rTs"r%rUrU*s!tr$c\'d Ve\P!VRVR7R#\P!VR4R#r\)rrputimer}s&$r%rr*s+F. tF+ tr$c V^8dQhRRRR/#)rLpathrrRr9r)rTs"r%rUrU1s$$s$t$r$c\P!V4p\P!TP 4# \dR#i;i)F)rprr5rS_ISREGr)rrs& r%rr1s= XXd^ << ## s8 AAc V^8dQhRRRR/#)rLrrrRr9r)rTs"r%rUrU9s9999r$cFVPR4;'g \V9#)r) startswithrq)rs&r%r%r%9s ??3  8 8=D#88r$cV^8dQhRR/#rr)rTs"r%rUrU=s..t.r$c\P!4s\\P 44FpVP 4K R#r)rsrtrzlistrvaluesr=r_s r%_reset_all_after_forkr=s5 $..*..01++-2r$cV^8dQhRR/#rr)rTs"r%rUrUGs)))r$c\\P44F5p\\4;_uu_4VP RR7RRR4K7 R# +'giKL;i)TrN)rrrr Exceptionrrs r%_cleanup_all_instancesrGsH..01 i   4  (! 2 s A A* cV^8dQhRR/#rr)rTs"r%rUrUMs   r$c\'g\P!\4Rs\'g8\ \ R4'd \ P!\R7RsR#R#R#)Tregister_at_fork)after_in_childN) _atexit_registeredatexitregisterr_fork_registeredhasattrrprrrr$r%r{r{MsL  ./!  ,> ? ? +@A!@ r$)rr)K__conditional_annotations__r? __future__rrr3rprirrVrsysrsrr contextlibrr dataclassesrpathlibrtypingrrweakrefr filelock._apir filelock._errorr filelock._softr filelock._utilr collections.abcrrr4rqr_rrr]platformrsupports_dir_fdrrr"rtrzrrrr'r,r2typerArSThreadr;rr2r`rrrrr%rrr{__all__)rs@r%rs`"   /!)',#'23   b,* b,* <<7*LLrww":L:L/L?R?T<Tnn& $     $   $ $  $.$.bZ&+Z&zy''(  2D2(R<*  *Z t d$9.)   r$