+ jMa0t$Rt^RIHt^RIt^RIt^RIHt^RIH t ^RI H t ^RI H t HtHtHt^RIHt^RIHt] 'd^R IHt]R,,t]R-,tR tR ]R &^tR ]R&^ tR ]R&R.tR ]R&^@tR ]R&RtR ]R&Rt R ]R&Rt!R ]R&!RR]4t"] !RR7!RR44t#RRlt$R R!lt%R"R#lt&R$R%lt'!R&R'4t(!R(R)4t)!R*R+4t*.R/Ot+R#)0aw 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, 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. ) annotationsN)suppress) dataclass)Path) TYPE_CHECKINGFinalLiteralProtocol)SoftFileLockProtocolError) host_name)Callablez filelock-rw/1z Final[str] _PROTOCOLz Final[int]_GENERATION_DIGITS_TOKEN_HEX_LENGTH_MAX_RECORD_SIZE_RETAINED_GENERATIONSgen_GENERATIONS_DIRECTORYholders_HOLDERS_DIRECTORYz.commit-_TEMPORARY_PREFIXcn]tRt^4tRtRRltRRltRRltRR ltR R lt R R lt RRlt Rt R#)Filesz`The filesystem operations the protocol runs on; :mod:`._storage` implements them over :mod:`os`.c V^8dQhRRRR/#)pathstrreturn bytes | None)formats"\/home/luca/screen-checking/.venv/lib/python3.14/site-packages/filelock/_soft_rw/_protocol.py __annotate__Files.__annotate__7skkkkc R#)z\The file's bytes, ``None`` when it does not exist, or ``b""`` when it is not a regular file.Nrselfrs&&r!read Files.read7r$c$V^8dQhRRRRRR/#)rrrdatabytesrNoner)r s"r!r"r#:s&ss3sessr$c R#)zdCreate the file exclusively with the whole record written; raise ``FileExistsError`` when it exists.Nrr'rr,s&&&r!create Files.create:r*r$c$V^8dQhRRRRRR/#)rsourcertargetrboolr)r s"r!r"r#=s&yy3yyyr$c R#)zjHard-link *source* to *target* without replacing; ``True`` when *target* names *source*'s file afterwards.Nr)r'r4r5s&&&r!link Files.link=r*r$c$V^8dQhRRRRRR/#)rrrr,r-rr6r)r s"r!r"r#@s&^^c^^4^r$c R#)zORewrite the file in place from offset zero; ``False`` when it no longer exists.Nrr0s&&&r! overwriteFiles.overwrite@r*r$c V^8dQhRRRR/#)rrrrr.r)r s"r!r"r#CsDD3D4Dr$c R#)z5Remove the file, tolerating one that is already gone.Nrr&s&&r!unlink Files.unlinkCr*r$c V^8dQhRRRR/#)rrrrz list[str]r)r s"r!r"r#FsSSCSISr$c R#)zDThe names in the directory, or an empty list when it does not exist.Nrr&s&&r!listdir Files.listdirFr*r$c V^8dQhRRRR/#)rrootrrr.r)r s"r!r"r#IsvvCvDvr$c R#)zgCreate the protocol directories under *root*, refusing anything at those paths that is not a directory.Nr)r'rGs&&r!prepare Files.prepareIr*r$rN) __name__ __module__ __qualname____firstlineno____doc__r(r1r8r<r@rDrI__static_attributes__rr$r!rr4s5jksy^DSvvr$rT)frozenc\]tRt^Mt$RtR]R&R]R&R]R&]RR l4tR R ltR t R #)SnapshotzJThe lock's state at one generation: which token writes, which tokens read.int generation str | Nonewriterfrozenset[str]readerscV^8dQhRR/#)rrrXr)r s"r!r"Snapshot.__annotate__VsUUUr$c rVPf VP#VPVP0,#)z"Every token this generation names.)rWrYr's&r!membersSnapshot.membersUs+ ${{2t||T  }8TTr$cV^8dQhRR/#)rrr-r)r s"r!r"r[ZsFFFr$c (\RVP 2.pVPeVPRVP 24VP R\ VP 444RPRV44PR4#)z generation=zwriter=c3,"TF pRV 2xK R#5i)zreader=Nr).0tokens& r! "Snapshot.encode..^sI4H5wug&4Hsc3*"TF q R2xK R#5i) Nr)rclines& r!rerf_s5utr{uascii) r rUrWappendextendsortedrYjoinencode)r'liness& r!rqSnapshot.encodeZstk$//):;< ;; " LL74;;-0 1 IF4<<4HIIww5u55<`` record encodes, or ``None`` when the record is malformed.Nrlri=rUrWreaderrUrWrY)lenrdecodesplitUnicodeDecodeErrorr set partitionrisdigitrrTis_tokenaddrS frozenset) r,rrrUrWrYrjkey_values & r!parse_snapshotrbs, 3t9// G$**40 Qx9b !JFGa s+  < "E 00 CJ5(UJ H_HUOOF H_%U5I KK  %4u8zbklsbt+uu/ s E E)(E)c V^8dQhRRRR/#)rrrrr6r)r s"r!r"r"skkCkDkr$c\V4\8H;'d5\;QJdRV4F 'dK R# R#!RV44#)zBWhether *value* is a claim token: exactly 32 lowercase hex digits.c3*"TF qR9xK R#5i)0123456789abcdefNr)rc characters& r!reis_token..s2jdiW`@R3RdirkFT)r}rall)rs&r!rrs? u:* * j jss2jdi2jssjsjs2jdi2j/jjr$cV^8dQhRR/#)rrrr)r s"r!r"r"s5535r$cD\P!\^,4#)zA fresh claim token.)secrets token_hexrrr$r! new_tokenrs   .!3 44r$c$V^8dQhRRRRRR/#)rrdrnoncerr-r)r s"r!r"r"s&qqqSqUqr$c \ RV R\P!4 R\4 RV R2 P R4#)zhThe ``holders/`` record; only the nonce changes between heartbeats, so the length stays constant.z token=z pid=z host=z nonce=rirl)r osgetpidr rq)rdrs&&r! encode_holderrs>[vbiik]')+hW\V]]_ ` g gho ppr$c>]tRt^tRtRRltRRltRRltRtR #) 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 V^8dQhRRRR/#)rclockCallable[[], float]rr.r)r s"r!r"Ledger.__annotate__s??1?d?r$c Wn/VnR#N_clock_seen)r'rs&&r!__init__Ledger.__init__s <> r$c$V^8dQhRRRRRR/#)rrrrrrfloatr)r s"r!r"rs!3|r$c VP4pVPPV4;peV^,V8wdW#3VPV&R#W4^,, #)zCRecord *value* for *key* and return how long it has been unchanged.g)rrget)r'rrnowseens&&& r!observeLedger.observesNkkmJJNN3' 'D 0DGu4D$lDJJsO!W}r$c V^8dQhRRRR/#)rrrrr.r)r s"r!r"rs""#"$"r$c >VPPVR4R#r)rpop)r'rs&&r!forget Ledger.forgets sD!r$rN) rKrLrMrNrOrrrrPrr$r!rrs?""r$rc]tRt^tRtRRltRRltRRltRR ltR R lt R R lt RRlt ] RRl4t RtR#) GenerationLogzeThe ordered snapshots under ``gen/``, found by listing and probing, advanced by linking the next one.c(V^8dQhRRRRRRRR/#)rfilesr lock_filerrGrr.r)r s"r!r"GenerationLog.__annotate__s(--e--3-4-r$c VWnW n\V\4VnRVnR#r)_files _lock_filerr _directory_latest)r'rrrGs&&&&r!rGenerationLog.__init__s" #t%;<(, r$cV^8dQhRR/#)rrrSr)r s"r!r"rsr$c VP4pVPV4;pf[VP4pVPV4;pf6V'd\VPRR4h\ ^R\ 4R7pTpVP p^pV\8d0V^, pVPV4;pf V^, pK4Tp^pK:W0n V#)am The newest snapshot. Lists the directory on every call, since opening it is what makes an NFS client revalidate what it has cached about the names inside, then starts from the newest readable generation the listing or memory names and probes forward by name across the retained window. A listing served stale, a generation compacted between the listing and the read, and a hole left by a committer that died before it compacted are all covered by the probe; only a listing that names generations 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 snapshotr{) _list_startr rrSrrUr_readr)r'listedstartlatestrUgapsnapshots& r!rGenerationLog.latests[[( (E 1ZZ\FV,,53DOOTKvww AdIKP%% )) !OJ JJz22;qFC  r$cV^8dQhRR/#)rr list[int]r)r s"r!r"rs//y/r$c \RVPP\VP4444pVR\ )F-pVPP VPV44K/ V\ )R#)c3"TF>pVP4'gK\V4\8XgK1\V4xK@ R#5ir)rr}rrT)rcnames& r!re&GenerationLog._list..s: A||~ "%d)/A"A CIIAsAAAN)rorrDrrrr@_path)r'rrUs& r!rGenerationLog._listsv  ++C,@A   !!8#8"89J KK  tzz*5 6:,,-..r$c V^8dQhRRRR/#)rrrrrwr)r s"r!r"rsY?r$c VPp\V4F5pVeVPV8dVu#VPV4;pfK3Vu# V#r)rreversedrUr)r'r rememberedrUrs&& r!rGenerationLog._startsT\\ "6*J%**?*?:*M!! JJz22? + r$c V^8dQhRRRR/#)rrUrTrrwr)r s"r!r"rsr$c VPPVPV44;pfR#\V4;peVPV8wd)VP V4p\ VPVR4hV#)Nzmalformed generation record)rr(rrrU_namer r)r'rUr,rrs&& r!rGenerationLog._readsmKK$$TZZ %;< `` 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. FT) rrrrrr1rqr8rrUr@rr)r'r temporarylinkeds&& r!commitGenerationLog.commits->,? }*MMN  9&6&6&89 *[[%%iI>Dc V^8dQhRRRR/#rrUrTrrr)r s"r!r"rs====r$c X\VPVPV4, 4#r)rrr)r'rUs&&r!rGenerationLog._paths4??TZZ %;;<.As$h1NRVR`R`afRgee1Ns+ +NFwriter(T)rangerr_keep_claim_fresh_sweeprr^rdrWrYr_commitrrU)r'rrstalerWrYgrantedrUsf r!advanceParticipant.advance2s4qAYY%%'F  " "6 * KK h4::,1NhhE#]]e3TFnnu,G===% VWD ;?99;O4::w"7VZ\cgkgqgqfr\rUsii6)88[G}}}U7"ll67JJ S DM",N-.r$c V^8dQhRRRR/#rrrSrr.r)r s"r!r"rVsYYYTYr$c  ^VPVP9VnVP4'ge\ \ 4;_uu_4VP PVP\VP\444RRR4R#R# +'giR#;ir) rdr^r_refresh_noncerFileExistsErrorrr1rrr)r'rs&&r!rParticipant._keep_claim_freshVsn  fnn4 ""$$/** ""4<<tzz9;1WX+*%***s AB B, c V^8dQhRRRR/#rr)r s"r!r"r`sLLXL$Lr$c VP4;q P8dR#W P^, ,Vn\VP\ 4pVP P\V44F^pW@P8wgKWAP9gK'\V4'gK:VPRV 2\W4, 44K` \VP\4pVP P\V44FDpVP\4'gK VPRV 2\WT, 44KF R#)Nzholder:z temporary:)rrrrrrrrDrrdr^r_collectr startswithr)r'rrrr generationss&& r!rParticipant._sweep`s;;= C$4$4 4 !6!6!::tzz#56KK''G 5Dzz!d..&@Xd^^ v.GN0CD64::'=> KK''K(89D011 4&13{7I3JK:r$c$V^8dQhRRRRRR/#)rrrrrr.r)r s"r!r"rps!%%C%s%t%r$c VPPWPPV44VP8d9VPP V4VPP V4R#R#r)rrrr(rr@r)r'rrs&&&r!rParticipant._collectpsX <<  [[%5%5d%; <@U@U U KK  t $ LL   $ Vr$c ,V^8dQhRRRRRRRRRR /#) rrrSrWrVrYrXrrz int | Noner)r s"r!r"rus4 $ $ $(2 $=K $Tb $  $r$c 8\VP^,W#R7pVPPV4'gR#VFHpVPP VP V44VPPV4KJ VP#)r{N) rSrUrrrr@rrr)r'rrWrYrrrds&&&&& r!rParticipant._commitusz(9(9A(=f^ yy **E KK  t007 8 LL   &###r$c V^8dQhRRRR/#)rrdrrr6r)r s"r!r"rsppsptpr$c VPPWPPVP V444VP 8#r)rrrr(rrr'rds&&r!r Participant._is_stales=||##E;;+;+;D??r$cV^8dQhRR/#r r)r s"r!r"rs[[[r$c VPPVP\VP\ 444#r)rr<rrrdrr]s&r!rParticipant._refresh_nonces*{{$$T\\=Y[3YZZr$cV^8dQhRR/#)rrz'tuple[HeartbeatOutcome, OSError | None]r)r s"r!r"rsHHBHr$c .VP4'gR#TPP4pTP T4TP TP 9dR#RR3# \dpRT3uRp?#Rp?ii;i \dRu#i;i)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. lostN transient)r6N)okN)rOSErrorrrrrdr^)r'errorrs& r! heartbeatParticipant.heartbeats &&&((##) YY%%'F KK  fnn4GG&4GG &% % &    s3A(A(+B( B3A<6B<B BBcV^8dQhRR/#rr)r s"r!r"rs ) )t )r$c VPVPP4;pP9d\ VP ^,VP VP8XdRM VP VPVP0, R7pVPPV4'gKRVn RVnVPPVP4R#)zRCommit this participant out of the latest snapshot, then remove its holder record.Nr{F) rdrrr^rSrUrWrYrrrr@r)r'rrs& r!leaveParticipant.leavesjjtyy'7'7'99VBBB !,,q0%}} :t $**5I yy **  4<<(r$) rrrrrrrrrrUrrdN)rKrLrMrNrOrrrrrrrr rrr;r?rPrr$r!rr sP#0Q "HYL % $p@[H* ) )r$r)r(r)r8r6r7i) rrHeartbeatOutcomerrrrSrrrr),__conditional_annotations__rO __future__rrr contextlibr dataclassesrpathlibrtypingrrrr filelock._errorr filelock._identityr collections.abcr rrAr rtrrrrrrrrrSrrrrrrr__all__)rBs@r!rLs&# !::5((45' :'!#J# ":"&*&%'z&%* *!*J* *:*vHv2 $FFF(v@k 5 q ""2^6^6B_)_)D r$