+ ~jxxa0t$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*] PVR8g;'d]PX]PZ9t.]!4t/R]0R&] Pb!4s2Rs3Rs4]!RR7!RR44t5]!RR44t6]!RR7!RR44t7]!RR44t8!RR]94t:!R R!]:R"7t;!R#R$] Px4t=R%R/R&R'llt>R%R/R(R)llt?R*R+lt@R%R/R,R-lltAR%R/R.R/lltBR%R/R0R1lltCR2R3ltDR4R5ltER6R7ltFR8R9ltGR:R;ltHR!.tIR#)=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_NOFOLLOWwin32,WeakValueDictionary[Path, SoftReadWriteLock]_all_instancesFT)frozenc6]tRt^-t$R]R&R]R&R]R&RtR#)_PathsstrstatewritereadersN__name__ __module__ __qualname____firstlineno____annotations____static_attributes__rl/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/filelock/_soft_rw/_sync.pyrr-s J J Lr#rc6]tRt^4t$R]R&R]R&R]R&RtR#)_Locksthreading.Lockinternal transactionr rrNrrr#r$r&r&4s r#r&c6]tRt^;t$R]R&R]R&R]R&RtR#) _MarkerInfortokenintpidhostnamerNrrr#r$r+r+;s J HMr#r+cl]tRt^Bt$RtR]R&R]R&R]R&R]R &R ]R &R]R &R ]R&R]R&RtR#)_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_stoprN)rrrr __doc__r!r"rr#r$r1r1Bs1c J KO J&&##r#r1c `a]tRt^Pt$R]R&R]R&RRRRRRR R R R R /RV3RlllltRtV;t#) _SoftRWMetar _instancesr'_instances_lockblockingT is_singletonheartbeat_interval>@stale_thresholdN poll_interval?c8V^8dQhRRRRRRRRRRR R R RR R /#) lock_filestr | os.PathLike[str]timeoutfloatrCr8rDrErG float | NonerHreturnSoftReadWriteLockr)formats"r$ __annotate___SoftRWMeta.__annotate__TsZ**)**  *  *"*&** *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))rCrDrErGrHNz$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=) super__call__rresolverBrAgetrNrC ValueError) clsrLrNrCrDrErGrH normalizedinstancemsg __class__s &&&$$$$$ r$rX_SoftRWMeta.__call__Ts7#!)#5 /+$ )_,,.  ~~))*5H 7+%!-'9$3"/,.6z*!!W,0A0AX0M:8;K;K:LKX`XiXiWjk55 r)rrrr r!rXr" __classcell__r`s@r$r@r@PsP<<##*  * " *%)*)-* $***r#r@c ]tRt^t$Rt]!4tR]R&]P!4t R6RRRRRRR R R R /R Rlllt ] R7RR /RRlll4t ] R7RR /RRlll4tR7RR /RRllltR7RR /RRllltRRltRR/RRllt]R6RR/RRlll4tRR ltR!R"ltR#R$ltR%R&ltR'R(ltR)R*ltR+R,ltR-R.ltR/R0ltR1R2ltR3R4ltR5t R #)8rRuE 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 rrArCTrDrErFrGNrHrIc8V^8dQhRRRRRRRRRRR R R RR R /#)rKrLrMrNrOrCr8rDrErGrPrHrQNoner)rSs"r$rTSoftReadWriteLock.__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)rrrrNr(r)rFrc)r[osfspathrLrNrCrErGrHr_pathsr r& threadingLockr r_locks_readers_dir_fd_hold_fork_invalidated_closed_all_instances_lockrrrY_register_hooks) selfrLrNrCrDrErGrHr_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/#rKrNrPrC bool | NonerQzGenerator[None]r)rSs"r$rTris";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 rCN) acquire_readreleaser{rNrCs&&$r$ read_lockSoftReadWriteLock.read_locks2 '5   LLNDLLNA,A>Ac$V^8dQhRRRRRR/#rr)rSs"r$rTris",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/#rKrNrPrCrrQr r)rSs"r$rTri s'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_read s*}}VW}@@r#c$V^8dQhRRRRRR/#rr)rSs"r$rTri$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/#rKrQrhr)rSs"r$rTri?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) rrtr(rxrurOSErrorrocloser{s&r$rSoftReadWriteLock.close?s 4  [[ ! ! !|||" ! DL##/g&&HHT112''+$" ! '& " ! !s)C,C;!B5 C5 C C C rFc V^8dQhRRRR/#)rKrr8rQrhr)rSs"r$rTriPs(&(&(&(&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?rmdir_fd)rtr(rwrvrLid RuntimeErrorr2r=setr;joinrEr9_unlinkr7ru)r{rholdr_s&$ r$rSoftReadWriteLock.releasePs#[[ ! ! !%%%!  " ! ::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/#) rKrLrMrNrOrCr8rQrRr)rSs"r$rTri{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\rLrNrCs&&&$r$get_lockSoftReadWriteLock.get_lockzs(999r#c(V^8dQhRRRRRRRR/#) rKr4r3rNrPrCrrQr r)rSs"r$rTris8D.D.D.D.  D.  D.r#c  4Vf VPMTpVf VPMTpVPP;_uu_4VP'dRVP R2p\ V4hVP'dRVP R2p\ V4hVPeVPV4uuRRR4#RRR4\P!4pV'g(VPPPRR7pMUVR8Xd(VPPPRR7pM'VPPPRVR7pV'g\VP 4RhVPP;_uu_4VPe@VPV4uuRRR4VPPP4#RRR4VR8XdRMWt,p \ P"!^4p VR8XdVP%WVR 7wrMVP'WVR 7wr\(P*!4p \-VP.VP0V R \3V4R 2R 7pVPP;_uu_4\5^TVR8Xd\(P6!4MRV V V VV R 7VnRRR4VP94\;VR7VPPP4# +'giELw;i +'giEL^;i +'giLx;i TPPP4i;i)NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFrT)rCrNrdeadlinerCzfilelock-heartbeat-x)refreshinterval stop_eventname)r2r4r6r7r9r,r;r=lockrc)rNrCrtr(rwrLrrxrv_validate_reentranttime perf_counterr)acquirer rsecrets token_hex_acquire_writer_slot_acquire_reader_slotrrEventr:_refresh_markerrErr1 get_identstartr )r{r4rNrCeffective_timeouteffective_blockingr_racquiredrr,r7r9r heartbeats&&&$ r$rSoftReadWriteLock._acquires-4ODLL.6.>T]]H [[ ! ! !%%%-dnn-==qr"3''|||-dnn-==MN"3''zz%//5" !&"!!#!{{..666FH " ${{..666EH{{..66N_6`H$..)t 3' .%%%::)33D9&%L KK # # + + -K*& 1B6tE.__annotate__s  $ r#c<SPP;_uu_4\SPPSP \ P !4R7\SPP4'd RRR4R#\SPPS4RRR4R# \d RRR4R#i;i +'giR#;i)rGnowNFT) rtr_break_stale_markerrqrrGr _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)rSs"r$rTrs / /$ /r#c <SPP;_uu_4\\4;_uu_4\ SP P 4RRR4SP\P!44SP4'*uuRRR4# +'giLS;i +'giR#;iN) rtrrr_touchrqr_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 rrqr)r{r,rrCrrsff$$ r$r&SoftReadWriteLock._acquire_writer_slots     / / 'XN  NN3QYN Z {{  %''   DKK%% &  s A%%,Bc(V^8dQhRRRRRRRR/#rr)rSs"r$rTris8OOO O  O  Or#c haaaaaSP4\P!4P R\P !4 2oSP o\\SPP4S, 4oRVVVVV3RllpSPWBVR7SeSR3#SR3#).cV^8dQhRR/#rr)rSs"r$rT.__annotate__s  $ r#c<SPP;_uu_4\SPPSP \ P !4R7\SPP4'd RRR4R#Se\SSSR7M \SS4RRR4R# +'giR#;i)rNFrT) rtrrrqrrGrrr)rfull_reader_path reader_namer{r,sr$try_claim_reader@SoftReadWriteLock._acquire_reader_slot..try_claim_readers"""#DKK$5$5tG[G[aeajajalm 1 122 #"%)+uVL)*:EB#"""sA&B: B:: C rT) ruuiduuid4hexrogetpidrurrrqrr)r{r,rrCrrrrsff$$ @@@r$r&SoftReadWriteLock._acquire_reader_slots  ))*!BIIK=9 %%tDKK$7$78;FG   'XN%1 $NN7G$NNr#c(V^8dQhRRRRRRRR/#) rK predicateCallable[[], bool]rrPrCr8rQrhr)rSs"r$rTri,s2""%" "  "  "r#c LV!4'dR#\P!4pV'g\VP4hVeWB8d\VP4hVPpVe\ V\ W$, R44p\P!V4K)TNg)rrr rLrHminmaxsleep)r{rrrCr sleep_fors&&$$ r$rSoftReadWriteLock._wait_for,s|{{##%Cdnn--#dnn--**I# 3x~s+CD JJy !r#cV^8dQhRR/#rr)rSs"r$rTri@s 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)r4NzB exists but is not a directory or is a symlink; refusing to use it O_DIRECTORY)rrqrrrmkdirrolstatstatS_ISLNKst_modeS_ISDIRrru_SUPPORTS_DIR_FDO_RDONLYgetattr _O_NOFOLLOWopen)r{ readers_pathstr_flagss& r$r#SoftReadWriteLock._open_readers_dir@sDKK//0 o & &   E  *'XXdkk)) * << # #4<< +C+C[[(())klCs# #    ',<,<KK'"mQ"??+ME#%774;;+>+>#FD -= '' & &s E-- E> cV^8dQhRR/#rr)rSs"r$rTriNsdr#c 6VP4FpR# R#)TF)_iter_reader_entries)r{_s& r$rSoftReadWriteLock._any_readersNs**,A-r#cV^8dQhRR/#)rKrQzGenerator[tuple[str, bool]]r)rSs"r$rTriSs@@&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) ruroscandir_is_housekeeping_namerrrqrr)r{itentryrs& r$r&SoftReadWriteLock._iter_reader_entriesSs    +D0011RE0<<#jj$.. 2 DKK//0 ZZ % %,UZZ88lZZ78%??& % 21  % % %sA7D/DD0AD/7D#D= D/ D  D/ D, & D/c V^8dQhRRRR/#)rKrrOrQrhr)rSs"r$rTrifs```$`r#c .pVP4F+wr4TPY4'd VPMR34K- TFwr5\ Y0P YR7K R# \dR#i;i)N)rGrr)rappendrurrrG)r{rnamesrdirfd_relativefds&& r$r&SoftReadWriteLock._break_stale_readersfsr.0 (,(A(A(C$ dND$8$8PTUV)DHD 6J6JPS _   s?A'' A65A6cV^8dQhRR/#rr)rSs"r$rTripsr#c VPP;_uu_4VPpVf RRR4R#VPpVPpVP 'd VP MRpRRR4\XXR7pVfR#VwrgVe(\P!VPX4'gR#\W$R7R# +'giLc;i \dR#i;i)NFrT) rtr(rvr7r,r9ru _read_markerhmaccompare_digestrFileNotFoundError)r{rr7r,r read_resultinfo_mtimes& r$r!SoftReadWriteLock._refresh_markerps [[ ! ! !::D|" !**KJJE-1^^^T))F "#;v>  "  r rAr!rrrsrBr|rrrrrrr classmethodrrrrrrrrrrrr9r"rr#r$rRrRs8,\@S?TJ<Tnn&O0  0 " 0%)0)-0 $00dQU&RV&ATXAA.BUYBB6,"(&u(&T:  ::*D.L-(&(PO4"( G @&`. & &r#rR) metaclassc:a]tRtRtRV3RlltRRltRtV;t#)r:ic ,V^8dQhRRRRRRRRR R /#) rKrrrrOrr<rrrQrhr)rSs"r$rT_HeartbeatThread.__annotate__s< & &# & &$ &  &  &r#c N<\SV`VRR7WnW nW0nR#)T)rdaemonN)rWr|_refresh _interval _stop_event)r{rrrrr`s&&&&&r$r|_HeartbeatThread.__init__s' d40 !%r#cV^8dQhRR/#rr)rSs"r$rTr?sTr#c VPPVP4'g5VP4'dKCVPP 4R#R#r)rDwaitrCrBrrs&r$run_HeartbeatThread.runsB""''77==??  $$&8r#)rCrBrD)rrrr r|rIr"rdres@r$r:r:s & &r#r:rc(V^8dQhRRRRRRRR/#)rKrrr,rr5rQrhr)rSs"r$rTrTs)   C J RV r#c"\P\P,\P,\,p\ 'dVe\P !WRVR7pM\P !WR4pV R\P!4 R\P!4 R2PR4p\P!WE4\P!V4R# \P!T4i;i)Nir ascii) roO_CREATO_EXCLO_WRONLYrrrrsocket gethostnameencoderr)rr,rrr*contents&&$ r$rrs JJ "R[[ 0; >EF. WWT% 7 WWT% (G2biik]"V-?-?-A,B"ELLWU    s AC66Dc$V^8dQhRRRRRR/#)rKrrrr5rQz'tuple[_MarkerInfo | None, float] | Noner)rSs"r$rTrTs"22s2z2=d2r#c0\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) rorrrrrfstatr_MAX_MARKER_SIZEr_parse_marker_bytesst_mtime)rrrr*rdatas&$ r$r.r.s KK+ %E4D4DI[RWWT 0acahahimau "B772/!34D  t $bkk 11        s: C2C8C CC C: C=9C::C==Dc V^8dQhRRRR/#)rKr]bytesrQz_MarkerInfo | Noner)rSs"r$rTrTsRReR(:Rr#cLV'd\V4\8dR#VPR4p\P !RT\P 4pTfR#\TR,^ 4pTR8dR#\TR,Y2R,R7# \dR#i;i)NrNu \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,r/)r,r.r/i) lenrZdecodeUnicodeDecodeErrorrematchVERBOSEr-r+)r]textrer.s& r$r[r[s 3t9//{{7# HH    E } eElB C Y U7^Z?P QQ' sB B#"B#c ,V^8dQhRRRRRRRRRR /#) rKrrrGrOrrr5rQr8r)rSs"r$rTrTs<** **  *  *  *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)r.r _BREAK_SUFFIXrorrrrrenamerrr/r0r,) rrGrrr2 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/#rKrrrr5rQrhr)rSs"r$rTrTs!  # *  r#c\\4;_uu_4\'dVe\P!WR7M\ V4P 4RRR4R# +'giR#;irX)rr1rrounlinkrrrs&$r$rrsD # $ $   2 IId * J    % $ $ $s AA$$ A5 c$V^8dQhRRRRRR/#rur)rSs"r$rTrTs!tr#c\'d Ve\P!VRVR7R#\P!VR4R#rX)rroutimerxs&$r$rrs+F. tF+ tr#c V^8dQhRRRR/#)rKpathrrQr8r)rSs"r$rTrT&s$$s$t$r#c\P!V4p\P!TP 4# \dR#i;i)F)ror r1r S_ISREGr)r}rs& r$rr&s= XXd^ << ## s8 AAc V^8dQhRRRR/#)rKrrrQr8r)rSs"r$rTrT.s9999r#cFVPR4;'g \V9#)r) startswithrl)rs&r$r!r!.s ??3  8 8=D#88r#cV^8dQhRR/#rr)rSs"r$rTrT2s..t.r#c\P!4s\\P 44FpVP 4K R#r)rrrsrylistrvaluesr9r^s r$_reset_all_after_forkr2s5 $..*..01++-2r#cV^8dQhRR/#rr)rSs"r$rTrT<s)))r#c\\P44F5p\\4;_uu_4VP RR7RRR4K7 R# +'giKL;i)TrN)rrrr Exceptionrrs r$_cleanup_all_instancesr<sH..01 i   4  (! 2 s A A* cV^8dQhRR/#rr)rSs"r$rTrTBs   r#c\'g\P!\4Rs\'g8\ \ R4'd \ P!\R7RsR#R#R#)Tregister_at_fork)after_in_childN) _atexit_registeredatexitregisterr_fork_registeredhasattrrorrrr#r$rzrzBsL  ./!  ,> ? ? +@A!@ r#)rr)J__conditional_annotations__r> __future__rrr/rordrrRr sysrrrr contextlibrr dataclassesrpathlibrtypingrrweakrefr filelock._apir filelock._errorr filelock._softr filelock._utilr collections.abcrrr3rlrZrrplatformrsupports_dir_fdrrr!rsryrrrr&r+r1typer@rRThreadr:rr.r[rrrrr!rrrz__all__)rs@r$rs`"   /!)',#'23   b,* <<7*LLrww":L:L/L?R?T<Tnn& $     $   $ $  $.$.bQ&+Q&hy''(  2D2&R<*  *Z t d$9.)   r#