EixN%SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKJrJr SSKJr SSKJr SSKJrJr SSKJr SS KJr SS KJr SS KJr SS K J!r! \(aSS K"J#r#J$r$ \Sr%Sr&Sr'\("\SS5r)\ RTS:g=(a \RV\RX;r-\"5r.S\/S'\ R`"5q1Sq2Sq3\"SS9"SS55r4\"SS55r5\"SS9"SS55r6\"SS55r7"S S!\85r9"S"S#\9S$9r:"S%S&\ Rv5rS5S*jr?SS'.S6S+jjr@SS'.S7S,jjrASS'.S7S-jjrBS8S.jrCS9S/jrDS:S0jrES:S1jrFS:S2jrGS#/rHg);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 Generator)readwritez.breaki O_NOFOLLOWwin32,WeakValueDictionary[Path, SoftReadWriteLock]_all_instancesFT)frozenc4\rSrSr%S\S'S\S'S\S'Srg)_Paths-strstaterreadersN__name__ __module__ __qualname____firstlineno____annotations____static_attributes__rT/home/mande/repo/quber/.venv/lib/python3.13/site-packages/filelock/_soft_rw/_sync.pyrr-s J J Lr&rc4\rSrSr%S\S'S\S'S\S'Srg) _Locks4threading.Lockinternal transactionr rrNrrr&r'r)r)4s r&r)c4\rSrSr%S\S'S\S'S\S'Srg) _MarkerInfo;rtokenintpidhostnamerNrrr&r'r/r/;s J HMr&r/cj\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S 'S\S'S\S'Srg)_HoldBzYEverything that exists only while a lock is held; ``None`` when the instance has no lock.r2level_Modemode int | Nonewrite_thread_idr marker_namebool is_readerr1_HeartbeatThreadheartbeat_threadthreading.Eventheartbeat_stoprN)r r!r"r#__doc__r$r%rr&r'r6r6Bs1c J KO J&&##r&r6cv^\rSrSr%S\S'S\S'S SSSSS S .SU4S jjjjrS rU=r$) _SoftRWMetaPr _instancesr+_instances_lockT>@N?blocking is_singletonheartbeat_intervalstale_threshold poll_intervalc >U(d[T U]UUUUUUUS9$[U5R5nUR UR R U5n U c"[T U]UUUUUUUS9n XR U'OMU RU:wdU RU:wa-SU RSU RSUSU3n [U 5eU sSSS5 $!,(df  g=f)NrLz$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=) super__call__rresolverIrHgettimeoutrM ValueError) cls lock_filerWrMrNrOrPrQ normalizedinstancemsg __class__s r'rT_SoftRWMeta.__call__Ts7#!)#5 /+$ )_,,.  ~~))*5H 7+%!-'9$3"/,.6z*!!W,0A0AX0M:8;K;K:LKX`XiXiWjk55rNr>rOrcrP float | NonerQrcreturnSoftReadWriteLock)r r!r"r#r$rTr% __classcell__r^s@r'rFrFPs<<## * !$((,#*)**  *  *"*&** **r&rFc\rSrSr%Sr\"5rS\S'\R"5r S!SSSSSS .S"S jjjr \ S#SS .S$S jjj5r \ S#SS .S$S jjj5rS#SS .S%SjjjrS#SS .S%SjjjrS&SjrSS.S'Sjjr\S!SS .S(Sjjj5rS)SjrS*SjrS+SjrS+SjrS,SjrS&SjrS-SjrS.SjrS/SjrS-SjrS&SjrS r g)0rfuE 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 rrHTrJNrKrLc ,US::aSU3n[U5eUcUS-nXe::aSUSUS3n[U5eUS::aSU3n[U5e[R"U5UlX lX0lXPlX`lXpl[URS3URS 3URS 3S 9Ul [UR5 [[R"5[R"5[URR S S 9S9UlSUlSUlSUlSUl[, U[.[1UR5R35'[55 SSS5 g!,(df  g=f)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)rrrrarWr,r-rF)rXosfspathrZrWrMrOrPrQr_pathsrr) threadingLockr r_locks_readers_dir_fd_hold_fork_invalidated_closed_all_instances_lockrrrU_register_hooks) selfrZrWrMrNrOrPrQr]s r'__init__SoftReadWriteLock.__init__ss  "=>P=QRCS/ !  "014O  0D_DUUYZlYmmnoCS/ ! A 8HCS/ ! ii 2% & );&5$1^^$F+^^$F+~~&h/  /^^%!(t{{00"=  ,0#' '," =AN4/779 :  ! s 5F FrMc#~# URXS9 Sv UR5 g!UR5 f=f7f)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 rN) acquire_readreleaser|rWrMs r' read_lockSoftReadWriteLock.read_locks2 '5   LLNDLLN=(=:=c#~# URXS9 Sv UR5 g!UR5 f=f7f)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"URSXS9$)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 rr_acquirers r'rSoftReadWriteLock.acquire_read s*}}VW}@@r&c"URSXS9$)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&cURSS9 URR UR(a SSS5 gSUlURb?[ [ 5 [R"UR5 SSS5 SUlSSS5 g!,(df  N=f!,(df  g=f)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)B/#B/%!BB/ B, (B// B=FrcURR UR(aSUlSSS5 gURnUc8U(a SSS5 gSURS[ U5S3n[ U5eU(aSUlOU=RS-slURS:a SSS5 gSUlSSS5 WRR5 URRURS-S9 UR(a[URUR S 9 g[UR5 g!,(df  N=f) 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 heldrg?rndir_fd)rur,rxrwrZid RuntimeErrorr8rCsetrAjoinrOr?_unlinkr=rv)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" !sEEAE?E E"cU"XUS9$)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)rYrZrWrMs r'get_lockSoftReadWriteLock.get_lockzs(999r&c Uc UROUnUc UROUnURR UR(aSUR S3n[ U5eUR(aSUR S3n[ U5eURbURU5sSSS5 $SSS5 [R"5nU(d$URRRSS9nONUS:Xa$URRRSS9nO$URRRSUS9nU(d[UR 5SeURR URb>URU5sSSS5 URRR5 $SSS5 US:XaSOXt-n [ R""S 5n US :XaUR%XUS 9upOUR'XUS 9up[(R*"5n [-UR.UR0U S [3U5S 3S9nURR [5SUUS :Xa[(R6"5OSU U U UU S9UlSSS5 UR95 [;US9URRR5 $!,(df  GNA=f!,(df  GN<=f!,(df  No=f!URRR5 f=f)NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFrraT)rMrWrdeadlinerMzfilelock-heartbeat-x)refreshinterval stop_eventnamer)r8r:r<r=r?r1rArClock)rWrMrur,rxrZrryrw_validate_reentranttime perf_counterr-acquirer rsecrets token_hex_acquire_writer_slot_acquire_reader_slotrsEventr@_refresh_markerrOrr6 get_identstartr )r|r:rWrMeffective_timeouteffective_blockingr]racquiredrr1r=r?r 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*& 1B6tE1L/ L)4 L LL) L&"L))&Mc URnUceURU:waDUS:XaSOSnUS:XaSOSnSUSURS[U5SUS US 3 n[ U5eUS:XaZ[ R "5=obR:wa6S URS[U5S US UR3n[ U5eU=RS- sl[US9$)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) rwr:rZrrrsrr<r8r )r|r:ropposite 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^^TR5 SUU4SjjnSU4SjjnTRXBUS9 TRXRUS9 TRR S4$![a! [TRR 5 ef=f)Nc>TRR [TRRTR [ R "5S9 [TRR5(a SSS5 g[TRRT5 SSS5 g![a SSS5 gf=f!,(df  g=f)NrPnowFT) rur_break_stale_markerrrrrPr _file_exists_atomic_create_markerFileExistsError)r|r1sr'try_claim_writer@SoftReadWriteLock._acquire_writer_slot..try_claim_writers""#DKK$5$5tG[G[aeajajalm 1 122 #"!)$++*;*;UC #'! #" ! #"s*A"C B.. C8CCC Cch>TRR [[5 [ TR R 5 SSS5 TR[R"55 TR5(+sSSS5 $!,(df  NP=f!,(df  g=fN) rurrr_touchrrr_break_stale_readersr _any_readersrsr'readers_drained_touchingHSoftReadWriteLock._acquire_writer_slot..readers_drained_touchingsn""g&4;;,,-'))$))+6,,.. #"'&#"s#B# BAB# B B## B1rFrer>)_open_readers_dir _wait_forr rrrr)r|r1rrMrrs`` r'r&SoftReadWriteLock._acquire_writer_slots     / 'XN  NN3QYN Z {{  %''   DKK%% &  s A+BcV^^^^^TR5 [R"5RS[R "53mTR m[[TRR5T- 5mSUUUUU4SjjnTRXBUS9 TbTS4$TS4$)N.cr>TRR [TRRTR [ R "5S9 [TRR5(a SSS5 gTb [TTTS9 O [TT5 SSS5 g!,(df  g=f)NrFrT) rurrrrrrPrrr)rfull_reader_path reader_namer|r1sr'try_claim_reader@SoftReadWriteLock._acquire_reader_slot..try_claim_readers""#DKK$5$5tG[G[aeajajalm 1 122 #"%)+uVL)*:EB#""sA"B(B(( B6rTr) ruuiduuid4hexrpgetpidrvrrrrrr)r|r1rrMrrrrs`` @@@r'r&SoftReadWriteLock._acquire_reader_slots  ))*!BIIK=9 %%tDKK$7$78;FG   'XN%1 $NN7G$NNr&c8U"5(ag[R"5nU(d[UR5eUbXB:a[UR5eURnUb[ U[ X$- S55n[R"U5 M)Ng)rrr rZrQminmaxsleep)r| predicaterrMr sleep_fors r'rSoftReadWriteLock._wait_for,s{{##%Cdnn--#dnn--**I# 3x~s+CD JJy !r&c[URR5n[[5 UR SS9 SSS5 [ R"URR5n[R"UR5(d%[R"UR5(d$URRS3n[U5eURcf[(aZ[ R[![ SS5-["-n[ R$"URRU5Ul ggg!,(df  GN=f)Ni)r:zB exists but is not a directory or is a symlink; refusing to use it O_DIRECTORYr)rrrrrrmkdirrplstatstatS_ISLNKst_modeS_ISDIRrrv_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"c2UR5Hn g g)NTF)_iter_reader_entries)r|_s r'rSoftReadWriteLock._any_readersNs**,A-r&c#$# URb_[R"UR5nUH/n[UR5(aMURS4v M1 SSS5 g[ UR R5n[R"U5nUH:n[UR5(aM[X2R- 5S4v M< SSS5 g!,(df  g=f!,(df  g=f7f)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_entriesSs    +D001RE0<<#jj$.. 2 DKK//0 ZZ %,UZZ88lZZ78%??& % 21  % %s@.DC.C.&>D$C?C?% D. C<8D? D  Dc/nUR5H*up4URX4(a UROS45 M, UHup5[ X0R XS9 M g![a gf=f)N)rPrr)rappendrvrrrP)r|rnamesrdirfd_relativefds r'r&SoftReadWriteLock._break_stale_readersfsr.0 (,(A(A(C$ dND$8$8PTUV)DHD 6J6JPS _   s>A"" A/.A/cURR URnUc SSS5 gURnURnUR (a UR OSnSSS5 [WWS9nUcgUupgUb&[R"URW5(dg[X$S9 g!,(df  NU=f![a gf=f)NFrT) rur,rwr=r1r?rv _read_markerhmaccompare_digestrFileNotFoundError)r|rr=r1r read_resultinfo_mtimes r'r!SoftReadWriteLock._refresh_markerps [[ ! !::D|" !**KJJE-1^^T))F "#;v>  "  rNr>rOrcrPrdrQrcreNoner)rWrdrM bool | NonerezGenerator[None])rWrdrMr rer rer)rr>rer)rZrbrWrcrMr>rerf)r:r9rWrdrMr rer )r:r9rer )r1rrrdrMr>reztuple[str, bool])rCallable[[], bool]rrdrMr>rerr)rezGenerator[tuple[str, bool]])rrcrer)!r r!r"r#rDr rHr$rsrtrIr}rrrrrrr classmethodrrrrrrrrrrrrr%rr&r'rfrfs.,\@S?TJ<Tnn&O 0 !$((,#0)00  0  0"0&00 0dQU&RV&ATXAA.BUYBB6,"(-(&T:  :)::  :  ::*D.D.D.  D.  D.L-(&(&( &(  &(  &(POO O  O  O4"%" "  "  "( G @&`. &r&rf) metaclasscJ^\rSrSrSU4SjjrSSjrSrU=r$)r@icF>[TU]USS9 XlX lX0lg)NT)rdaemon)rSr}_refresh _interval _stop_event)r|rrrrr^s r'r}_HeartbeatThread.__init__s' d40 !%r&cURRUR5(d]UR5(dURR 5 gURRUR5(dM\ggr)r*waitr)r(rrs r'run_HeartbeatThread.runsZ""''77==??  $$&""''77r&)r)r(r*) rr"rrcrrBrrrerr!)r r!r"r#r}r.r%rgrhs@r'r@r@sB &# & &$ &  &  &r&r@rc[R[R-[R-[-n[ (aUb[R "XSUS9nO[R "XS5nUS[R"5S[R"5S3RS5n[R"XE5 [R"U5 g![R"U5 f=f)Nir ascii) rpO_CREATO_EXCLO_WRONLYrrrrsocket gethostnameencoderr)rr1rrrcontents r'rrs JJ "R[[ 0; >EF. WWT% 7 WWT% (G2biik]"V-?-?-A,B"ELLWU    s 7AC$$C<c[R[-n[(aUb[R"XUS9O[R"X5n[R "U5n[R"U[S-5n[R"U5 [U5UR4$![ a gf=f![ a [R"U5 gf=f![R"U5 f=f)Nrr) rprrrrrfstatr_MAX_MARKER_SIZEr_parse_marker_bytesst_mtime)rrrrrdatas r'rrs KK+ %E4D4DI[RWWT 0acahahimau "B772/!34D  t $bkk 11        s59B64C6 CC C)C,(C))C,,DcU(a[U5[:agURS5n[R "SU[R 5nUcg[USS5nUS:ag[USX2SS9$![a gf=f) Nr2u \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 r3 ir1r4)r1r3r4) lenr<decodeUnicodeDecodeErrorrematchVERBOSEr2r/)r?textrFr3s r'r=r=s 3t9//{{7# HH    E } eElB C Y U7^Z?P QQ' sA>> B  B c[XS9nUcgUupVX&- U::agUc [XS9 gU[S[R"5S[ R "S53n[(aUb[R"XX3S9 O[U5RU5 [XsS9nUcgUupU c [XsS9 g[R"URU R5(dgX:ag[XsS9 g![a gf=f)NrFTrr) src_dir_fd dst_dir_fd)rr _BREAK_SUFFIXrprrrrrenamerrrrr1) rrPrrr 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&  s #C>C>> D  D c[[5 [(aUb[R"XS9 O[ U5R 5 SSS5 g!,(df  g=fNr)rrrrpunlinkrrrs r'rrs> # $   2 IId * J    % $ $s =A A$c|[(aUb[R"USUS9 g[R"US5 grU)rrputimerWs r'rrs+F. tF+ tr&c[R"U5n[R"UR 5$![a gf=f)NF)rprrrS_ISREGr)pathrs r'rr&s= XXd^ << ## s8 AAcDURS5=(d [U;$)Nr) startswithrL)rs r'r r .s ??3  8=D#88r&c[R"5q[[R 55HnUR 5 M gr)rsrtrzlistrvaluesrr\s r'_reset_all_after_forkrc2s5 $..*..01++-2r&c[[R55H*n[[5 UR SS9 SSS5 M, g!,(df  M>=f)NTr)r`rrar Exceptionrrbs r'_cleanup_all_instancesrf<sB..01 i   4  (! 2 s A  A c[(d[R"[5 Sq[(d1[ [ S5(a[ R"[S9 Sqggg)NTregister_at_fork)after_in_child) _atexit_registeredatexitregisterrf_fork_registeredhasattrrprhrcrr&r'r{r{BsL  ./!  ,> ? ? +@A!@ r&)rrr1rrr;rer)rrrr;rez'tuple[_MarkerInfo | None, float] | None)r?bytesrez_MarkerInfo | None) rrrPrcrrcrr;rer>)rrrr;rer)r\rrer>)rrrer>r!)IrD __future__rrkrrprErr6rsysrsrr contextlibrr dataclassesrpathlibrtypingrr weakrefr filelock._apir filelock._errorr filelock._softr filelock._utilrcollections.abcrrr9rLr<rrplatformrsupports_dir_fdrrr$rtrzrjrmrr)r/r6typerFrfThreadr@rrr=rrrrr rcrfr{__all__rr&r'rs`"   /!)',#'23   b,* <<7*Lrww":L:L/L?R?T<Tnn& $     $   $ $  $.$.bQ&+Q&hy''(JN 592&RF * **  *  *  *Z04 /3$9.)   r&