Ë •Kêjyãó—UdZddlmZgd¢ZddlZddlZddlmZddlm Z ddl mZddlm Z dd lmZmZmZmZdd lmZddlmZerddlmZed ZedZdZded<dZded<dZded<dZded<dZ ded<dZ!ded<dZ"ded<dZ#ded <d!Z$ded"<d#Z%ded$<Gd%„d&e&«Z'Gd'„d(e«Z(e d)¬*«Gd+„d,««Z)d9d-„Z*d:d.„Z+d;d/„Z,da; The generation-log protocol behind :class:`~filelock.SoftReadWriteLock`. The lock's whole state is a sequence of immutable snapshots, ``gen/``, each naming the writer and the readers that hold the lock at generation ``N``. Every transition is one atomic publication of the next snapshot: a participant reads the latest generation, derives the successor it wants, and links a fully written temporary file to ``gen/``. The link fails if a peer got there first, so the participant re-reads and tries again. No step is ever half done: a crash leaves at most an unlinked temporary file, never a state that another participant must repair before it can proceed. Liveness rests on a nonce, not a clock. Each participant keeps ``holders/`` and rewrites its nonce every heartbeat. A contender records the bytes it read there and the moment it read them on its own monotonic clock; a member whose bytes have not changed for ``stale_threshold`` is evicted by committing a snapshot without it. Two hosts never compare clocks, so a skewed file server or a suspended virtual machine cannot make a live holder look dead. The generation number is monotonic and unique to one transition within one incarnation of the log, so the generation at which a hold was granted fences it: a resource that rejects anything carrying a lower generation than the highest it has accepted refuses a holder that paused past its expiry and resumed. A random epoch file names the incarnation, so a participant that outlives a removal of the log reads the new one instead of continuing the old numbering into it. é)Úannotations)Ú contextlibzfilelock._errorzfilelock._identityÚmathÚpathlibÚsecretsN)Úsuppress)Ú dataclass)Úisfinite)ÚPath)Ú TYPE_CHECKINGÚFinalÚLiteralÚProtocol)ÚSoftFileLockProtocolError)Ú host_name)ÚCallable)ÚreadÚwrite)ÚokÚlostÚ transientz filelock-rw/1z Final[str]Ú _PROTOCOLéz Final[int]Ú_GENERATION_DIGITSé Ú_TOKEN_HEX_LENGTHiÚ_MAX_RECORD_SIZEé@Ú_RETAINED_GENERATIONSÚgenÚ_GENERATIONS_DIRECTORYÚepochÚ_EPOCH_NAMEÚHEADÚ _HEAD_NAMEÚholdersÚ_HOLDERS_DIRECTORYz.commit-Ú_TEMPORARY_PREFIXcó—eZdZdZy)ÚTreeReplacedErrorz£ Raised by a ``Files`` implementation when a protocol directory is not a real directory (a symlink, a junction, a file) or belongs to another account. N)Ú__name__Ú __module__Ú__qualname__Ú__doc__©óú`/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/filelock/_soft_rw/_protocol.pyr*r*>s„òr0r*có\—eZdZdZdd„Zddœdd„Zdd„Zdd„Zdd„Zdd „Z dd „Z ddœdd„Zy )ÚFilesz`The filesystem operations the protocol runs on; :mod:`._storage` implements them over :mod:`os`.có—y)z\The file's bytes, ``None`` when it does not exist, or ``b""`` when it is not a regular file.Nr/©ÚselfÚpaths r1rz Files.readHór0F©Údurablecó—y)a Create the file exclusively with the whole record written; raise ``FileExistsError`` when it exists. The returned device and inode (the kernel's identity for a file, independent of its name) let ``overwrite`` check that the name still leads to this file. *durable* flushes it to stable storage first, for a record that outlives the host that wrote it: a generation a crash left empty would wedge every other participant. A holder record dies with its writer, so it skips that. Nr/)r6r7Údatar:s r1ÚcreatezFiles.createKr8r0có—y)zjHard-link *source* to *target* without replacing; ``True`` when *target* names *source*'s file afterwards.Nr/©r6ÚsourceÚtargets r1Úlinkz Files.linkVr8r0có—y)ziRename *source* over *target* atomically; ``False`` when the platform refused because *target* is in use.Nr/r?s r1Úreplacez Files.replaceYr8r0có—y)z” Rewrite from offset zero the file ``create`` returned *identity* for. ``False`` when *path* no longer leads to that file. Nr/)r6r7r<Úidentitys r1Ú overwritezFiles.overwrite\r8r0có—y)z5Remove the file, tolerating one that is already gone.Nr/r5s r1ÚunlinkzFiles.unlinkcr8r0có—y)zDThe names in the directory, or an empty list when it does not exist.Nr/r5s r1Úlistdirz Files.listdirfr8r0©Úforcecó—y)zÒ Create the protocol directories under *root*, refusing anything at those paths that is not a directory. Done once per lock; *force* repeats it after a write found a directory missing. Nr/)r6ÚrootrMs r1Úpreparez Files.prepareir8r0N)r7ÚstrÚreturnúbytes | None)r7rQr<Úbytesr:ÚboolrRútuple[int, int])r@rQrArQrRrU)r7rQr<rTrFrVrRrU)r7rQrRÚNone)r7rQrRz list[str])rOrQrMrUrRrW)r+r,r-r.rr=rBrDrGrIrKrPr/r0r1r3r3Es>„ÙjókðAFõ óyóxóóDóSð38ör0r3T)ÚfrozencóJ—eZdZUdZded<ded<ded<edd„«Zdd „Zy ) ÚSnapshotzJThe lock's state at one generation: which token writes, which tokens read.ÚintÚ generationú str | NoneÚwriterúfrozenset[str]Úreaderscóf—|j€|jS|j|jhzS)z"Every token this generation names.)r^r`©r6s r1ÚmemberszSnapshot.membersys+€ð $Ÿ{™{Ð2ˆt|‰|ÐT¸¿¹ÈÏÉÀ}Ñ8TÐTr0có$—td|j›g}|j|jd|j›«|j d„t|j«D««djd„|D««jd«S)Nzgeneration=zwriter=c3ó&K—|] }d|›–—Œyw)zreader=Nr/)Ú.0Útokens r1ú z"Snapshot.encode..‚sèø€ÒI¨5w˜u˜gÔ&ÑIùó‚Úc3ó&K—|] }|›d–—Œyw)ú Nr/©rfÚlines r1rhz"Snapshot.encode..ƒsèø€Ò5 t˜$˜˜r”{Ñ5ùriÚascii) rr\r^ÚappendÚextendÚsortedr`ÚjoinÚencode)r6Úliness r1rtzSnapshot.encode~st€Ü˜k¨$¯/©/Ð):Ð;Ð<ˆØ;‰;Ð"ØL‰L˜7 4§;¡; -Ð0Ô1Ø ‰ÑI´F¸4¿<¹<Ó4HÔIÔIØw‰wÑ5¨uÔ5Ó5×<Ñ<¸WÓEÐEr0N)rRr_©rRrT)r+r,r-r.Ú__annotations__Úpropertyrcrtr/r0r1rZrZqs0…áTàƒOØÓØ Óà òUóðUôFr0rZcóP—|rt|«tkDry |jd«jd«}|dt k7s|dryd}d}t «}|ddD]Ÿ}|jd«\}}}|dk(rG|€Et|«tkr3|j«r#tt|««|k(rt|«}Œd|d k(r|€t|«r|}Œy|d k(r!t|«r||vr|j|«ŒŸy|€dSt||t|«¬«S#t$rYywxYw)zTThe snapshot a ``gen/`` record encodes, or ``None`` when the record is malformed.Nrorlréÿÿÿÿéú=r\r^Úreader©r\r^r`)ÚlenrÚdecodeÚsplitÚUnicodeDecodeErrorrÚsetÚ partitionrÚisdigitrQr[Úis_tokenÚaddrZÚ frozenset) r<rur\r^r`rnÚkeyÚ_Úvalues r1Úparse_snapshotrŒ†s0€á”3t“9Ô/Ò/ØðØ—‘˜GÓ$×*Ñ*¨4Ó0ˆð ˆQx”9Ò b¢ ØØ!€JØ€FÜ›€GØa˜òˆØŸ™ sÓ+‰ ˆˆQà<ÒØÐ"ÜE“ Ô0Ò0Ø— ‘ ”Ü”C˜“J“ 5Ò(ä˜U›‰JØ HŠ_ ´H¸U´OØ‰FØ HŠ_¤¨%¤°UÀ'Ñ5IØK‰K˜Õáðð Ð%ˆ4Ðu¬8¸zÐRXÔbkÐlsÓbtÔ+uÐuøô/òÙðús— DÄ D%Ä$D%cóN—t|«tk(xrtd„|D««S)zBWhether *value* is a claim token: exactly 32 lowercase hex digits.c3ó$K—|]}|dv–—Œ yw)Ú0123456789abcdefNr/)rfÚ characters r1rhzis_token..¨sèø€Ò2jÐW`°9Ð@RÔ3RÑ2jùs‚)rrÚall)r‹s r1r†r†¦s#€äˆu‹:Ô*Ñ*Òj¬sÑ2jÐdiÔ2jÓ/jÐjr0có:—tjtdz«S)zA fresh claim token.é)rÚ token_hexrr/r0r1Ú new_tokenr•«s€ä×ÑÔ.°!Ñ3Ó4Ð4r0có–—t›d|›dtj«›dt«›dt |«›d|›djd«S)aC The ``holders/`` record; only the nonce changes between heartbeats, so the length stays constant. *lease* is the writer's own ``stale_threshold``: a peer configured tighter must not read this holder's longer heartbeat interval as death, so evictors wait the longer of their threshold and this one. z token=z pid=z host=z lease=z nonce=rlro)rÚosÚgetpidrÚfloatrt)rgÚnonceÚleases r1Ú encode_holderrœ°sN€ôˆ+X˜e˜W F¬2¯9©9«;¨-°w¼y»{¸mÈ8ÔTYÐZ_ÓT`ÐScÐckÐlqÐkrÐrtÐußfˆWƒoðr0có— td„|xsdjd«jd«D««jd«}t |«}t|«r|dkDrt|«|k(r|SdS#t tf$rYywxYw)zjThe ``lease`` a holder record carries, or ``None`` when it has none (an older release) or it is malformed.c3óDK—|]}|jd«sŒ|–—Œyw)úlease=N)Ú startswithrms r1rhzholder_lease..¿s!èø€ò ØÈDÏOÉOÐ\dÕLeŒDñ ùs‚ ™ r0rorlrŸNr) Únextr€rÚremoveprefixr™Ú StopIterationÚ ValueErrorr Úrepr)ÚrecordÚtextr›s r1Úholder_leaser¨¼s€ðÜñ Ø$šm¨×3Ñ3°GÓ<×BÑBÀ4ÓHô ó ç ‰,xÓ ð ôd“ˆô˜U”O¨°ª ´d¸5³kÀTÒ6Iˆ5ÐSÈtÐSøô œ:Ð&òÙðús‚AA2Á2BÂBcó6—eZdZdZdd„Zddœd d„Zd d„Zdd„Zy)ÚLedgera How long each observed value has stayed the same, measured on this observer's monotonic clock. A value that has not changed for ``stale_threshold`` belongs to a participant that stopped refreshing it. The clock is the observer's own and only ever measures the gap between two of its own observations, which is what lets two hosts agree on liveness without agreeing on the time. có —||_i|_y©N)Ú_clockÚ_seen)r6Úclocks r1Ú__init__zLedger.__init__Òs€ØˆŒØ<>ˆ r0N©Úaskedcó¨—|j«}|jj|«x}|d|k7r||f|j|<y|€|n||dz S)a Record *value* for *key* and return for how long it has stayed the same. *asked* is the clock reading taken before the caller fetched *value*. An unchanged value counts as unchanged up to *asked*, so a pause between the fetch and this call adds no time. rçr{)rr®Úget)r6r‰r‹r²ÚnowÚseens r1ÚobservezLedger.observeÖs[€ðk‰k‹mˆØ—J‘J—N‘N 3Ó'Ð'ˆDÐ0°D¸±G¸uÒ4DØ$ c˜lˆDJ‰Js‰OØØ}‘¨%°4¸±7Ñ:Ð:r0có<—|jj|d«yr¬)r®Úpop)r6r‰s r1Úforgetz Ledger.forgetãs€Ø ‰ ‰s˜DÕ!r0có€—|jj«Dcic] \}}||vsŒ||“Œc}}|_ycc}}w)ziDrop every key not in *keys*: peers that left would otherwise stay in the ledger for the lock's lifetime.N)r®Úitems)r6Úkeysr‰r·s r1Úretainz Ledger.retainæs2€à15·±×1AÑ1AÓ1C×S¡I C¨ÀsÈdÂ{c˜4‘iÓSˆ ùÓSsž:«:)r¯úCallable[[], float]rRrW)r‰rQr‹rSr²úfloat | NonerRr™)r‰rQrRrW)r¾zset[str]rRrW)r+r,r-r.r°r¸r»r¿r/r0r1rªrªÉs#„ñó?ðOSõ;ó"ôTr0rªcó¦—eZdZdZdd„Zdd„Zdd„Zdd„Zdd„Zdd„Z dd„Z dd „Zdd „Ze fdd„Zdd„Zdd „Zdd„Zdd„Zdd„Zd d„Zed d„«Zy)!Ú GenerationLogzeThe ordered snapshots under ``gen/``, found by listing and probing, advanced by linking the next one.cóê—||_||_t|t«|_t|jtz«|_t|jtz«|_ d|_ d|_yr¬)Ú_filesÚ _lock_filerr!Ú _directoryrQr#Ú_epoch_pathr%Ú _head_pathÚ_epochÚ_latest)r6ÚfilesÚ lock_filerOs r1r°zGenerationLog.__init__îsX€ØˆŒØ#ˆŒÜ˜tÔ%;Ó<ˆŒÜ˜tŸ™´Ñ<Ó=ˆÔÜ˜dŸo™o´ Ñ:Ó;ˆŒØ$(ˆŒØ(,ˆr0cóŠ—|j«x}€)|j«x}€t|jdd«‚||_|S)at The newest snapshot. Starts from the newest readable generation among those ``gen/HEAD``, the listing, or memory name, then probes forward by name across the retained window. ``HEAD`` only names a generation, and that generation must still read back: a committer stalled before its rename can leave ``HEAD`` on a generation compacted since. A generation compacted between the listing and the read, and a hole left by a committer that died before it compacted, are covered by the probe. Memory and ``HEAD`` are bound to the log's epoch, so a log wiped and restarted is never continued from a generation it no longer holds. Only a log that names generations, now or as remembered, of which none can be read is refused, because that is a client so far behind the log that nothing it reads can be trusted. Nz)generation log names no readable snapshot)Ú_findrrÆrË©r6Úlatests r1rÑzGenerationLog.latest÷sE€ð—j‘j“lÐ"ˆFÐ+¸4¿:¹:»<Ð1G°Ð0PÜ+¨D¯O©O¸TÐCnÓoÐoØˆŒØˆ r0có|—|j«x}|jk7r|dc|_|_t|j ««}|j;|jj r%|j |jj «|j«x}r|j |«t|d¬«D]5}|j|«x}€Œ|j|||k(rdnt¬«cSt|d¬«}|jt|dt«¬««}|j |kDs|s|SdS)NT)Úreverser{)Úpatiencer)Údefaultr~)Ú_incarnationrÊrËrƒÚ_listr\r‡Ú_head_generationrrÚ_readÚ_proberÚmaxrZrˆ)r6r"ÚnamedÚheadr\ÚstartÚnewestÚfounds r1rÏzGenerationLog._finds€Ø×&Ñ&Ó(Ð(ˆE¨T¯[©[Ò8Ø(-¨tÐ%ˆDŒK˜œÜD—J‘J“LÓ!ˆà<‰<Ð#¨¯©×(?Ò(?ØI‰Id—l‘l×-Ñ-Ô.Ø×(Ñ(Ó*Ð*ˆ4Ð*ØI‰IdŒOÜ °Ô5ò gˆJØŸ™ JÓ/Ð/Ñ<ð—{‘{ 5¸ ÀdÒ8J±1ÔPe{ÓfÒfð gô U AÔ&ˆØ—‘œH°¸tÌYË[ÔYÓZˆØ×(Ñ(¨6Ò1¹ˆuÐHÀDÐHr0cóZ—|j«x} t|«x}€y|jSr¬)Ú_head_recordrŒr\)r6r¦Úsnapshots r1rØzGenerationLog._head_generations7€ð×'Ñ'Ó)Ð)ˆFÐ2Ä>ÐRXÓCYÐ7Y°xÐ6bØØ×"Ñ"Ð"r0có°—|jj|j«x}€y|jd«\}}}|j «||zk(r|SdS)Nó )rÅrrÉr„Ú_valid_epoch)r6r<r"Únewliner¦s r1râzGenerationLog._head_record$sW€Ø—K‘K×$Ñ$ T§_¡_Ó5Ð5ˆDÐ>Øà!%§¡°Ó!6Ñˆˆw˜Ø×*Ñ*Ó,°¸±Ò?ˆvÐIÀTÐIr0cóz—|j}|,t|jdd«jd««r|SdS)NrorDrl)rÊr†r€Úremovesuffix©r6r"s r1ræzGenerationLog._valid_epoch+s:€Ø—‘ˆØÐ)¬h°u·|±|ÀGÈYÓ7W×7dÑ7dÐeiÓ7jÔ.kˆuÐuÐquÐur0cóV—|jj|j«x}€h |jj|jt «›djd«d¬«|jj|j«}|S#t$rYŒ2t$rYywxYw)NrlroTr9)rÅrrÈr=r•rtÚFileExistsErrorÚFileNotFoundErrorrês r1rÖzGenerationLog._incarnation/s›€Ø—[‘[×%Ñ% d×&6Ñ&6Ó7Ð7ˆEÐ@ð Ø—‘×"Ñ" 4×#3Ñ#3¼ »°}ÀBÐ5G×5NÑ5NÈwÓ5WÐaeÐ"Ôfð—K‘K×$Ñ$ T×%5Ñ%5Ó6ˆEØˆøô #ò ÙÜ$ò áð ús©ABÂ B(ÂB(Â'B(có¨—|j«}|dtD],}|jj|j |««Œ.|tdSr¬)Ú_listedrrÅrIÚ_path)r6Úlistedr\s r1r×zGenerationLog._list>sU€Ø—‘“ˆØ Ð!8Ô#8Ð"8Ð9ò 7ˆJØK‰K×Ñ˜tŸz™z¨*Ó5Õ6ð 7àÔ,Ð,Ð-Ð.Ð.r0có~—td„|jjt|j««D««S)Nc3ó–K—|]A}t|«tk(r-|j«r|j«r t |«–—ŒCywr¬)rrÚisasciir…r[)rfÚnames r1rhz(GenerationLog._listed..Fs9èø€ò àÜ4‹yÔ.Ò.°4·<±<´>ÀdÇlÁlÄnô Iñ ùs‚AA )rrrÅrKrQrÇrbs r1rïzGenerationLog._listedDs4€äñ àŸ™×+Ñ+¬C°·±Ó,@ÓAô ó ð r0có€—|}|j}d}||kr(|dz }|j|«x}€|dz }Œ#|}d}||krŒ(|S)Nrr{)r\rÙ)r6rÞrÔrÑr\Úgaprãs r1rÚzGenerationLog._probeLsa€ØˆØ×%Ñ%ˆ ØˆØHŠnØ˜!‰OˆJØ ŸJ™J zÓ2Ð2Ð;Øq‘ØØˆFØˆCð H‹nðˆ r0cóè—|jj|j|««x}€yt|«x}|j|k7r(|j|«}t |j|d«‚|S)Nzmalformed generation record)rÅrrðrŒr\Ú_namerrÆ)r6r\r<rãrõs r1rÙzGenerationLog._readYsm€Ø—K‘K×$Ñ$ T§Z¡Z° Ó%;Ó<Ð<ˆDÐEØÜ& tÓ,Ð,ˆHÐ5¸×9LÑ9LÐPZÒ9ZØ—:‘:˜jÓ)ˆDÜ+¨D¯O©O¸TÐC`ÓaÐaØˆr0cób—|jj|j«|jk7s|j |j «sy|j |j|j «|j«x}|jjd¬«sytg|j«¢|j«xsd‘«|j z }|tk\s|j |j «sFd|cxkr tks6n|jj|j|j ««y||_t!t"«5|j%«x}|jj|j«|k(rW|j«xsd|j kr6|j |j&||z|jj(d¬«ddd«|j tz dz x}dkDr|j+|«y#1swYŒ6xYw)a/ Publish *successor* as the next generation; ``False`` when a peer published that generation first. The record is complete before it gets its public name, and a no-replace hard link is the compare-and-swap: only one link to ``gen/`` can ever succeed. The link's return code is not trusted, because an NFS retry can report a link that did land as failed; the file's identity after the call is what decides. A log whose epoch changed since the snapshot was read is a different log, so the commit is refused as lost and the caller re-reads; that narrows a wipe racing this commit to the moment between the epoch check and the link. A slot compaction freed is refused the same way, before the link and again after it, since a committer can stall in between. After the link a surviving predecessor proves little: it may be a record another stalled committer linked into its own freed slot and has yet to remove. A slot comes free once the log is a whole window past it, and the head stays, so a record the listing or ``HEAD`` leads by a window is refused as well. A record refused after it landed is removed when nothing was built on it. One that peers lead by less than a window stays, or its slot would come free early. FTr9rNr{)rÅrrÈrÊÚ_extends_the_logr\Ú_publishrðrtrBrÛrïrØrrIrËrÚOSErrorrærÉrDÚ_compact_through)r6Ú successorr<Úleadr"Úexpireds r1ÚcommitzGenerationLog.commitasÔ€ð ;‰;×Ñ˜D×,Ñ,Ó-°·±Ò<ÀD×DYÑDYÐZc×ZnÑZnÔDoØØ}‰}ØJ‰Jy×+Ñ+Ó,°i×6FÑ6FÓ6HÐ.H¨dÈ$Ï+É+×JZÑJZÐdhðô ðÜÐBT—\‘\“^ÐB T×%:Ñ%:Ó%<Ò%AÀÐBÓCÀi×FZÑFZÑZˆØÔ(Ò(°×0EÑ0EÀi×FZÑFZÔ0[ØtÔ3Ô3Ô3Ø—‘×"Ñ" 4§:¡:¨i×.BÑ.BÓ#CÔDØØ ˆŒô”gÓ ñ aà×+Ñ+Ó-Ð-Ð:Ø—K‘K×$Ñ$ T×%5Ñ%5Ó6¸%Ò?Ø×*Ñ*Ó,Ò1°°Y×5IÑ5IÒIà— ‘ ˜dŸo™o¨u°t©|¸T¿[¹[×=PÑ=PÐZ_ Ô`÷ að!×+Ñ+Ô.CÑCÀaÑGÐGˆGÈ1ÒLØ×!Ñ! 'Ô*Ø÷ að aús ÅBH%È%H.cóŽ—|dkDr/|jj|j|dz ««duS|j«duS©Nr{)rÅrrðrâ©r6r\s r1rûzGenerationLog._extends_the_logŠsF€ð˜Š>Ø—;‘;×#Ñ# D§J¡J¨z¸A©~Ó$>Ó?ÀtÐKÐKØ× Ñ Ó" dÐ*Ð*r0có8—t|jt›t«›z«} |jj|||¬« |||«|jj|«S#t$rYywxYw#|jj|«wxYw)Nr9F)rQrÇr(r•rÅr=rírI)r6rAr<Úplacer:Ú temporarys r1rüzGenerationLog._publish‘sŒ€Ü˜Ÿ™Ô->Ð,?Ä Ã¸}Ð*MÑMÓNˆ ð ØK‰K×Ñ˜y¨$¸ÐÔ@ð *Ù˜ FÓ+àK‰K×Ñ˜yÕ)øô!ò ñð ûð K‰K×Ñ˜yÕ)úsªA-Á A<Á- A9Á8A9Á<BcóX—|}|dkDre|jj|j|dz ««8|dz}|dkDr.|jj|j|dz ««Œ8t||dz«D],}|jj |j|««Œ.yr)rÅrrðÚrangerI)r6rÚoldestr\s r1rþzGenerationLog._compact_throughžs—€àˆØqŠj˜TŸ[™[×-Ñ-¨d¯j©j¸À!¹Ó.DÓEÐQØa‰KˆFðqŠj˜TŸ[™[×-Ñ-¨d¯j©j¸À!¹Ó.DÓEÑQä ¨°!©Ó4ò 7ˆJØK‰K×Ñ˜tŸz™z¨*Ó5Õ6ñ 7r0cóP—t|j|j|«z«Sr¬)rQrÇrùrs r1rðzGenerationLog._path¦s€Ü4—?‘? T§Z¡Z° Ó%;Ñ;Ó<Ð}‰jj«}‰j|«‰j |«tˆfd„|j‰jhz D««}|j|vrdn|j}|j|z }‰jsL||r‰j||||«y‰jdk(r‰j|fnd|‰jhzf\}}‰jdk(xs|}‰jr|s|sy‰j||||«x}€Œ-d‰_ |r|‰_ |cSy)aö Take the next step toward holding the lock; ``True`` once the lock is granted. A reader enters as soon as no live writer is named. A writer enters as soon as no live writer is named, which blocks every new reader, then waits for the named readers to leave. Stale members are evicted in the same commit that admits this participant, and a writer's final admission is itself a commit, so no admission can rest on a snapshot a peer is about to supersede. éc3óF•K—|]}‰j|«sŒ|–—Œywr¬)Ú _is_stale)rfrgr6s €r1rhz&Participant.advance..ðs øèø€Òh¨ÐRV×R`ÑR`ÐafÕRgœeÑhùsƒ!š!NFrrT)r rrÑÚ_keep_claim_freshÚ_sweeprˆrcrgr^r`rÚ_commitrr\)r6rŠrÑÚstaler^r`Úgrantedr\s` r1ÚadvancezParticipant.advanceás<ø€ôq“ó ˆAØ—Y‘Y×%Ñ%Ó'ˆFØ×"Ñ" 6Ô*ØK‰K˜ÔÜÓh°·±À4Ç:Á:À,Ñ1NÔhÓhˆEØ#Ÿ]™]¨eÑ3‘T¸¿¹ˆFØ—n‘n uÑ,ˆGØ—=’=ØÐ%áØŸ™ V¨V°W¸eÔDÙ Ø;?¿9¹9ÈÒ;O 4§:¡:¨wÑ"7ÐVZÐ\cÐgk×gqÑgqÐfrÑ\rÐUs‘˜Ø—i‘i 6Ñ)Ò8°¨[ˆGØ}Š}¡U±7ÙØ"Ÿl™l¨6°6¸7ÀEÓJÐJ ÐSÙØ ˆDŒMÙØ",”ØŠNð- ð.r0cóÈ—|j|jv|_|j«s)t t «5|j «ddd«yy#1swYyxYwr¬)rgrcrÚ_refresh_noncerrìr%rÐs r1r.zParticipant._keep_claim_freshsW€ðŸ ™ f§n¡nÐ4ˆŒ Ø×"Ñ"Ô$Üœ/Ó*ñ &Ø×#Ñ#Ô%÷ &ð &ð%÷ &ð &ús½AÁA!có0—|j«x}|jkry||jdzz|_t|j«}t|jt«}|jjt|««D]a}||jk7sŒ||jvsŒ"t|«sŒ.|jd|›x}«|j|t||z««Œct|jt«}|jjt|««D]L}|j!t"«sŒ|jd|›x}«|j|t||z««ŒN|j$j'|«y)Nr“zholder:z temporary:)rr rrƒrcrrr'rÅrKrQrgr†r‡Ú_collectr!r r(rr¿)r6rÑr¶Úwatchedr&rõr‰Úgenerationss r1r/zParticipant._sweepsL€ð—;‘;“=Ð ˆC D×$4Ñ$4Ò4ØØ ×!6Ñ!6¸Ñ!:Ñ:ˆÔÜf—n‘nÓ%ˆÜt—z‘zÔ#5Ó6ˆØ—K‘K×'Ñ'¬¨G«Ó5ò 8ˆDØt—z‘zÓ! d°&·.±.Ò&@ÄXÈdÅ^Ø—‘ W¨T¨FÐ#3Ð3˜CÔ4Ø— ‘ ˜c¤3 w°¡~Ó#6Õ7ð 8ô˜4Ÿ:™:Ô'=Ó>ˆØ—K‘K×'Ñ'¬¨KÓ(8Ó9ò <ˆDØ‰Ô0Õ1Ø—‘ Z°¨vÐ#6Ð6˜CÔ7Ø— ‘ ˜c¤3 {°TÑ'9Ó#:Õ;ð <ð ‰×Ñ˜GÕ$r0có–—|j||«r7|jj|«|jj |«yyr¬)Ú_unchanged_for_its_leaserÅrIrr»)r6r‰r7s r1r7zParticipant._collect$s;€Ø×(Ñ(¨¨dÔ3ØK‰K×Ñ˜tÔ$ØL‰L×Ñ Õ$ð4r0có —t|jdz||¬«}|jj|«sy|D]G}|jj|j |««|jj|«ŒI|jS)Nr{r~) rZr\rrrÅrIrrr»)r6rÑr^r`r1rÿrgs r1r0zParticipant._commit)s€ô¨×(9Ñ(9¸AÑ(=ÀfÐV]Ô^ˆ Øy‰y×Ñ Ô*ØØò 'ˆEØK‰K×Ñ˜t×0Ñ0°Ó7Ô8ØL‰L×Ñ Õ&ð 'ð×#Ñ#Ð#r0cóD—|j||j|««Sr¬)r;r©r6rgs r1r-zParticipant._is_stale4s €Ø×,Ñ,¨U°D×4EÑ4EÀeÓ4LÓMÐMr0cóÜ—|j«}|jj|«}|jj |||¬«t|jt|«xsd«k\S)Nr±r´)rrÅrrr¸rÛrr¨)r6r‰r7r²r¦s r1r;z$Participant._unchanged_for_its_lease7s\€Ø—‘“ ˆØ—‘×!Ñ! $Ó'ˆØ|‰|×#Ñ# C¨°uÐ#Ó=ÄÀT×EZÑEZÔ\hÐioÓ\pÒ\wÐtwÓAxÑxÐxr0cóJ—tt|jt|««Sr¬)rQrrr'r>s r1rzParticipant._holder_path<s€Ü”4˜Ÿ ™ Ô$6¸Ó>Ó?Ð?r0cóŠ—|jx}€y|jj|j|j «|«Sr)rrÅrGrr()r6rFs r1r5zParticipant._refresh_nonce?s9€Ø×-Ñ-Ð-ˆHÐ6ØØ{‰{×$Ñ$ T§\¡\°4·<±<³>À8ÓLÐLr0có2— |j«sy |jj «}|j|«|j|jvrddfSddfS#t$rYyt$r}d|fcYd}~Sd}~wwxYw#ttf$rYywxYw)aì Refresh the nonce and confirm the latest snapshot still names this participant. ``lost`` means a peer evicted this participant or removed its holder record: the lock is no longer held, and the holder must stop using what it protects. ``transient`` is a filesystem error refreshing the nonce, worth retrying on the next tick. A failure to read the log or to sweep decides nothing about this holder's liveness, so it is not counted against it. )rNrN)rNrr)r5r*rýrrÑr/rgrc)r6ÚerrorrÑs r1Ú heartbeatzParticipant.heartbeatDs¥€ð &Ø×&Ñ&Ô(Ø#ð)ð Ø—Y‘Y×%Ñ%Ó'ˆFØK‰K˜ÔðŸ ™ f§n¡nÑ4À4ÐGÐG¸&À4ÐGÐGøô!ò ÙÜò &Ø Ð%Õ%ûð &ûô Ô*Ð+ò Ùð ús4‚A •+BÁ BÁ+BÁ3A<Á6BÁ<BÂBÂBcóØ—tt«5 |j|jj «x}j vr§t |jdz|j|jk(rdn|j|j|jhz ¬«}|jj|«rn3|j|jj «x}j vrŒ§d|_d|_|jj|j« ddd«y#d|_d|_|jj|j«wxYw#1swYyxYw)zRCommit this participant out of the latest snapshot, then remove its holder record.r{Nr~F)rr*rgrrÑrcrZr\r^r`rrrÅrIr)r6rÑrÿs r1ÚleavezParticipant.leave[s€ô Ô'Ó (ñ 1ð 1Ø—j‘j¨t¯y©y×/?Ñ/?Ó/AÐ%A V×$JÑ$JÑJÜ (Ø#)×#4Ñ#4°qÑ#8Ø'-§}¡}¸¿ ¹ Ò'B™tÈÏ É Ø &§¡°$·*±*°Ñ =ô!Ið —y‘y×'Ñ'¨ Ô2Øð—j‘j¨t¯y©y×/?Ñ/?Ó/AÐ%A V×$JÑ$JÒJð!&” Ø"&”Ø—‘×"Ñ" 4§<¡<Õ0÷ 1ð 1øð!&” Ø"&”Ø—‘×"Ñ" 4§<¡<Õ0ú÷ 1ð 1ús#E ’CD(Ã+3E Ä(5EÅE Å E)N)rÌr3rOrQrÚModer!r™r¯rÀr"rªr#rÃrRrW)rRrWrv)rRrU)rÑrZrRrW)r‰rQr7rQrRrW) rÑrZr^r]r`r_r1r_rRr)rgrQrRrU)r‰rQr7rQrRrU)rgrQrRrQ)rRz'tuple[HeartbeatOutcome, OSError | None])r+r,r-r.r°r&r%r(r3r.r/r7r0r-r;rr5rDrFr/r0r1rr®sÐ„ñð#àð#ðð#ðð #ðð #ð#ð#ðð#ðð#ð ó#ó2ó UóMó"óH &ó%ó(%ð $Øð $Ø(2ð $Ø=Kð $ØTbð $à ó $óNóyó @óMó Hô.1r0r) r3rÃÚHeartbeatOutcomerªrGrrZr*rœr¨r†r•rŒ)r<rTrRr)r‹rQrRrU)rRrQ)rgrQršrQr›r™rRrT)r¦rSrRrÁ)3r.Ú __future__rÚ__lazy_modules__r—rrrÚdataclassesr rr rrÚtypingrr rrÚfilelock._errorrÚfilelock._identityrÚcollections.abcrrGrHrrwrrrrr!r#r%r'r(ÚRuntimeErrorr*r3rZrŒr†r•rœr¨rªrÃrÚ__all__r/r0r1úrRsEðòõ(#âhÐã ÛÝÝ!ÝÝß:Ó:å5Ý(áÝ(àˆÑ€ØÐ4Ñ5Ðà'€ ˆ:Ó'Ø!#ÐJÓ#Ø "Ð:Ó"à&Ð*Ó&ð%'ÐzÓ&Ø%*Ð˜ Ó*ð"€ˆZÓ!ð € ˆJÓØ!*ÐJÓ*Ø *Ð:Ó*ô˜ôô)ˆHô)ñX$Ô÷FðFóðFó(vó@kó 5ó ó T÷TñT÷D@6ñ@6÷F1ñ1òDr0