+ Wj|a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t H t ^RIHt^RIHt^RIHtHtHt^RIHtHtHt^RIHt]P8!]4t!R R ]4t RoR R llt!R Rlt"RRlt#RRlt$RpRRllt%Rt&Rt'Rt(Rt)!RR]*4t+RRlt,RRlt-RR lt.R!R"lt/RpR#R$llt0RpR%R&llt1RpR'R(llt2RqR)R*llt3R+R,lt4!R-R.4t5R/R0/R1R2llt6R3R4lt7R5R6lt8R7R8lt9R9R:lt:R;R<lt;R=R>ltR@&RARBlt?RCRDlt@RpRER0/RFRGllltAR/R0RHRRIR/RJRKlltB]!RLRM44tCRNROltDRPRQltERRRSltFRHRRIR/RTRUlltGRVRRWR0/RXRYlltHRVRRZRRWR0/R[R\lltIR]R^ltJRVR/R_R`lltKRatLRbRcltMRdReltNRfRgltORpR/R0/RhRillltP] RZRRjR/RkRlll4tQ] RjR/RmRnll4tRR#)rzCross-process active chat session leases. The session database records persisted conversations; this module records currently open chat surfaces, including idle CLI/TUI sessions that have not written a transcript row yet. ) annotationsN)contextmanagersuppress) dataclass)Path)AnyIteratorOptional)get_default_hermes_rootget_hermes_homenamed_profile_is_liveatomic_json_writec]tRt^tRtRtR#)ActiveSessionRegistryErrorz@The liveness registry could not prove a safe ownership decision.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rNC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_cli\active_sessions.pyrrsJrrc$V^8dQhRRRRRR/#)valuerkeystrreturn Optional[int]r)formats"r __annotate__r" s" * *# *C *Xe *rcVfR#\V\4'g-\V\4'd"VP4'g \ V4h\V\ 4'd\ VP4^ 4M \ V4pT^8dT#R# \\3d\PRY4R#i;i)z=Return a positive integer cap, or None when disabled/invalid.NzEIgnoring invalid %s=%r (expected a positive integer; 0/null disables)) isinstanceboolfloat is_integer ValueErrorrintstrip TypeErrorloggerwarning)rrparseds&& rcoerce_max_concurrent_sessionsr/ s } eT " "z%'?'?HXHXHZHZU# #+5eS+A+AU[[]B's5z aZ6)T) z " SUX  sAB AB'CCc V^8dQhRRRR/#)rconfigrrr r)r!s"rr"r"0s88C8M8rcRpRp\V\4'dURV9dVPR4pMHVPR4p\V\4'dVPR4pRpM \VRR4p\ WR7#)zBResolve top-level max_concurrent_sessions with gateway.* fallback.Nmax_concurrent_sessionsgatewayzgateway.max_concurrent_sessionsr)r$dictgetgetattrr/)r1rawr gateway_cfgs& rresolve_max_concurrent_sessionsr;0szC #C&$ $ .**67C **Y/K+t,,!oo&?@7f7> )# 77rc V^8dQhRRRR/#)rsecondsr&rrr)r!s"rr"r"AsAAA#Arc\^\V^<,44pV^<8dV R2#\V^<4wr!V'gV R2#V RV R2#)mh)maxr)divmod)r=minuteshourss& r format_agerFAsX!SB'(G|!}GR(NE%eWA;@eWAgYa+@@rc V^8dQhRRRR/#)rentrieslist[dict[str, Any]]rrr)r!s"rr"r"Is  3  rcV'gR#\P!RV44pRPR\VP 4RR744pRV4Uu.uFq3'gK VNK ppV'd:VR\ \ P !4\V4, 4 R 2, pV#uupi) zDCompact "who is holding the slots" phrase, e.g. ``desktop x4, cli``.c3j"TF)p\VPR4;'gR4xK+ R#5i)surfaceunknownNrr7.0es& r $summarize_holders..Ms) UWQUU9%5%B%B!C!CWs!33z, c3F"TFwrV^8dV RV 2MTxK R#5i)z xNr)rQrMns& rrSrTNs/PJGU7)2aS/Ps!c(V^,)V^,3#)rVr)kvs&r#summarize_holders..Ps"Q%Arr5c3V"TFp\VPR44xK! R#5i) started_atN)_optional_floatr7rPs& rrSrTRs!QA?155+>??s')z , oldest  ago) collectionsCounterjoinsorteditemsrFtimemin)rHcountsheldtstarteds& rsummarize_holdersrkIs   UW U UF 99 5OP DRQWQQUVqqQGW )Jtyy{S\'ABC4HH KXs % B>3B>c(V^8dQhRRRRRRRR/#)r active_countr) max_sessionsrHzOptional[list[dict[str, Any]]]rrr)r!s"rr"r"Xs,   %( 3Q  rcd\T;'g.4pV'dRV R2MRpRV RV RV R2#)z Held by: .rKz'Hermes is at the active session limit (/z).z) Try again when another session finishes.)rk)rmrnrHrhdetails&&& ractive_session_limit_messagersXsG W]] +D%)z$q !rF 1,qb (; =rSESSION_NOT_OWNEDMAX_CONCURRENT_SESSIONS SESSION_COORDINATION_UNAVAILABLETc>a]tRt^xt$RtR]R&RV3RlltRtV;t#)ActiveSessionRefusalzYRefusal message (a ``str``, so callers are untouched) with a machine-readable ``reason``.rreasonc$V^8dQhRRRRRR/#)rmessagerryrrxr)r!s"rr"!ActiveSessionRefusal.__annotate__}s"c33Grc 2<\SV`W4pW#nV#N)super__new__ry)clsr{ryobj __class__s&&& rrActiveSessionRefusal.__new__}sgoc+  rr) rrrrr__annotations__rr __classcell__)rs@rrxrxxsc Krrxc V^8dQhRRRR/#)rr{rrr)r!s"rr"r"sUU3U3UrcR\VRR4pV'd RV RV 2#\V4#)zFKeep the refusal contract across the one-shot CLI subprocess boundary.ryrKzhermes-refusal-reason:  )r8r)r{rys& rformat_refusal_stderrrs/ Wh +F T5M TRV Trc\VPR4;'gR4\P!48wdR#\ TPR4;'g/PR4;'gR4p\ T;'g/PR4;'gR4p\T;'dT4;'dY#8H# \\ 3dR#i;i)zTrue when an existing lease belongs to the very caller re-acquiring it. Identity is (pid, live_session_id): pid alone lets two live sessions in one process steal each other's lease; the live id alone lets another process with an equal id.pidFrlive_session_idrK)r)r7osgetpidr+r(rr%)rr existing_live incoming_lives&& r_is_same_writerrs uyy%%2 &"))+ 5 6:.44"99:KLRRPRSMR,,->?EE2FM  //- 0 S S]5SS z "sC C C"!C"c$V^8dQhRRRRRR/#r session_idrrrrr)r!s"rr"r"s&FFcF.FSFrc\VPR4;'gR4p\VPR44pV'd*R\\P!4V, 4 R2MRpRV RV V R 2#) zY00 - (D ) 4 4dY6FI_6_ __rc V^8dQhRRRR/#)rlockr%rNoner)r!s"rr"r"sKKKKrc`\PR8XdW^RIpVP^4TP VP 4V'd VP M VP^4R#^RIpTPVP 4V'd VPM VP4R#)zOExclusive whole-file lock/unlock on ``fh`` (fcntl on POSIX, msvcrt on Windows).ntN) rnamemsvcrtseeklockingfilenoLK_LOCKLK_UNLCKfcntlflockLOCK_EXLOCK_UN)fhrrrs&$ r_flockrsa ww$  ryy{dFNNQRS BIIK$EMMJrc.]tRt^tRRltRtRtRtR#) _FileLockcV^8dQhRR/#)rpathrr)r!s"rr"_FileLock.__annotate__sTrc WnRVnR#r~)r_fh)selfrs&&r__init___FileLock.__init__s rc :VPPPRRR7\VPR4Vn\ VPRR7V# \ d3pTPP4RTn\R4ThRp?ii;i)T)parentsexist_okza+brNz$active session file lock unavailable) rparentmkdiropenrr Exceptionclose RuntimeError)rexcs& r __enter___FileLock.__enter__s td; 5) P 488$ '   P HHNN DHEFC O PsA B(-BBc VPRuq@nVe@\\4;_uu_4\VRR7RRR4VP 4R#R# +'giL$;i)NFr)rrrrr)rexc_typertbrs&&&& r__exit___FileLock.__exit__sExx H >)$$r&% HHJ $$s A A) )rrN)rrrrrrrrrrrrrs rrstrictFc$V^8dQhRRRRRR/#)rrrrr%rrIr)r!s"rr"r"s"****:N*rc aaa a RV3Rllp\SRRR7;_uu_4p\P!V4pRRR4\X\4'dTPR4MTp\T\4'gT'd T!R 4h.#TUu.uFp\T\4'gKTNK ppT'gT#\T4\T48wd T!R 4h\4o TFoSPR 4o T 3R lR 3T T 3RlR3T3RlR3T3RlR3T3RlR3T3RlR3T3RlR3T3RlR33FwrT !4'gKT!RT 24h S PS 4K T# +'giELI;i \d.u#\d4pT'd T!R4Th\ P RS4.uRp?#Rp?ii;iuupi)c V^8dQhRRRR/#)rwhatrrrr)r!s"rr"#_read_entries..__annotate__sUUcU8Urc&<\RV RS 24#)zactive session registry z: )r)rrs&rinvalid_read_entries..invalids),DTF"TF*STTrrz utf-8-sig)encodingN unreadablez.Ignoring corrupt active session registry at %srHzhas invalid shapezcontains invalid entrieslease_idc$<\S4'*#r~) _nonblank_str)rsrrZ_read_entries..s x00rzan invalid lease idc<SS9#r~r)r seen_leasessrrZrs X,rza duplicate lease idcB<\SPR44'*#)r)rr7rsrrZrsuyy'>??rzan invalid session idc><\SPR44^8*#r) _registry_pidr7rsrrZrs]599U#349rzan invalid pidcL<\SPR4\4'*#)rM)_optional_isinstancer7rrsrrZrs-eii .BCHHrzan invalid surfacecL<\SPR4\4'*#)track_liveness)rr7r%rsrrZrs-eii8H.I4PPrzan invalid liveness markercL<\SPR4\4'*#)r)rr7r6rsrrZrs-eii .CTJJrzinvalid metadatacB<\SPR44'*#)process_start_time)_valid_process_startr7rsrrZrs-eii8L.MNNrzan invalid process start timez contains )rjsonloadFileNotFoundErrorrr,r-r$r6r7listlensetadd) rrrrdatarrHrvalidbadrrrs f$ ` @@r _read_entriesrsUU  $k 2 2b99R=D3&0d%;%;dhhy!G gt $ $ -. . ' Cu:eT+BUUE C   5zS\!011EK99Z(12G H ,.D E ?AX Y 9;K L HJ^ _ PRn o JL^ _ NPo p  ICuu $011   !!" LK3 2 2   ,'S 0GN  DsQFE<FG6G< F F F GG(G)(GGGc V^8dQhRRRR/#rvrrr%r)r!s"rr"r"s22S2T2rcd\V\4;'d\VP44#r~)r$rr%r*)rs&rrrs! a  1 1$qwwy/1rc V^8dQhRRRR/#rr)r!s"rr"r"s++C++rc0VRJ;'g \W4#r~)r$)rtyps&&rrrs 9 * * 1**rc V^8dQhRRRR/#)rrrrr)r)r!s"rr"r"sssrc\V\4'g\V\\34'g^#\V4# \\ 3d^#i;i)zERegistry pid as int; 0 for bools, non-int/str, or unparseable values.)r$r%r)rr+r(rs&rrrsG#tJsS#J$?$?3x z "s AAAc V^8dQhRRRR/#rr)r!s"rr"r""s88C8D8rcnVR9dR#\V4pVRJ;'d\P!V4#)NTNrK)r^mathisfinite)rr.s& rrr"s2J Q F   7 7$--"77rc$V^8dQhRRRRRR/#)rrrrHrIrrr)r!s"rr"r")s'OOO(<OOrc(\VRV/RRR7R#)rHNT)indent sort_keysr )rrHs&&r_write_entriesr&)sdY0Nrc V^8dQhRRRR/#)rrr)rOptional[float]r)r!s"rr"r"-sS_rc^RIp\VPV4P44# \dR#i;i)r?N)psutilr&Process create_timer)rr*s& r_process_start_timer--s9V^^C(44677 s +. ==ztuple[int, float] | None _OWN_STARTcV^8dQhRR/#)rrr(r)r!s"rr"r":s   rc\P!4p\e\^,V8wd\V4pVfR#W3s\^,#)zMThis process's create_time, read from psutil once instead of per lease probe.N)rrr.r-)rstarts r_own_start_timer2:sC ))+CZ]c1#C( =\ a=rc V^8dQhRRRR/#)rrrrr(r)r!s"rr"r"Fs3?rcdVeVR8XdR#\V4# \\3dR#i;ir)r&r+r()rs&rr^r^Fs6 } U| z "s //lenientc(V^8dQhRRRRRRRR/#)rrrrr5r%rzOptional[bool]r)r!s"rr"r"Os)77s777Yg7rcV'dRMRp\V4pV^8:dV#V\P!48HpV'g^RIHpV!V4'gR#\V4pVfR#V'd \4M \V4pVf V'dR#R#\W, 4R8# \\3d^pLi;i \dTu#i;i)zTrue/False for live/dead, or None when unknowable. ``lenient`` never returns None: an unparseable pid or failed existence probe counts as dead, an unreadable start as alive.FN) _pid_existsTgMbP?) r)r+r(rrgateway.statusr8rr^r2r-abs) rrr5 unknown_deadpid_intis_selfr8expected_start current_starts &&$ r _pid_livenessr@Os$5Lc(!|$G  2w''(%%78N)0O%6I'6RMt(D( }- . 66% z "   s# B,C,CC CCtarget_session_id target_pidc ,V^8dQhRRRRRRRRR R/#) rrHrIrr%rA str | NonerB int | Nonerr)r!s"rr"r"js6   ! .2 ! 6@  rcVRJ;'gVRJp.pVFpT;'g\VPR44p\VPR4VPR4V'*R7pVffV'dQVe3\VPR4;'gR4\V48XgVe"VPR4V8Xd \ R4hR pV'gKVP V4K V#) u=Keep entries whose owner is alive; tracked/strict entries must be provably so. With ``target_session_id`` only THAT session's owner has to be provable: an unrelated sibling whose liveness is unknowable (pid present, start time unreadable — an LXC ``/proc`` after a backend restart) stays in the live set, so it still fences its own session and still counts toward capacity, but no longer refuses every claim/release for a different session id. See #113683. ``target_pid`` scopes the same way by owner pid (the orphan sweep only ever reclaims this process's own leases). Nrrr)r5rrKz(active session owner liveness is unknownT)r%r7r@rrappend) rHrrArBtargetedlivertrackedstates &$$$ r _prune_deadrLjs!,FF $0FH!#D==D+;!<= IIe eii(<=7{  =%1EIIl399r:cBS>TT*uyy/?:/M01[\\E 5 KK  Krc]tRtRt$R]R&R]R&R]R&RtR]R&R tR]R &R tR ]R &R tR ]R&R t R]R&RRlt Rt R #)ActiveSessionLeaseirrrrMTr%enabledFreleasedNzOptional[Path]rrrcV^8dQhRR/#)rrrr)r!s"rr"ActiveSessionLease.__annotate__s%%%rc hVP'gVP'gR#\V4R#r~)rPrOrelease_active_session)rs&rreleaseActiveSessionLease.releases === t$rr) rrrrrrOrPrrrrUrrrrrNrNsOMO LGTHd "&J% $I~$ ND %%rrNc V^8dQhRRRR/#)rrrrr)r!s"rr"r"sJJnJJrcVP4UUu/uF)wr\V\4'gK\V4VbK+ upp#uuppir~)rdr$r)rkrs& r_clean_metadatarZs8"*.."2 I"2$!jC6HICFAI"2 II Is AAc(V^8dQhRRRRRRRR/#)rrrrHrIrrrr)r!s"rr"r"s,3?BrcVUu.uF0p\VPR4;'gR4V8wgK.VNK2 pp\V4\V48wd \W4V#uupi)zRRemove ``lease_id`` from ``entries``, writing the registry only if it was present.rrK)rr7r r&)rrHrrRkepts&&& r _drop_leaser^sZ Kw!#aeeJ&7&=&=2">("JAAwD K 4yCL z( K Ls!A# A#A#c$V^8dQhRRRRRR/#)rrHrIrrrr%r)r!s"rr"r"s'[[0[c[d[rca\T;'gR4o\S4;'d;\;QJdV3RlV4F 'gK R# R#!V3RlV44#)rKc3r<"TF,p\VPR4;'gR4S8HxK. R#5i)rrKNrO)rQrRtargets& rrS!_holds_session..s.ZRYQAEE,$7$=$=2 >& HRYs!77TF)rr%any)rHrrbs&&@r_holds_sessionresL !!r "F < Z ZCCZRYZCCZCZCZRYZZZrc 0V^8dQhRRRRRRRRR R R R /#) rrrrr%warnrrArDrBrErz;Optional[tuple[list[dict[str, Any]], list[dict[str, Any]]]]r)r!s"rr"r"s?)-58!6@Arc\VRR7pV\WQW4R73# \d#T'dh\P T4R#i;i)aD``(raw, pruned)`` from the registry, or None when it is unreadable. Liveness-tracked callers re-raise instead (they must not proceed on an unprovable registry); untracked callers get ``warn`` logged and decide how to degrade. ``target_session_id`` is the session the caller is about to claim/release (see ``_prune_dead``). Tr)rrArBN)rrLrr,r-)rrrgrArB raw_entriess&$$$$ r_read_live_entriesrksS #Jt< K /    &  t sA A  A rrc 0V^8dQhRRRRRRRRRRR R /#) rrrrrMrrrr%rrr)r!s"rr"r"s>"%03&?Crc\P!4pRVR\V4R\V4R\P!4R\ 4RVRV/pV'dRVR&V'd\ V4VR &V#) rrrMrrr] updated_atTrr)rerrrr2rZ)rrrMrrnowrs$$$$$ r _lease_entryrpsq ))+CHc*o3w< ryy{o/ccE"&+H5j Lrrc4V^8dQhRRRRRRRRRR R R R R /#)rrrrMr1rrrrrrr%rz2tuple[Optional[ActiveSessionLease], Optional[str]]r)r!s"rr"r"sO\\\!$\.1\=U\$\=A\8\rc aa\V4p\P!4Pp\ T;'gR4pV'g"V'g\ Wx\ V4RR7R3#\ Wx\ V4VVR7p \VR7wop \ Wx\ V4SWR7p \V 4;_uu_4\SVRVR 7p V f!R\R S R 2\43uuRRR4#V wp o\V 4\S4, pV'd\PR V4R VV3RllpV'd\S4Fwpp\ VP!R4;'gR4V8wdK1\#VV4'd"V SV&\%SS4V R3uuuRRR4#V!\'VV4\(RVVP!R4VP!R44uuuRRR4# VeH\S4V8d8V!\+\S4VS4\,R\S4Wa4uuRRR4#SP/V 4\%SS4RRR4V R3# +'giT R3#;i)aqAcquire an active-session slot: ``(lease, None)`` or ``(None, ActiveSessionRefusal)``. Per-session exclusivity is CORRECTNESS, enforced unconditionally (at most one live owner per stored session); ``max_concurrent_sessions`` is resource POLICY, applied only when configured. ``registry_home`` lets profile-scoped backends share the owning profile's registry. Ownership uncertainty fails CLOSED (SESSION_COORDINATION_UNAVAILABLE). Liveness tracking keeps richer desktop lifecycle semantics; ``registry_home`` lets profile-scoped backends share the owning profile's registry even when launched from another home. See #94595. rKF)rrrMrONrrrMrrr)rrrMrrrzdActive-session registry is unavailable; refusing the session rather than risking a concurrent writerrrgrAz5Hermes could not read the active-session registry at za, so it cannot prove this session has no other live owner. Fix or remove that file and try again.z'Pruned %d stale active session lease(s)c(V^8dQhRRRRRRRR/#)rr{rrylogrz!tuple[None, ActiveSessionRefusal]r)r!s"rr"0try_acquire_active_session..__annotate__s) ? ?C ? ?3 ?Bc ?rcf<\SS4\P!V.VO5!R\W43#r~)r&r,inforx)r{ryrvargsrHrs&&&*rrefuse*try_acquire_active_session..refuses/ :w / KK #d #-g>> >rrz-G,EE1    & W[!CL0  KKA6 J ? ? #,W#5xx||L177R8C? #8X66%*GEN":w7 $;&Q  R1#x@BSRe,hll9.ES  <$6$  #G (D,S\<Q'KG l c  n uz7+q t $;u  t $;s2=)I+1AI+-I+/6I+0:I+5AI+I++ I> c V^8dQhRRRR/#)rrrNrrr)r!s"rr"r"As"4rc N\V4wr\V4;_uu_4VP'd RRR4R#\WPRVP R7pVe\ W^,VP4RVnRRR4R# +'giR#;i)NzXActive-session registry is unavailable; preserving it while releasing an untracked leasertT)rrrPrkrrr^r)rrrrs& rrTrTAs)/J 9   >>>   $ ';';0#..      1Iu~~ >    sBA B B$ c(V^8dQhRRRRRRRR/#) rrrNrrrrrr%r)r!s"rr"r"Ts,)) ).1)=U) )rc ,a\T;'gR4pV'dSP'dR#SP'g VSnR#\ S4wrE\ V4;_uu_4SP'd RRR4R#\ VSPRSPR7pVf RRR4R#V^,p\V3RlV4R4pVe4W8R&\P!4VR &V'd\V4VR &MQSP'd5VP\SPVSPVRR 74M RRR4R#\WG4VSnRRR4R# +'giR#;i) zEMove an existing lease to a new session id without dropping the slot.rKFTNzVActive-session registry is unavailable; refusing to overwrite it during lease transferrtc3<"TF<p\VPR4;'gR4SP8XgK8VxK> R#5i)rrKN)rr7r)rQrRrs& rrS*transfer_active_session..ns4Yw!#aeeJ.?.E.E2*F%..*XAAws!AA Arrnrrs)rrPrOrrrrkrnextrerZrGrprrMr&) rrrnew_session_idrrrrHowns f$$ rtransfer_active_sessionrTsO))r*N U^^^ ===)(/J 9   >>>   $ u';';,#..   >  )YwY[_` ? .  $ C "1(";J  ! ! ! NN<NEMM!$  5  6 z+);    s%.F (F>A'F&5F%F F g>@c$V^8dQhRRRRRR/#)rrHrIown_live_lease_idsset[str] | Nonerr)r!s"rr"r"s$   ! 7F  rczVfV#\P!4p\P!4\, pVUu.uFopVP R4V8wgU\ VP R4;'gR4V9g,\ VP R44;'gRV8gKmVNKq up#uupi)zEDrop this process's leases only when its caller can vouch for owners.rrrKr]g)rrre_SELF_ORPHAN_GRACE_SECONDSr7rr^)rHrrcutoffrs&& r_drop_self_orphansrs! ))+C YY[5 5F" "% 99U s " uyy$** +/A A EIIl3 4 ; ;v E 7  s7B88,B8%B8/B8c$V^8dQhRRRRRR/#)rrrlive_lease_idsset[str]rr)r)r!s"rr"r"s"D(WZrc \V4pVP4'g^#\\V44;_uu_4\ VRR\ P !4R7pVf RRR4^#V^,p\WA4p\V4\V4, pV'd \W%4VuuRRR4# +'giR#;i)r?FzEActive-session registry is unavailable; skipping orphaned-lease sweep)rrgrBN) rexistsrrrkrrrr r&)rrrrrHr]droppeds&& r _release_orphaned_leases_in_homers]+J      :m, - -# uXyy{  > . -)!':g,T*  : , . - - -s(C2AC C c V^8dQhRRRR/#)rrrrr)r)r!s"rr"r"sHrc8\4pV.pVPRVR, P444^pVFpV\ W@4, pK V# \dL-i;i \d"p\ P RYE4Rp?KTRp?ii;i)uDrop this process's registry entries that no live session owns. ``_prune_dead`` only reclaims leases of dead processes, so on a days-long server a lease whose session skipped teardown is held until restart. The owning process is the only authority on its own leases — exact, no heartbeat on the turn path, no threshold. Sweeps the root home and every profile home (a multiplexed server leases across them). c3L"TFp\V4'gKVxK R#5ir~)r )rQps& rrS*release_orphaned_leases..sZ =1AVWXAYQQ =s$ $profilesz&orphaned-lease sweep failed for %s: %sN)r extenditerdirOSErrorrr,debug)rroothomesrrrs& rrelease_orphaned_leasesrs # $D FE  Z !2 ; ; =ZZG N 7M MG N     N LLA4 M M Ns)-AA- A*)A*- B8BBc$V^8dQhRRRRRR/#)rrrrr%rrIr)r!s"rr"r"s$$8<rc B\VR7wr#\V4;_uu_4\VRR7pRRR4\XVR7pWT8wEdVUu0uF'p\ VP R4;'gR4kK) ppVUu0uFRp\ VP R4;'gR4V9gK.\ VP R4;'gR4kKT pp\V4;_uu_4\VRR7p V Uu.uF0p\ VP R4;'gR4V9gK.VNK2 p p\ V 4\ V 48wd \W*4RRR4V#V# +'giELC;iuupiuupiuupi +'giT#;i)aReturn live leases; attachment callers require provable liveness. The per-entry liveness probes in ``_prune_dead`` run AFTER the file lock is released: holding an exclusive, unfair lock across process-introspection syscalls starves concurrent pollers once a handful of leases exist (#115578). The prune write-back re-locks and drops only the lease ids already proven dead, so a lease created between the snapshot and the write-back is never lost. rTriNrrK)rrrrLrr7r r&) rrrrrjrHrrdead_lease_idscurrent_entries kept_entriess &$ r active_session_registry_snapshotrsp)}EJ 9  #Jt<  +f5GHOPu#eii 399r:P% $599Z(..B/~E -C *%++ ,$  y ! !+JtDO#2#2%uyy,223>I? < C$88z8" N7N%   Q " ! NsYE*!E>2 E>!F% F3F F0F !F$ F2F8&F * E; F  F rc(V^8dQhRRRRRRRR/#) rrrrrrrrIterator[bool]r)r!s"rr"r"s. 2 2 2'8 2' 2 2rc #"\VR7wr4\V4;_uu_4\\VRR7RVR7p\ WR4p\ W54\ WP4xRRR4R# +'giR#;i5i)zHold the registry lock while reporting whether ``session_id`` is leased, so no new backend can acquire a lease between the check and the caller's ``end_session``.rTrirrAN)rrrLrrr&re)rrrrrrHs&$$ ractive_session_liveness_guardrse)}EJ 9   *T 24S] %WAz+W11    s"A?=A+! A?+ A< 6 A?c(V^8dQhRRRRRRRR/#) rrrNrrrrrrr)r!s"rr"r"s,// /+./GV//rc #"VP'dVP'dUVPe!VPPPMRp\ WVR7;_uu_4pVxRRR4R#\ V4wrV\ V4;_uu_4\\VRR7RVR7pVUu.uF:p\VPR4;'gR4VP8wgK8VNK< p p\W4p \V 4\V48wd \WY4RVn\W4xRRR4R# +'giR#;iuupi +'giR#;i5i)zRemove ``lease`` and hold its registry lock through a lifecycle write, making cleanup one atomic decision (release, check siblings, end the durable row).N)rrTrirrrK)rOrPrrrrrrLrrr7rrr r&re) rrrractiverrrHrRr]s &&$ r%release_active_session_liveness_guardrs( ===ENNN161A1A1Mu&&--SW * ?Q  L  (/J 9   *T 24S] #U7ac!%% *;*A*Ar&Benn&T7U!$; t9G $ : ,T..     V   sZ$E5AE5,E1*E5E!9!EE3E9AE!> E5 E  E5E!! E2 , E5)r3r~)NN)S__conditional_annotations__r __future__rr loggingr`r rrer} contextlibrr dataclassesrpathlibrtypingrrr hermes_constantsr r r utilsr getLoggerrr,rrr/r;rFrkrsrtrurvPER_SESSION_EXCLUSIVE_SUBMITrrxrrrrrrrrrrrrrrrr&r-r.rr2r^r@rLrNrZr^rerkrprrTrrrrrrrr)rs@rrsD#  /!**\\#   8 $KK * 8"A   (3$F $3U TF YNN`K0**Z2+8O(, $+ 7u776 5: $( CG F %% %(J[ $(CG0)-FK*\X\\'+\DI\~&)X\)d"  ,0?DD 2;? 2*. 2 2 /Y]//r