dtj0;,ddlmZddlZddlZddlZddlmZddlmZddl m Z m Z m Z m Z ddlmZmZddlmZdd lmZdd lmZmZmZmZdd lmZdd lmZmZer(ddlZdd l m!Z!ddl"m#Z#ej$dkrddlm%Z%nddl&m%Z%edZ'edZ(edGddZ)edGddZ*eGddZ+GddZ,Gdde,e Z-Gdd eZ.gd!Z/dS)") annotationsN)suppress) dataclass)EventThreadcurrent_threadlocal) TYPE_CHECKINGLiteral)LeaseSettingsMismatch)owner_is_stale)MarkerSoftFileLock OwnerMode OwnerRecord parse_marker)_read_lock_file)break_lock_filetouch)Callable) LockOptions) )Unpack)marker-missing owner-changedrefresh-failed)oklost transientT)frozenc@eZdZUdZded<ded<ded<dZded <dS) LeaseCompromisez6Why a held lease stopped being this process's to hold.str lock_filetokenCompromiseReasonreasonNOSError | Noneerror)__name__ __module__ __qualname____doc____annotations__r*M/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/filelock/_lease.pyr#r#!sG@@NNNJJJ E      r1r#c(eZdZUdZded<ded<dS) _HeartbeatzPA running heartbeat and the event that stops it, which only ever exist together.rthreadrstopN)r+r,r-r.r/r0r1r2r4r4+s(ZZNNNKKKKKr1r4c>eZdZUdZdZded<dZded<dZded<dS) _LeaseClaimzNThe state of one claim: its token, its heartbeat, and how that claim was lost.N str | Noner&LeaseCompromise | None compromisez_Heartbeat | None heartbeat)r+r,r-r.r&r/r;r<r0r1r2r8r83sKXXE)-J----#'I''''''r1r8ceZdZdZddZdS)_LeaseClaimHolderz,Holds the claim its owning context acquired.returnNonec,t|_dSN)r8claimselfs r2__init__z_LeaseClaimHolder.__init__Bs ]] r1Nr?r@)r+r,r-r.rFr0r1r2r>r><s.66 ######r1r>ceZdZdZdS)_ThreadLocalLeaseClaimHolderz:A thread local version of the ``_LeaseClaimHolder`` class.N)r+r,r-r.r0r1r2rIrIFsDDDDr1rIceZdZUdZdZded<dZded<dZd ed <d d d d d;fdZe ddZ e d?d!Z d@fd" Zd@fd# ZdAfd% Zd@fd& ZdBd(ZdCd/Zd@d0ZdDd3ZdEd5ZdFd:ZxZS)G SoftFileLeasea Existence lock whose claim expires, so a peer may take it while the previous holder still runs. A lease trades mutual exclusion for progress. The holder publishes a claim and refreshes it every ``heartbeat_interval`` seconds; a contender takes the marker once it is ``lease_duration`` seconds stale. Nothing stops the expired holder: it keeps running, and it keeps using whatever the lock protects. Treat the lease as a hint about who *should* be working, not as a guarantee that only one worker is. To make a protected resource reject a superseded holder, that resource must be linearizable and must fence on a monotonic generation it controls. :attr:`token` names a claim; it does not fence one. Where overlap is unacceptable, use :class:`StrictSoftFileLock ` instead. Every contender for a path must agree on ``lease_duration``. A contender that finds a claim published under a different duration raises :class:`LeaseSettingsMismatch ` rather than apply its own expiry to a peer that never agreed to it. Expiry reclaims less on Windows, which refuses to rename or delete a file another process holds open. A peer there takes an expired claim only once the previous holder's process exits and its handle closes; a holder that lives on but stops refreshing keeps the marker. Unix reclaims the marker either way. ``on_compromise`` fires from the heartbeat thread when a refresh fails, or when the marker vanishes or names another owner. The holder should stop touching the protected resource when it runs. Because it runs on that thread, a ``release()`` inside it only takes effect when the lease was built with ``thread_local=False``; the default thread-local context hides the claim from every thread but the one that acquired it, so the release does nothing. Signal the acquiring thread instead when the context stays thread-local. .. versionadded:: 3.30.0 leaser _owner_modeFbool_lifetime_supportedz(lease_duration sets when a lease expiresr$_lifetime_unsupported_reasong>@N)lease_durationheartbeat_interval on_compromiser%str | os.PathLike[str]rQfloatrR float | NonerS(Callable[[LeaseCompromise], None] | NonekwargsUnpack[LockOptions]r?r@c L|dkrd|}t|||dz }d|cxkr|ksnd|}t|tj|fi|||_||_||_|rtnt|_ dS)a Create a lease. :param lease_duration: seconds of marker staleness after which a contender may take the claim. Every contender for the path must pass the same value. :param heartbeat_interval: seconds between refreshes. Defaults to a third of ``lease_duration``, leaving room for two missed refreshes before a peer may take the claim. Must be shorter than ``lease_duration``. :param on_compromise: called from the heartbeat thread with a :class:`LeaseCompromise` when the claim is lost. :param kwargs: every other :class:`BaseFileLock ` option, ``timeout`` and ``mode`` among them. The metaclass passes them all by keyword, and taking them here lets :class:`AsyncSoftFileLease ` add the async plumbing a fixed signature would hide. rz%lease_duration must be positive, got NrzBheartbeat_interval must be positive and below lease_duration, got ) ValueErrorsuperrF_lease_duration_heartbeat_interval_on_compromiseis_thread_localrIr>_claims)rEr%rQrRrSrXmsg __class__s r2rFzSoftFileLease.__init__os. Q  L.LLCS// !  %!/!!3 %66666666mWimmCS// !--f----#5 + ZD,@,@,B,B Y ( (HY+ +  r1r8c|jjSrB)rarCrDs r2_claimzSoftFileLease._claims |!!r1c|jS)zEThe staleness in seconds after which a contender may take this claim.)r]rDs r2rQzSoftFileLease.lease_durations ##r1r9c|jjS)z The token naming the claim this process published. :returns: the token while the lease is held, ``None`` otherwise. It identifies a claim; it does not fence one. )rer&rDs r2r&zSoftFileLease.tokens{  r1r:c|jjS)z The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )rer;rDs r2r;zSoftFileLease.compromises{%%r1c4|j}|tjdx|_}d|_t |jj x})|jj x} | ||||dSdSdS)N) re_stop_heartbeatsecrets token_hexr&r;r\_acquire_context lock_file_fdlock_file_fd_identity_start_heartbeat)rErCr&fdidentityrcs r2rnzSoftFileLease._acquires  %/333 e -, ,B 9 ; ;H?  ! !%Xu = = = = = : 9??r1c|d|j_tdSrB)rkrer&r\_releaserErcs r2rvzSoftFileLease._releases;    r1rct|jj|jS)N)r&rQ)r\_published_record_replacerer&r]rws r2ryzSoftFileLease._published_records5ww((**33$+:K\`\p3qqqr1c\|x}"tdS|\}}}|jdkrdS|j|jkr)|jd|jd|jd}t|tt5t|j |j |j r$t|j|| ddddStj|z |jkrt|j||ddddS#1swxYwYdS)NrLz holds a lease of z s but this contender configured z:s; every contender for a path must agree on lease_duration) _read_peerr\_try_break_stale_lockmoderQr]r%r rOSErrorrpidhostnamestartrtime)rEpeerownermtimeinorbrcs r2r}z#SoftFileLease._try_break_stale_locksOO%% %D . GG ) ) + + + F uc : F  4#7 7 7>ffU5Iff'fff (,, ,g   < <eiEE s;;;  < < < < < < < < y{{U"d&:::s;;; < < < < < < < < < < < < < < < < < 0B93B>9B>r(r'r*r)ct|j||||_|j||jdSdS)N)r%r&r(r*)r#r%r;r_)rErCr(r*r&s r2rz SoftFileLease._report_compromise;sO+T^5Y_glmmm   *    0 1 1 1 1 1 + *r1) r%rTrQrUrRrVrSrWrXrYr?r@)r?r8)r?rU)r?r9)r?r:rG)r?r)r?r) rCr8rsrrtrr&r$r?r@) rCr8rsrrtrr&r$r6rr?r@) rCr8rsrrtrr&r$r?r) rCr8r(r'r*r)r&r$r?r@)r+r,r-r.rMr/rOrPrFpropertyrerQr&r;rnrvryr}r|rrrkrrr __classcell__)rcs@r2rKrKJs<%K$$$$!&%%%%(R RRRR !%+/BF ' ' ' ' ' ' ' ' R"""X"$$$X$!!!X!&&&X& > > > > > > rrrrrr<<<<<<< D D D D00 2 2 2 2 2 2 2 2r1rK)r'r#rK)0 __future__rrrlr contextlibr dataclassesr threadingrrrr typingr r _errorr _identityr_markerrrrr_softr_utilrrsyscollections.abcr_apir version_infortyping_extensionsr'_RefreshOutcomer#r4r8r>rIrK__all__r0r1r2rs""""""  !!!!!!::::::::::::))))))))))))))%%%%%%MMMMMMMMMMMM"""""")))))))) -JJJ((((((!!!!!! 7""!!!!!!!,,,,,,NO34 $!!!!!!!! $ ((((((( (########EEEEE#4eEEE}2}2}2}2}2&}2}2}2@   r1