^j8ddlmZddlZddlZddlZddlmZddlmZddl m Z m Z m Z m Z ddlmZmZddlmZdd lmZdd lmZmZmZmZdd lmZdd lmZmZer,ddlZdd l m!Z!ddl"m#Z#ejHdk\rddlm%Z%nddl&m%Z%edZ'edZ(edGddZ)edGddZ*eGddZ+GddZ,Gdde,e Z-Gdd eZ.gd!Z/y)") 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 <y) LeaseCompromisez6Why a held lease stopped being this process's to hold.str lock_filetokenCompromiseReasonreasonNOSError | Noneerror)__name__ __module__ __qualname____doc____annotations__r*Z/var/www/ramen.bs-engineer-server.com/venv/lib/python3.12/site-packages/filelock/_lease.pyr#r#!s@N J  E> r1r#c&eZdZUdZded<ded<y) _HeartbeatzPA running heartbeat and the event that stops it, which only ever exist together.rthreadrstopN)r+r,r-r.r/r0r1r2r4r4+sZ N Kr1r4c<eZdZUdZdZded<dZded<dZded<y) _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<r0r1r2r8r83s%XE:)-J&-#'I 'r1r8ceZdZdZddZy)_LeaseClaimHolderz,Holds the claim its owning context acquired.c"t|_yN)r8claimselfs r2__init__z_LeaseClaimHolder.__init__Bs  ] r1NreturnNone)r+r,r-r.rDr0r1r2r>r><s 6 #r1r>ceZdZdZy)_ThreadLocalLeaseClaimHolderz:A thread local version of the ``_LeaseClaimHolder`` class.N)r+r,r-r.r0r1r2rIrIFsDr1rIcXeZdZUdZdZded<dZded<dZd ed <d d d d  dfdZe ddZ e ddZ e d dZ e d!dZ d"fd Zd"fd Zd#fd Zd"fd Zd$dZd%dZd"dZ d&dZ d'dZ d(dZxZS)) 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_compromisec "|dkrd|}t|||dz }d|cxkr|ksnd|}t|t||fi|||_||_||_|j rt|_ yt|_ y)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 ) ValueErrorsuperrD_lease_duration_heartbeat_interval_on_compromiseis_thread_localrIr>_claims)rCr%rQrRrSkwargsmsg __class__s r2rDzSoftFileLease.__init__os. Q 9.9KLCS/ !  %!/!!3 %66VWiVlmCS/ ! -f--#5 + ZD,@,@,B (+  HY+  r1c.|jjSr@)r[rArBs r2_claimzSoftFileLease._claims||!!!r1c|jS)zEThe staleness in seconds after which a contender may take this claim.)rWrBs r2rQzSoftFileLease.lease_durations###r1c.|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. )r`r&rBs r2r&zSoftFileLease.tokens{{   r1c.|jjS)z The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )r`r;rBs r2r;zSoftFileLease.compromises{{%%%r1c.|j}|jtjdx|_}d|_t ||jjx}/|jjx} |j||||yyy)N) r`_stop_heartbeatsecrets token_hexr&r;rV_acquire_context lock_file_fdlock_file_fd_identity_start_heartbeat)rCrAr&fdidentityr^s r2rizSoftFileLease._acquires  %//33 e --,, ,B 9 ;; ;H?  ! !%Xu =? 9r1cd|jd|j_t|yr@)rfr`r&rV_releaserCr^s r2rqzSoftFileLease._releases&    r1c~t|j|jj|j S)N)r&rQ)rV_published_record_replacer`r&rWrrs r2rtzSoftFileLease._published_records2w(*33$++:K:K\`\p\p3qqr1cd|jx}t| y|\}}}|jdk7ry|j|j k7r4|j d|jd|j d}t|tt5t|j|j|jr!t|j || dddytj|z |j k\rt|j ||dddy#1swYyxYw)NrLz holds a lease of z s but this contender configured z:s; every contender for a path must agree on lease_duration) _read_peerrV_try_break_stale_lockmoderQrWr%r rOSErrorrpidhostnamestartrtime)rCpeerownermtimeinor]r^s r2rxz#SoftFileLease._try_break_stale_locksOO% %D . G ) +  uc ::    4#7#7 7>>""4U5I5I4LLl''**df (, ,g  <eiiEs;  < < yy{U"d&:&::s; < < #3 3    ! !$*B*B ! C 4r1ctj}|j|js|j ||||\}}|dk(ry|dk(rtj}nFtj|z |j |jz k\r|j |d||y|j|jsyy)Nrrr)r~ monotonicwaitrX_refresh_claimrW_report_compromise) rCrArnror&r6 last_successoutcomer*s r2rz$SoftFileLease._refresh_until_stoppeds~~' ))D445!00HeLNGU& $#~~/ !L0D4H4H4KcKc4cc''/?N))D445r1c tj|j}|j |jf|k7r|j |dd|y t|j|y#t$r}|j |d||Yd}~yd}~wt $r}d|fcYd}~Sd}~wwxYw#t $r}d|fcYd}~Sd}~wwxYw)Nr)rNr r)rn)rN) rlstatr%FileNotFoundErrorrrzst_devst_inor)rCrArnror&str*s r2rzSoftFileLease._refresh_claims &$..)B IIryy !X -  # #E?D% H & $..R (!  # #E+;UE J &% % & &% % &sGA*B)* B&3B  B&B!B&!B&) C2B;5C;Cct|j||||_|j|j|jyy)N)r%r&r(r*)r#r%r;rY)rCrAr(r*r&s r2rz SoftFileLease._report_compromise6sB+T^^5Y_glm    *    0 0 1 +r1) r%zstr | os.PathLike[str]rQfloatrRz float | NonerSz(Callable[[LeaseCompromise], None] | Noner\zUnpack[LockOptions]rFrG)rFr8)rFr)rFr9)rFr:rE)rFr)rFz%tuple[OwnerRecord, float, int] | None) rAr8rnintrotuple[int, int]r&r$rFrG) rAr8rnrrorr&r$r6rrFrG) rAr8rnrrorr&r$rFz&tuple[_RefreshOutcome, OSError | None]) rAr8r(r'r*r)r&r$rFrG)r+r,r-r.rMr/rOrPrDpropertyr`rQr&r;rirqrtrxrwrmrfrrr __classcell__)r^s@r2rKrKJs<%K$!&%(R #R !%+/BF ' )'  ' ) ' @ ' &'  ' R""$$!!&& > r<< D "      0 "    0 0 2 2! 2 2  2  2r1rK)r'r#rK)0 __future__rrrgr~ contextlibr dataclassesr threadingrrrr typingr r _errorr _identityr_markerrrrr_softr_utilrrsyscollections.abcr_apir version_infortyping_extensionsr'_RefreshOutcomer#r4r8r>rIrK__all__r0r1r2rs"  !::))%MM")(! 7"!,NO34 $!!! $ (( (##E#4eEx2&x2v r1