*pj %SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKJrJrJr SSKJr SSKJr SSKJrJrJr SSKJr SS KJrJrJrJ r J!r!J"r"J#r#J$r$ SS K%J&r& SS K'J(r( SS K)J*r*J+r+J,r, \(aSS K-J.r.J/r/ \Sr0Sr1S\2S'Sr3S\2S'\4"\SS5r5S\2S'\4"\SS5r6S\2S'\ RnS:g=(a \Rp\Rr;r:S\2S'\"5r;S\2S'\ Rx"5q=S\2S'\>"5r?S \2S!'"S"S#\@5rA"S$S%\AS&9rB"S'S(\ R5rDSS).S@S*jjrESAS+jrFSS).SBS,jjrGSS).SCS-jjrHSDS.jrISS).SES/jjrJSS).SFS0jjrKSS).SGS1jjrLSHS2jrMSIS3jrNSJS4jrO\"S5S69"S7S855rP\"S9S:55rQ\"S5S69"S;S<55rR\"S=S>55rSSKS?jrT\R"\T5 \!"\B5 S%/rVg)LzZCross-process and cross-host reader/writer lock built on :class:`SoftFileLock` primitives.) annotationsN)closingcontextmanagersuppress) dataclass)Path) TYPE_CHECKINGFinalLiteral)WeakValueDictionary)AcquireReturnProxy_ensure_current_process_fork_transition_raise_grouped_errors_register_fork_class_register_fork_object_register_owned_descriptor_unregister_owned_descriptor)Timeout) SoftFileLock)ensure_directory_existstouch write_all)Callable Generator)readwritez.breakz Final[str] _BREAK_SUFFIXiz Final[int]_MAX_MARKER_SIZE O_NOFOLLOW _O_NOFOLLOW O_NONBLOCK _O_NONBLOCKwin32z Final[bool]_SUPPORTS_DIR_FDz2Final[WeakValueDictionary[int, SoftReadWriteLock]]_ALL_INSTANCESthreading.Lock_ALL_INSTANCES_LOCKzFinal[set[Path]]_SINGLETONS_UNDER_CONSTRUCTIONcv^\rSrSr%S\S'S\S'S SSSSS S .SU4S jjjjrS rU=r$) _SoftRWMeta6,WeakValueDictionary[Path, SoftReadWriteLock] _instanceszthreading.RLock_instances_lockT>@N?blocking is_singletonheartbeat_intervalstale_threshold poll_intervalc  >[5 U(d[T U] UUUUUUUS9$[U5R 5nUR  UR RU5n U cU[;aSU<3n [U 5e[R"5n [RU5 [T U] UUUUUUUS9n [RU5 [R"5U :wa Sn [U 5eXR U'OMU RU:wdU RU:wa-SU RSU RSUSU3n [!U 5eU sSSS5 $![RU5 f=f!,(df  g=f)Nr2z2Singleton lock construction is already active for zOLock construction cannot continue after fork; construct a new lock in the childz$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=)rsuper__call__rresolver/r.getr) RuntimeErrorosgetpidadddiscardtimeoutr3 ValueError) cls lock_filerBr3r4r5r6r7 normalizedinstancemsgconstruction_pid __class__s S/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/filelock/_soft_rw/_sync.pyr:_SoftRWMeta.__call__:s !7#!)#5 /+$ )_,,.  ~~))*5H!??Nym\C&s++#%99; .22:> G$w/!!)%1+=(7&3 0 H3:::F99;"22kC&s++-5z*!!W,0A0AX0M:8;K;K:LKX`XiXiWjk55..`` — 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 invalidates the inherited instance in the child so the child cannot double-own the lock with its parent; ``release()`` on that instance is a no-op, and the child must construct a new instance 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 r-r.Tr0Nr1r2c 2[R"5UlUS::aSU3n[U5eUcUS-nXe::aSUSUS3n[U5eUS::aSU3n[U5e[R"U5UlX lX0lXPlX`l Xpl [UR S3UR S 3UR S 3S 9Ul [UR 5 [[R "5[R "5[#URR$S S 9S9UlSUlSUlSUlSUl[0 U[2[5U5'SSS5 [7U5 g!,(df  N=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)staterreadersrOrBinternal transactionrdF)r>r? _creator_pidrCfspathrErBr3r5r6r7_Paths_pathsr_Locks threadingLockrrd_locks_readers_dir_fd_readers_dir_fd_token_hold_closedr(r&idr) selfrErBr3r4r5r6r7rHs rK__init__SoftReadWriteLock.__init__swIIK  "=>P=QRCS/ !  "014O  0D_DUUYZlYmmnoCS/ ! A 8HCS/ ! ii 2% & );&5$1^^$F+^^$F+~~&h/  /^^%!(t{{00"=  ,015"#' " '+N2d8 $!d#! s !F Fc[R"5q[5Ul[R "5Ul[R5 gN) rorpr(r r.RLockr/r)clear)rDs rK_reset_class_after_fork)SoftReadWriteLock._reset_class_after_forks6(nn.,.'oo/&,,.r^r3c#~# 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_readreleaserwrBr3s rK 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 rK 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 rKrSoftReadWriteLock.acquire_reads*}}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 rKrSoftReadWriteLock.acquire_writes2}}Wg}AAr^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 rrM)rDrErBr3s rKget_lockSoftReadWriteLock.get_lock9s(999r^cfUR[R"5:wagURSS9 URR  UR (a SSS5 gSUlURb}[5 URb[UR5 SUl URSsol[[5 [R"U5 SSS5 SSS5 SSS5 g!,(df  N=f!,(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. NTforce)rjr>r?rrqrhrurrrrsrrOSErrorclose)rwfds rKrSoftReadWriteLock.closeOs    +  4  [[ ! !||" ! DL##/%'11=4T5O5OP15D./3/C/CT,B,!'* + ( " !+* (' " !sC D"&D"A DD'D/D" D D D D"" D0FrcUR[R"5:wagURR UR nUc8U(a SSS5 gSUR S[U5S3n[U5eU(aSUl OU=RS-sl URS:a SSS5 gSUlSSS5 WRR5 URRURS-S9 UR(a[!UR"UR$S 9 gUR'UR(5 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?rfdir_fd)rjr>r?rqrhrtrErvr=levelheartbeat_stopsetheartbeat_threadjoinr5 is_reader_unlink marker_namerr_unlink_writer_marker_if_ourstoken)rwrholdrHs rKrSoftReadWriteLock.releasefs    +  [[ ! !::D| " ! 2$..1ARPTXJVhi"3''  a zzA~" !DJ"" ! ""4+B+BS+H"I >> D$$T-A-A B  . .tzz :-" !sEAEE E*chURR [URR5=nc SSS5 gUup4Ub&[ R "URU5(d SSS5 g[URR5 SSS5 g!,(df  g=fr{) rqrd _read_markerrmrhmaccompare_digestrr)rwrrinfo_s rKr/SoftReadWriteLock._unlink_writer_marker_if_ourss[[  $T[[%6%677@ GD|4#6#6tzz5#I#I   DKK%% &   s$B#.B#;B## B1cUR[R"5:waSURS3n[ U5eUc UR OUnUc UR OUnURR UR(aSURS3n[ U5eURbURU5sSSS5 $SSS5 [R"5nU(d$URRRSS9nONUS:Xa$URRRSS9nO$URRRSUS9nU(d[!UR5SeUR#XXSS9URRR%5 $!,(df  N=f!URRR%5 f=f) NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFrrOT)r3rB)rjr>r?rEr=rBr3rqrhrurt_validate_reentranttime perf_counterriacquirer_do_acquire_innerr)rwmoderBr3rHstartacquireds rKrSoftReadWriteLock._acquires    +)$..)99mnCs# #")/$,,w$,$44==( [[ ! !||-dnn-==MN"3''zz%//5 " !& "!!#{{..666FH ]{{..666EH{{..66g6VH$..)t 3 .))$)R KK # # + + -'" !& KK # # + + -s7A F4G4 G&G+c nURR URbURU5sSSS5 $SSS5 US:XaSOX2-n[R "S5nUS:XaUR XeUS9upxOURXeUS9upx[R"5n [URURU S[U5S3S9n Sn URR [SUUS:Xa[R"5OSUUUU U S 9UlU R!5 SSS5 U b/U(a[%XpR&S 9 U eUR)U5 U e[+US 9$!,(df  GN;=f!["an SUlU n Sn A NmSn A ff=f!,(df  N{=f) NrOrdeadliner3zfilelock-heartbeat-x)refreshinterval stop_eventnamer)rrwrite_thread_idrrrrrrlock)rqrhrtrsecrets token_hex_acquire_writer_slot_acquire_reader_slotroEvent_HeartbeatThread_refresh_markerr5rv_Hold get_identr BaseExceptionrrrrr ) rwreffective_timeoutrr3rrrrr heartbeat start_errorerrors rKr#SoftReadWriteLock._do_acquire_inners[[ ! !zz%//5" !%"-248Q!!"% 7?%)%>%>ubj%>%k "K%)%>%>ubj%>%k "K__& $((,,!&r$xl3  -1 [[ ! !9= 3 3 5d'#!*) DJ $!"  " ,@,@A 2259 !t,,W" !D! $! #  $" !s;E4/1F&!F4 F F# FF&F##F&& F4c 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) rtrrErvr=rorrrr )rwrropposite directionrHcurs rKr%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 SUU4SjjnSUU4SjjnTRXBUS9 TRXRUS9 TRR S4$![a TRT5 ef=f)Nc>TRR TRT5sSSS5 $!,(df  g=fr{)rqrd_claim_writer_markerrwrsrKtry_claim_writer@SoftReadWriteLock._acquire_writer_slot..try_claim_writers*""007#""s 3 AcD>TRR TRT5(d TRT5(d SSS5 gTR [ R "55 TR 5(+sSSS5 $!,(df  g=fNF)rqrd_touch_writer_marker_if_oursr_break_stale_readersr _any_readersrsrKreaders_drained_touchingHSoftReadWriteLock._acquire_writer_slot..readers_drained_touchingsp""88??HaHabgHhHh #" ))$))+6,,.. #""s.B8B BrFrTrR)_open_readers_dir _wait_forrrrmr)rwrrr3rrs`` rKr&SoftReadWriteLock._acquire_writer_slots   8 8 / / 'XN  NN3QYN Z {{  %''    . .u 5   s AA;c([URRUR[R"5S9 [ URR5(ag[ URRU5 g![a gf=f)Nr6nowFT)_break_stale_markerrmrr6r _file_exists_atomic_create_markerFileExistsErrorrs rKr&SoftReadWriteLock._claim_writer_marker)st DKK--t?S?SY]YbYbYde  )) * *  !$++"3"3U ;  s# B BBc`[URR5nUcg[R"U[ S-5n[U5nUb&[R"URU5(d[R"U5 g[[ 5 [URRUS9 SSS5 [R"U5 g![ a [R"U5 gf=f!,(df  NL=f![R"U5 f=f)NFrrT) _open_markerrmrr>rrrr_parse_marker_bytesrrrrr)rwrrdatars rKr.SoftReadWriteLock._touch_writer_marker_if_ours6s$++++ , :  wwr#3a#78't,D|4#6#6tzz5#I#I HHRL '"dkk''B/# HHRL  HHRL  #" HHRLsGC4DDD>D D(DDD DDD-cV^^^^^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) rqrdrrmrr6rrr)rfull_reader_path reader_namerwrsrKtry_claim_reader@SoftReadWriteLock._acquire_reader_slot..try_claim_readerWs""#DKK$5$5tG[G[aeajajalm 1 122 #"%)+uVL)*:EB#""sA"B(B(( B6rTr) ruuiduuid4hexr>r?rrstrrrmrer)rwrrr3rrrrs`` @@@rKr&SoftReadWriteLock._acquire_reader_slotKs  ))*!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)rrrrEr7minmaxsleep)rw predicaterr3r sleep_fors rKrSoftReadWriteLock._wait_fores{{##%Cdnn--#dnn--**I# 3x~s+CD JJy !r^c [URR5n[[5 UR SS9 SSS5 [ R"URR5n[R"UR5(d%[R"UR5(d$URRS3n[U5eURc[(a~[5 [ R "URR[ R"[%[ SS5-[&-5n[)U5nX@l XPlSSS5 ggg!,(df  GN?=f![*aAn[ R,"U5 e![*an[/SUU5 SnAeSnAff=fSnAff=f!,(df  g=f)Ni)rzB exists but is not a directory or is a symlink; refusing to use it O_DIRECTORYrz>reader directory registration and descriptor close both failed)rrmrerrmkdirr>lstatstatS_ISLNKst_modeS_ISDIRr=rrr%ropenO_RDONLYgetattrr!rrrrrs)rw readers_pathstrHrrregistration_error close_errors rKr#SoftReadWriteLock._open_readers_dirysrDKK//0 o &   E  *'XXdkk)) * << # #4<< +C+C[[(())klCs# #    ',<,<!#WWT[[00"++M[\@]2]`k2kl 6r:E(*$-2*$#-= '' &%   )-\.'    $#s`E7AG F  G7 F GF+*G+ G 5 GGG  GGG G%c[UR55nUH n SSS5 g SSS5 g!,(df  g=f)NTF)r_iter_reader_entries)rwentriesrs rKrSoftReadWriteLock._any_readerss@ T..0 1W2 122 1s 55 Ac#$# 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. A consumer that stops early must close this generator: while suspended it holds the ``scandir`` handle open, and leaving that to the collector surfaces as an unraisable exception inside whatever runs next. NTF) rrr>scandir_is_housekeeping_namerrrmrer )rwitentryrs rKr#&SoftReadWriteLock._iter_reader_entriess    +D001RE0<<#jj$.. 2 DKK//0 ZZ %,UZZ88lZZ78%??& % 21  % %s@.DC.C.&>D$C?C?% D. C<8D? D  Dc./n[UR55nUH*upEURXE(a UROS45 M, SSS5 UHupF[ X@R XS9 M g!,(df  N.=f![a gf=f)N)r6rr)rr#appendrrrrr6)rwrnamesr$rdirfd_relativers rKr&SoftReadWriteLock._break_stale_readerss.0 2245,3(DLL$(<(rrrrrr)rwrrrrrrrs rKr!SoftReadWriteLock._refresh_markers8 [[ ! !::D|" !**KJJE-1^^T))F "  V[TU]USS9 XlX lX0lg)NT)rdaemon)r9rx_refresh _interval _stop_event)rwrrrrrJs rKrx_HeartbeatThread.__init__s' d40 !%r^cURRUR5(d]UR5(dURR 5 gURRUR5(dM\ggr{)rGwaitrFrErr7s rKrun_HeartbeatThread.runsZ""''77==??  $$&""''77r^)rFrErG) rr>rrQrthreading.Eventrr rTr:r;)rVrWrXrYrxrKr[r\r]s@rKrrsB &# & &$ &  &  &r^rrc[XS9nUcg[R"U5n[R"UR 5(d$SUR 4[R"U5 $[R"U[S-5n[R"U5 [U5UR 4$![a [R"U5 gf=f![R"U5 f=f)Nrr) rr>fstatrS_ISREGrst_mtimerrrrr)rrrrrs rKrrs d *B z  XXb\ ||BJJ''$  wwr+a/0  t $bkk 11     s*AB:.B:: CC CC C8c>[R"U[S-5$)Nr)r>rrrs rKr4r4s 772'!+ ,,r^c[R[-[-n[(aUb[R "XUS9$[R "X5$Nr)r>rr!r#r%r)rrflagss rKr2r2sD KK+ % 3E2B2BvGY2774v .s_a_f_fgk_ssr^c6[XS9$![a gf=frT)r2rrrs rKrr$s$t33 s  cU(a[U5[:agURS5n[R "SU[R 5nUcg[USS5nUS:ag[USX2SS9$![a gf=f) Nasciiu \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 pid irhostname)rrZr\) lenrdecodeUnicodeDecodeErrorrematchVERBOSEint _MarkerInfo)rtextrarZs rKrr+s 3t9//{{7# HH    E } eElB C Y U7^Z?P QQ' sA>> B  B c[[5 [(aUb[R"XS9 O[ U5R 5 SSS5 g!,(df  g=frT)rr3r%r>unlinkrrWs rKrrIs> # $   2 IId * J    % $ $s =A A$c[XS9=ncgUupVX&- 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)rrrr>r?rrr%renamerrrrr) rr6rr read_result info_before mtime_before break_name read_after info_after mtime_afters rKrrRs$D88 A +K _,$6-"))+a8I8I"8M7NOJ   2 IId6 M J  j )j8J(J *   {00*2B2B C C! J&  s #C>C>> D  D c [R[R-[R-[-n[ (aUb[R "XSUS9nO[R "XS5nSn[R"U5nURUR4n[XAS[R"5S[R"5S3RS55 [R"U5 g![ a3 [R"U5 Ub[#XUS9(a [%XS9 ef=f)Nir rY)r>O_CREATO_EXCLO_WRONLYr!r%rrOst_devst_inorr?socket gethostnameencoderr _same_filer)rrrrUridentityrs rKrr~s JJ "R[[ 0; >EF. WWT% 7 WWT% ((,H  XXb\99bii'"r"))+b1C1C1E0FbIPPQXYZ     Jtf$M D ( s 9A7D=Ec[(aUb[R"XS9O[R"U5nURUR 4U:H$![a gf=f)NrF)r%r>rrrxry)rr~rrs rKr}r}s\.>.>6CURXXd *[][c[cdh[i IIryy !X -- s8A A"!A"c[R"U5n[R"UR 5$![a gf=fr)r>rr3rrPr)pathrs rKrrs= XXd^ << ## s8 AAcDURS5=(d [U;$)Nr) startswithr)rs rKr(r(s ??3  8=D#88r^T)frozenc4\rSrSr%S\S'S\S'S\S'Srg)rlir rdrrerMNrVrWrXrYrZr[rMr^rKrlrls J J Lr^rlc4\rSrSr%S\S'S\S'S\S'Srg) rnir'rhrirrdrMNrrMr^rKrnrns r^rnc4\rSrSr%S\S'S\S'S\S'Srg) rdir rrcrZr\rMNrrMr^rKrdrds J HMr^rdcj\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S 'S\S'S\S'Srg)rizYEverything that exists only while a lock is held; ``None`` when the instance has no lock.rcrr=r int | Nonerr rrRrrrrrMrrMN)rVrWrXrYr?rZr[rMr^rKrrs1c J KO J&&##r^rc[[R55H*n[[5 UR SS9 SSS5 M, g!,(df  M>=f)NTr)listr&valuesr Exceptionr)rGs rK_cleanup_all_instancesrsB..01 i   4  (! 2 s A  A )rr rrrTz'tuple[_MarkerInfo | None, float] | None)rrcrTbytes)rr rrrTrc)rr rrrTr)rrrTz_MarkerInfo | None)rr rrrTr:) rr r6rQrrQrrrTrR)rr rr rrrTr:)rr r~ztuple[int, int]rrrTrR)rr rTrR)rr rTrRr;)Wr? __future__ratexitrr>r`rrzrsysrorr contextlibrrr dataclassesrpathlibrtypingr r r weakrefr filelock._apir rrrrrrrfilelock._errorrfilelock._softrfilelock._utilrrrcollections.abcrrr=rrZrrr!r#platformrsupports_dir_fdr%r&rpr(rr)typer+rUThreadrrr4r2rrrrrr}rr(rlrnrdrrregister__all__rMr^rKrsR`"   88!00'   $'DD3  $ z$#*#!"lA6 Z6!"lA6 Z6!$  7 YBGGrGYGY