\j0jddlmZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZmZddlmZdd lmZdd lmZmZmZmZdd lmZdd lmZmZer,ddlZdd lm Z ddl!m"Z"ejFdk\rddl m$Z$nddl%m$Z$edZ&edZ'edGddZ(GddeZ)gdZ*y)) annotationsN)suppress) dataclass)EventThreadcurrent_thread) 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)B/root/.hermes/venv/lib/python3.12/site-packages/filelock/_lease.pyr"r"!s@N J  E> r0r"ceZdZUdZdZded<dZded<dZd ed <d d d d  dfdZe ddZ e ddZ e ddZ d fd Z d fd Zd!fd Zd fd Zd"dZd#dZd dZd#dZd$dZd%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|||_||_||_d|_d|_t|_ d|_ 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 ) ValueErrorsuper__init___lease_duration_heartbeat_interval_on_compromise_token _compromiser_heartbeat_stop _heartbeat)selfr$r9r:r;kwargsmsg __class__s r1r?zSoftFileLease.__init__Ps. Q 9.9KLCS/ !  %!/!!3 %66VWiVlmCS/ ! -f--#5 +"& 37$w)-r0c|jS)zEThe staleness in seconds after which a contender may take this claim.)r@rGs r1r9zSoftFileLease.lease_durationxs###r0c|jS)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. )rCrLs r1r%zSoftFileLease.token}s{{r0c|jS)z The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )rDrLs r1 compromisezSoftFileLease.compromisesr0c$|jtjd|_d|_t ||jjx}8|jjx} |j|||jyyy)N) _stop_heartbeatsecrets token_hexrCrDr>_acquire_context lock_file_fdlock_file_fd_identity_start_heartbeat)rGfdidentityrJs r1rUzSoftFileLease._acquires ''+  --,, ,B 9 ;; ;H?  ! !"h <? 9r0cP|jd|_t| yN)rRrCr>_releaserGrJs r1r^zSoftFileLease._releases!   r0cjt|j|j|jS)N)r%r9)r>_published_record_replacerCr@r_s r1razSoftFileLease._published_records,w(*33$++VZVjVj3kkr0cd|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)Nr4z 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_lockmoder9r@r$r rOSErrorr pidhostnamestartrtime)rGpeerownermtimeinorIrJs r1rez#SoftFileLease._try_break_stale_locksOO% %D . G ) +  uc ::    4#7#7 7>>""4U5I5I4LLl''**df (, ,g  <eiiEs;  < < yy{U"d&:&::s; < < 0B93B>9B>ct|j||||_|j|j|jyy)N)r$r%r'r))r"r$rDrB)rGr'r)r%s r1rz SoftFileLease._report_compromises@*T^^5Y_glm    *    0 0 1 +r0) r$zstr | os.PathLike[str]r9floatr:z float | Noner;z(Callable[[LeaseCompromise], None] | NonerHzUnpack[LockOptions]returnNone)rr)rz str | None)rzLeaseCompromise | None)rr)rr)rz%tuple[OwnerRecord, float, int] | None)rZintr[tuple[int, int]r%r#rr)rZrr[rr%r#rz&tuple[_RefreshOutcome, OSError | None])r'r&r)r(r%r#rr)r*r+r,r-r5r.r7r8r?propertyr9r%rOrUr^rarerdrYrRrwrr __classcell__)rJs@r1r3r3+s<%K$!&%(R #R !%+/BF &.)&. &. ) &. @ &.&&. &.P$$   = l<< ="$2r0r3)r&r"r3)+ __future__rrxrSrk contextlibr dataclassesr threadingrrrtypingr r _errorr _identityr _markerrrrr_softr_utilrrsyscollections.abcr_apir version_infortyping_extensionsr&_RefreshOutcomer"r3__all__r/r0r1rs"  !33))%MM")(! 7"!,NO34 $!!!Y2&Y2x r0