"j>8ddlmZddlZddlZddlZddlmZddlmZddl m Z ddl m Z m Z mZmZddlmZmZdd lmZdd lmZdd lmZmZmZmZdd lmZdd lmZm Z er(ddl!Z!ddl"m#Z#ddl$m%Z%e!j&dkrddlm'Z'nddl(m'Z'edZ)edZ*edGddZ+edGddZ,eGddZ-GddZ.Gdde.eZ/Gd d!eZ0gd"Z1dS)#) annotationsN)suppress) dataclass)isfinite)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-failedevicted)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,O/home/spazio/kingdom_calls/venv/lib/python3.11/site-packages/filelock/_lease.pyr%r%$sG@@NNNJJJ E      r3r%c(eZdZUdZded<ded<dS) _HeartbeatzPA running heartbeat and the event that stops it, which only ever exist together.rthreadrstopN)r-r.r/r0r1r2r3r4r6r6.s(ZZNNNKKKKKr3r6c>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/r0r(r1r=r>r2r3r4r:r:6sKXXE)-J----#'I''''''r3r:ceZdZdZddZdS)_LeaseClaimHolderz,Holds the claim its owning context acquired.returnNonec,t|_dSN)r:claimselfs r4__init__z_LeaseClaimHolder.__init__Es ]] r3NrArB)r-r.r/r0rHr2r3r4r@r@?s.66 ######r3r@ceZdZdZdS)_ThreadLocalLeaseClaimHolderz:A thread local version of the ``_LeaseClaimHolder`` class.N)r-r.r/r0r2r3r4rKrKIsDDDDr3rKceZdZUdZdZded<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]rSfloatrT float | NonerU(Callable[[LeaseCompromise], None] | NonekwargsUnpack[LockOptions]rArBc t|tst|ttfs&dt |j}t |t|r|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. z5lease_duration must be a finite positive number, not rz0lease_duration must be positive and finite, got NrzBheartbeat_interval must be positive and below lease_duration, got ) isinstancerPintrWtyper- TypeErrorr ValueErrorsuperrH_lease_duration_heartbeat_interval_on_compromiseis_thread_localrKr@_claims)rGr'rSrTrUrZmsg __class__s r4rHzSoftFileLease.__init__rs8. nd + + !:nsTYl3[3[ !i$~J^J^JgiiCC.. '' ">Q+>+>W^WWCS// !  %!/!!3 %66666666mWimmCS// !--f----#5 + ZD,@,@,B,B Y ( (HY+ +  r3r:c|jjSrD)rgrErFs r4_claimzSoftFileLease._claims |!!r3c|jS)zEThe staleness in seconds after which a contender may take this claim.)rcrFs r4rSzSoftFileLease.lease_durations ##r3r;c|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. )rkr(rFs r4r(zSoftFileLease.tokens{  r3r<c|jjS)z The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )rkr=rFs r4r=zSoftFileLease.compromises{%%r3cn|j}|tjdx|_}d|_ t n#t$r d|_wxYw|j j x})|j j x} | ||||dSd|_dS)N) rk_stop_heartbeatsecrets token_hexr(r=rb_acquire BaseException_context lock_file_fdlock_file_fd_identity_start_heartbeat)rGrEr(fdidentityris r4rtzSoftFileLease._acquires  %/333 e  GG         EK   -, ,B 9 ; ;H?  ! !%Xu = = = = =EKKKs A!!A4c|d|j_tdSrD)rqrkr(rb_releaserGris r4r}zSoftFileLease._releases;    r3rct|jj|jS)N)r(rS)rb_published_record_replacerkr(rcr~s r4rzSoftFileLease._published_records5ww((**33$+:K\`\p3qqqr3c\|x}"tdS|\}}}|jdkrdS|j|jkr)|jd|jd|jd}t|tt5t|j |j |j r$t|j|| ddddStj|z |jkrt|j||ddddS#1swxYwYdS)NrNz holds a lease of z s but this contender configured z:s; every contender for a path must agree on lease_duration) _read_peerrb_try_break_stale_lockmoderSrcr'rrOSErrorrpidhostnamestartrtime)rGpeerownermtimeinorhris r4rz#SoftFileLease._try_break_stale_locksOO%% %D . GG ) ) + + + F uc : F  4#7 7 7>ffU5Iff'fff (,, ,g   < <eiEE s;;;  < < < < < < < < y{{U"d&:::s;;; < < < < < < < < < < < < < < < < < r)rGrErzr{r(r8r7s r4ryzSoftFileLease._start_heartbeatsmww.Xud3029;;00    %VT22 r3c|j}|jx}dS|jd|_|jj7|jt ur$|j|jdSdSdS)N)timeout) rkr>r8setr7identr joinrd)rGrEr>s r4rqzSoftFileLease._stop_heartbeat s  (I 1 F   ! -)2B.JZJZ2Z2Z   ! !$*B ! C C C C C . -2Z2Zr3r8rctj}||js|||||\}}|dkrdS|dkrtj}nAtj|z |j|jz kr||d||dS||jdSdS)Nr!r r)r monotonicwaitrd_refresh_claimrc_report_compromise) rGrErzr{r(r8 last_successoutcomer,s r4rz$SoftFileLease._refresh_until_stoppeds~'' ))D455 !00HeLLNGU&  $#~// !!L0D4H4Kc4ccc''/?NNN))D455     r3&tuple[_RefreshOutcome, OSError | None]c tj|j}nF#t$r#}||d||Yd}~dSd}~wt $r}d|fcYd}~Sd}~wwxYw|j|jf|kr||dd|dS t|j|n#t $r}d|fcYd}~Sd}~wwxYwdS)Nr)r!Nr"r)rz)r N) rlstatr'FileNotFoundErrorrrst_devst_inor)rGrErzr{r(str,s r4rzSoftFileLease._refresh_claim0s! &$.))BB     # #E+;UE J J J<<<<< & & &% % % % % % % & Iry !X - -  # #E?D% H H H< & $.R ( ( ( ( ( & & &% % % % % % % &zsD AA AAAAB&& B>0B93B>9B>r*r)r,r+ct|j||||_|j||jdSdS)N)r'r(r*r,)r%r'r=re)rGrEr*r,r(s r4rz SoftFileLease._report_compromiseHsO+T^5Y_glmmm   *    0 1 1 1 1 1 + *r3) r'rVrSrWrTrXrUrYrZr[rArB)rAr:)rArW)rAr;)rAr<rI)rAr)rAr) rEr:rzr^r{rr(r&rArB) rEr:rzr^r{rr(r&r8rrArB) rEr:rzr^r{rr(r&rAr) rEr:r*r)r,r+r(r&rArB)r-r.r/r0rOr1rQrRrHpropertyrkrSr(r=rtr}rrrryrqrrr __classcell__)ris@r4rMrMMs<%K$$$$!&%%%%(R RRRR !%+/BF * * * * * * * * X"""X"$$$X$!!!X!&&&X&( rrrrrr<<<<<<< D D D D00 2 2 2 2 2 2 2 2r3rM)r)r%rM)2 __future__rrrrr contextlibr dataclassesrmathr threadingrrr r typingr r _errorr _identityr_markerrrrr_softr_utilrrsyscollections.abcr_apir version_infortyping_extensionsr)_RefreshOutcomer%r6r:r@rKrM__all__r2r3r4rs""""""  !!!!!!::::::::::::))))))))))))))%%%%%%MMMMMMMMMMMM"""""")))))))) -JJJ((((((!!!!!! 7""!!!!!!!,,,,,,YZ34 $!!!!!!!! $ ((((((( (########EEEEE#4eEEEG2G2G2G2G2&G2G2G2T   r3