dtj(UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZmZmZddlmZddlmZddlmZmZmZddlmZdd lmZmZmZm Z m!Z!m"Z"m#Z#m$Z$dd l%m&Z&dd l'm(Z(dd l)m*Z*m+Z+m,Z,erdd l-m.Z.m/Z/edZ0dZ1de2d<dZ3de2d<e4eddZ5de2d<e4eddZ6de2d<e j7dko ej8ej9vZ:de2d<eZ;de2d<e j<a=de2d<e>Z?d e2d!<Gd"d#e@ZAGd$d%eA&ZBGd'd(e jCZDdd)dTd0ZEdUd4ZFdd)dVd5ZGdd)dWd6ZHdXd9ZIdd)dYd;ZJdd)dZd@ZKdd)d[dBZLd\dEZMd]dGZNd^dHZOedIJGdKdLZPeGdMdNZQedIJGdOdPZReGdQdRZSd_dSZTejUeTe!eBd%gZVdS)`zZCross-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_CONSTRUCTIONcHeZdZUded<ded< dddddd d dfdZxZS) _SoftRWMeta,WeakValueDictionary[Path, SoftReadWriteLock] _instanceszthreading.RLock_instances_lockT>@N?blocking is_singletonheartbeat_intervalstale_threshold poll_interval lock_filestr | os.PathLike[str]timeoutfloatr3boolr4r5r6 float | Noner7returnSoftReadWriteLockc nt|s(t|||||||St|}|j5|j|} | |tvrd|} t| tj } t | t|||||||} t |n#t |wxYwtj | krd} t| | |j|<n=| j|ks | j|kr'd| jd| jd|d|} t!| | cdddS#1swxYwYdS)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) RuntimeErrorosgetpidadddiscardr:r3 ValueError) clsr8r:r3r4r5r6r7 normalizedinstancemsgconstruction_pid __class__s U/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/filelock/_soft_rw/_sync.pyrBz_SoftRWMeta.__call__:sP !!! 77##!)#5 /+$ )__,,..    ~))*55H!???\y\\C&s+++#%9;; .22:>>> G$ww//!!)%1+=(7&3 0  H3:::FFFF2:::FFFF9;;"222kC&s+++-5z**!W,,0AX0M0MT8;KTTX`XiTT5<TTIQTT!oo%=                  s,"A'F* (D 2F* D))A4F**F.1F.r/)r8r9r:r;r3r<r4r<r5r;r6r=r7r;r>r?)__name__ __module__ __qualname____annotations__rB __classcell__rPs@rQr+r+6s|<<<<$$$$ 6 !$((,#666666666666r+ceZdZUdZeZded<ejZ dBdddddd dCdZ e dDdZ e dEdddFdZe dEdddFdZdEdddGdZdEdddGd Ze dBdddHd!ZdDd"Zd#d$dId&ZdJd)ZdKd,ZdLd/ZdMd0ZdNd3ZdOd4ZdOd5ZdNd6ZdPd9ZdDd:ZdQd;ZdRd=Z dSd?Z!dQd@Z"dDdAZ#dS)Tr?u 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 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-r/Tr0Nr1r2r8r9r:r;r3r<r4r5r6r=r7r>NonecLtj|_|dkrd|}t|||dz}||krd|d|d}t||dkrd|}t|tj||_||_||_||_||_ ||_ t|jd|jd |jd  |_ t|jttjtjt#|j jd |_d|_d|_d|_d|_t05|t2t5|<dddn #1swxYwYt7|dS)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)staterreadersr/r:internal transactionr_F)rFrG _creator_pidrJfspathr8r:r3r5r6r7_Paths_pathsr_Locks threadingLockrr__locks_readers_dir_fd_readers_dir_fd_token_hold_closedr(r&idr) selfr8r:r3r4r5r6r7rNs rQ__init__zSoftReadWriteLock.__init__sIKK  " "R>PRRCS// !  "014O 0 0 0o_ooZloooCS// ! A  HHHCS// ! i 22% & );&5$1^+++^+++~///    ///^%%!((t{0"===    ,015"#' "  , ,'+N2d88 $ , , , , , , , , , , , , , , ,d#####s&F  FFctjat|_tj|_tdSN) rjrkr(r r-RLockr.r)clear)rKs rQ_reset_class_after_forkz)SoftReadWriteLock._reset_class_after_forksG(n..,..'o//&,,.....rYr3 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 ryN) acquire_readreleaserrr:r3s rQ 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 ryN) acquire_writer~rs rQ 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 rry_acquirers rQr}zSoftReadWriteLock.acquire_reads*}}VWx}@@@rYc2|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 rryrrs rQrzSoftReadWriteLock.acquire_writes2}}Wg}AAArYc||||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 ry)rKr8r:r3s rQget_lockzSoftReadWriteLock.get_lock9s(s9g9999rYc,|jtjkrdS|d|jj5|jr ddddSd|_|jt5|j t|j d|_ |jdc}|_tt5tj |dddn #1swxYwYdddn #1swxYwYddddS#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. NTforce)rerFrGr~rlrcrprmrrnrrOSErrorclose)rrfds rQrzSoftReadWriteLock.closeOs   + + F 4    [ ! % %|  % % % % % % % % DL#/%''%%1=4T5OPPP15D./3/CT,B,!'**%% %%%%%%%%%%%%%%% %%%%%%%%%%%%%%% % % % % % % % % % % % % % % % % % %sa D D 3AC19C C1C C1!C "C1% D 1C5 5D 8C5 9D  D D Frrcx|jtjkrdS|jj5|j}|:|r ddddSd|jdt|d}t||rd|_ n|xj dzc_ |j dkr ddddSd|_dddn #1swxYwY|j |j |jdz|jrt!|j|j dS||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?radir_fd)rerFrGrlrcror8rqrElevelheartbeat_stopsetheartbeat_threadjoinr5 is_reader_unlink marker_namerm_unlink_writer_marker_if_ourstoken)rrrholdrNs rQr~zSoftReadWriteLock.releasefs   + + F [ !  :D|         j$.iiRPTXXiii"3'''   a zA~~        DJ               " !!! ""4+BS+H"III > ; D$T-A B B B B B B  . .tz : : : : :s B5AB5"B55B9<B9rstrc2|jj5t|jjx} ddddS|\}}|t j|j|s ddddSt|jjddddS#1swxYwYdSru) rlr_ _read_markerrhrhmaccompare_digestrr)rrrrinfo_s rQrz/SoftReadWriteLock._unlink_writer_marker_if_ourss[  ' '$T[%6777@ ' ' ' ' ' ' ' 'GD!|4#6tz5#I#I|  ' ' ' ' ' ' ' ' DK% & & &  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 'sB "B &B  BBmode_ModecV|jtjkrd|jd}t |||jn|}||jn|}|jj5|j rd|jd}t ||j !| |cdddS dddn #1swxYwYtj }|s!|jjd}nH|dkr!|jjd}n!|jjd|}|st!|jd ||||||jjS#|jjwxYw) NzSoftReadWriteLock on z4 was invalidated by fork(); construct a new instancez has been closedFryr/T)r3r:)rerFrGr8rEr:r3rlrcrpro_validate_reentranttime perf_counterrdacquirer_do_acquire_innerr~)rrrr:r3rNstartacquireds rQrzSoftReadWriteLock._acquires   + +n$.nnnCs## #")/$,,w$,$44==( [ ! 6 6| (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 # + + - - - -s=B00B47B4F F(effective_timeoutrc |jj5|j!||cdddS dddn #1swxYwY|dkrdn||z}t jd}|dkr||||\}}n||||\}}tj } t|j |j | dt|d} d} |jj5td||dkrtjnd|||| | |_ | n #t"$r} d|_| } Yd} ~ nd} ~ wwxYwdddn #1swxYwY| 0|rt%||j n||| t+| S) Nr/rdeadliner3zfilelock-heartbeat-x)refreshinterval stop_eventnamer)rrwrite_thread_idrrrrrrlock)rlrcrorsecrets token_hex_acquire_writer_slot_acquire_reader_slotrjEvent_HeartbeatThread_refresh_markerr5rq_Hold get_identr BaseExceptionrrmrr ) rrrrrr3rrrrr heartbeat start_errorerrors rQrz#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    -1 [ ! $ $9= 3 5 5 5d'#!*)   DJ $!!!!  $ $ $! #  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $  " : D,@AAAAA225999 !t,,,,sMAA A;6E32EE3 E$ EE3E$$E33E7:E7c |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) rorr8rqrErjrrrr )rrrropposite directionrNcurs rQrz%SoftReadWriteLock._validate_reentrantsYz 9  "&&..wwfH'+v~~ 9IO$OOOOBtHHOO%-OO6?OOO s## # 7??y':'<'< <AUUUWWW2d88WW"WW@D@TWW s## # a !t,,,,rYrtuple[str, bool]cdfd }dfd }||| |||n$#t$rwxYwjjdfS)Nr>r<czjj5cdddS#1swxYwYdSru)rlr__claim_writer_markerrrrsrQtry_claim_writerz@SoftReadWriteLock._acquire_writer_slot..try_claim_writers" 8 80077 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8s 044c6jj5s#s ddddSt j cdddS#1swxYwYdSNF)rlr__touch_writer_marker_if_oursr_break_stale_readersr _any_readersrsrQreaders_drained_touchingzHSoftReadWriteLock._acquire_writer_slot..readers_drained_touchings" / /88??!HaHabgHhHh!  / / / / / / / / ))$)++666,,...  / / / / / / / / / / / / / / / / / /s,B:BBBrFr>r<)_open_readers_dir _wait_forrrrhr)rrrrr3rrs`` rQrz&SoftReadWriteLock._acquire_writer_slots     8 8 8 8 8 8 8 / / / / / / / '(XNNN  NN3hQYN Z Z Z Z     . .u 5 5 5    { %''s A!A8ct|jj|jt jt |jjrdS t |jj|n#t$rYdSwxYwdS)Nr6nowFT)_break_stale_markerrhrr6r _file_exists_atomic_create_markerFileExistsErrorrs rQrz&SoftReadWriteLock._claim_writer_marker)s DK-t?SY]YbYdYdeeee  ) * * 5  !$+"3U ; ; ; ;   55 tsA** A87A8c8t|jj}|dS tj|t dz}n%#t $rYtj|dSwxYwt|}|tj |j |s tj|dStt 5t|jj|dddn #1swxYwY tj|dS#tj|wxYw)NFrrT) _open_markerrhrrFrrrr_parse_marker_bytesrrrrr)rrrrdatars rQrz.SoftReadWriteLock._touch_writer_marker_if_ours6sR$++ , , :5  wr#3a#788    HRLLLLL &t,,D|4#6tz5#I#I| HRLLLLL '"" 0 0dk'B//// 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 HRLLLLLBHRLLLLsP>D A DA  .D%D9C! D!C%%D(C%)DDcDtjjdt jjttj j z dfd } |||ndfS)N.r>r<cPjj5tjjjt jtjjr ddddStnt ddddS#1swxYwYdS)NrFrT) rlr_rrhrr6rrr)rfull_reader_path reader_namerrrsrQtry_claim_readerz@SoftReadWriteLock._acquire_reader_slot..try_claim_readerWs "  #DK$5tG[aeajalalmmmm 122!         %)+uVLLLLL)*:EBBB                  sA B(&BB"BrTr) ruuiduuid4hexrFrGrmrrrhr`r)rrrrr3rrrrs`` @@@rQrz&SoftReadWriteLock._acquire_reader_slotKs    )99BIKK99 %tDK$788;FGG           '(XNNN%1 7G$NNrY predicateCallable[[], bool]c$ |rdStj}|st|j|||krt|j|j}|!t |t ||z d}tj|)NTg)rrrr8r7minmaxsleep)rrrrr3r sleep_fors rQrzSoftReadWriteLock._wait_fores "y{{ #%%C .dn---#xdn---*I# 3x#~s+C+CDD Jy ! ! ! "rYc zt|jj}tt5|ddddn #1swxYwYt j|jj}tj |j stj |j s|jjd}t||j trt5t j|jjt jt%t ddzt&z} t)|}nQ#t*$rD} t j|n(#t*$r}t/d||Yd}~nd}~wwxYwd}~wwxYw||_ ||_ddddS#1swxYwYdSdSdS)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)rrhr`rrmkdirrFlstatstatS_ISLNKst_modeS_ISDIRrErmr%ropenO_RDONLYgetattrr!rrrrrn)rr readers_pathstrNrrregistration_error close_errors rQrz#SoftReadWriteLock._open_readers_dirysZDK/00 o & & + +   E  * * * + + + + + + + + + + + + + + +Xdk) * * < # # $4< +C+C $[(lllCs## #   ',< '!## 3 3WT[0"+M[\@]@]2]`k2kll 6r::EE$    (-\.'  (*$-2* 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 ( ' ' 'slAAA&A F,0E?F, F E F  F*F;F FF  FF,,F03F0ct|5}|D]}ddddS dddn #1swxYwYdS)NTF)r_iter_reader_entries)rrentriesrs rQrzSoftReadWriteLock._any_readerss T..00 1 1 W                          usAA AGenerator[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. 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) rmrFscandir_is_housekeeping_namerrrhr`r)rritentryr s rQrz&SoftReadWriteLock._iter_reader_entriess   +D011 /R//E0<</#j$..../ / / / / / / / / / / / / / / / FDK/00 Z % % @ @ @,UZ88@lUZ788%???? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @s#%AAA5CCCrc4g} t|5}|D]%\}}|||r|jndf& dddn #1swxYwYn#t$rYdSwxYw|D]\}}t ||j||dS)N)r6rr)rrappendrmrrr6)rrrnamesrrdirfd_relativers rQrz&SoftReadWriteLock._break_stale_readerss1.0 224455 [,3[[(D.LL$(X(<(&E=B>>.EED5) E5D99E<D9=EE-cttjtj|jj|_d|_d|_d|_dS)Nrb)rirjrkrlr_rormrnrrs rQ_reset_after_fork_in_childz,SoftReadWriteLock._reset_after_fork_in_childsU^%%!((+#     #%)"""rYrR)r8r9r:r;r3r<r4r<r5r;r6r=r7r;r>r[r>r[ru)r:r=r3rzr>r{)r:r=r3rzr>r )r8r9r:r;r3r<r>r?)rr<r>r[)rrr>r[)rrr:r=r3rzr>r ) rrrr;rr;r3r<r>r )rrr>r )rrrr=r3r<r>r)rrr>r<)rrrr=r3r<r>r[r)r>r)rr;r>r[)$rSrTrU__doc__r r-rVrjrvr.rs classmethodrxrrrr}rrrr~rrrrrrrrrrrrrrr rrYrQr?r?ss++Z@S?R?T?TJTTTT%io''O 1$ !$((,#1$1$1$1$1$1$f///[/QU^&RV^&ATXAAAAAA.BUYBBBBBB6:  :::::[:*%%%%.(-%;%;%;%;%;%;N ' ' ' ' . . . .D3-3-3-3-j----( ( ( ( (D    *OOOO4""""(33338 @@@@, ` ` ` `''''R******rYr?) metaclassc(eZdZd fd Zdd ZxZS)rrrrr;rthreading.Eventrrr>r[cxt|d||_||_||_dS)NT)rdaemon)rArs_refresh _interval _stop_event)rrrrrrrPs rQrsz_HeartbeatThread.__init__s> d4000 !%rYc|j|jsP|s|jdS|j|jNdSdSru)r+waitr*r)rrs rQrunz_HeartbeatThread.runsx"''77 ==??  $$&&&"''77     rY) rrrr;rr&rrr>r[r!)rSrTrUrsr.rWrXs@rQrrsQ & & & & & &rYrrrrr int | Noner>'tuple[_MarkerInfo | None, float] | Nonect||}|dS tj|}tj|jsd|jftj|Stj|tdz}n%#t$rYtj|dSwxYw tj|n#tj|wxYwt||jfS)Nrr) rrFfstatrS_ISREGrst_mtimerrrrr)rrrr rs rQrrs d6 * * *B zt  Xb\\ |BJ'' %$  wr+a/00       t $ $bk 11s/5A?!A?>B:? B! B: B!!B::Crintbytesc<tj|tdzS)Nr)rFrrrs rQrrs 72'!+ , ,,rYctjtztz}tr|tj|||ntj||SNr)rFrr!r#r%r)rrflagss rQrrsK K+ % 3E2B svGY274v . . . ._a_fgkmr_s_ssrYcH t||S#t$rYdSwxYwr9)rrrrs rQrr$s<tF3333 tts  !!r_MarkerInfo | NonecJ|rt|tkrdS |d}n#t$rYdSwxYwt jd|tj}|dSt|dd}|dkrdSt|d||dS) 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)rr@rB) lenrdecodeUnicodeDecodeErrorrematchVERBOSEr5 _MarkerInfo)rtextrGr@s rQrr+s 3t99///t{{7## tt H     E }t eElB  C Yt U7^uZ?P Q Q QQs4 AAr[ctt5tr|tj||n!t |ddddS#1swxYwYdSr9)rrr%rFunlinkrr<s rQrrIs # $ $    2 Id6 * * * * * JJ                        sAA$$A(+A(r6r;rr<cbt||x}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)rrrrFrGrrr%renamerrrrr) rr6rr read_result info_before mtime_before break_name read_after info_after mtime_afters rQrrRs$D8888 Au +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 CCrc ptjtjztjztz}t r|tj||d|}ntj||d}d} tj|}|j|j f}t||dtj dtj ddtj|dS#t $r;tj||#t#|||rt%||wxYw)Nir r?)rFO_CREATO_EXCLO_WRONLYr!r%rr2st_devst_inorrGsocket gethostnameencoderr _same_filer)rrrr:ridentityr s rQrr~s3 J "R[ 0; >E)F. WT5% 7 7 7 WT5% ( ((,H  Xb\\9bi'"II")++II1C1E1EIIIPPQXYYZZZ     JtXf$M$M$M  D ( ( ( ( s*A0C00AD5rctuple[int, int]c tr|tj||ntj|}n#t$rYdSwxYw|j|jf|kS)NrF)r%rFrrr]r^)rrcrr s rQrbrbso.> i6CURXd6 * * * *[][cdh[i[i uu Iry !X --s36 AApathc tj|}n#t$rYdSwxYwtj|jSr)rFrrrr3r)rfr s rQrrsJ Xd^^ uu < # ##s  %%c>|dpt|vS)Nr) startswithr)rs rQrrs ??3   8=D#88rYT)frozenc.eZdZUded<ded<ded<dS)rgrr_rr`NrSrTrUrVrrYrQrgrgs+JJJJJJLLLLLrYrgc.eZdZUded<ded<ded<dS)rir'rcrdrr_NrlrrYrQriris6rYric.eZdZUded<ded<ded<dS)rIrrr5r@rBNrlrrYrQrIrIs+JJJ HHHMMMMMrYrIcdeZdZUdZded<ded<ded<ded <d ed <ded <d ed<ded<dS)rzYEverything that exists only while a lock is held; ``None`` when the instance has no lock.r5rrrr/rrrr<rrrrr&rN)rSrTrUr"rVrrYrQrrslccJJJKKKOOOJJJ&&&&######rYrcttD]D}tt5|ddddn #1swxYwYEdS)NTr)listr&valuesr Exceptionr~)rMs rQ_cleanup_all_instancesrts..0011)) i  ) )   4  ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )))sA  A$ 'A$ )rrrr/r>r0)rr5r>r6)rrrr/r>r5)rrrr/r>r/)rr6r>r=)rrrr/r>r[) rrr6r;rr;rr/r>r<)rrrrrr/r>r[)rrrcrdrr/r>r<)rfrr>r<)rrr>r<r!)Wr" __future__ratexitrrFrFrr_rsysrjrr contextlibrrr dataclassesrpathlibrtypingr r r weakrefr filelock._apir rrrrrrrfilelock._errorrfilelock._softrfilelock._utilrrrcollections.abcrrrrrVrrr!r#platformrsupports_dir_fdr%r&rkr(rr)typer+r?ThreadrrrrrrrrrrbrrrgrirIrrtregister__all__rrYrQrs```""""""   8888888888!!!!!!0000000000''''''                    $#####''''''DDDDDDDDDD433333333  $ $$$$#####!'"lA66 6666!'"lA66 6666!$  7 YBGrGY