+ lHj3dRt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI H t HtHt^RIHt^RIHt]P*!R4t!RR4tR R ltR R ltR tRRltRtRRltR%RRlltRRltRRlt RRRR/RRllt!RR/RRllt"R t#R!R"/R#R$llt$R#)&afBackground-loop plumbing for tools.mcp_tool: cross-process discovery file lock, scheduling coroutines onto the MCP loop from caller threads (with profile HOME override and dashboard OAuth flow propagation) and the loop's exception handler. Origin state (``_lock``, ``_mcp_loop``) is read through ``_core`` so ``mock.patch("tools.mcp_tool.X")`` keeps working.) annotationsN)Any CoroutineOptional)_core)mcp_tool_lifecycleztools.mcp_toolc2]tRt^tRtRRltRRltRtR#) _LockCookiezHolds a cross-process file lock; ``release()`` drops it. The file object MUST stay open while held: both fcntl and portalocker locks are tied to the descriptor.c V^8dQhRRRR/#)fhrreturnNone)formats"8/home/ubuntu/.hermes/hermes-agent/tools/mcp_tool_loop.py __annotate___LockCookie.__annotate__s34c WnR#N_fh)selfr s&&r__init___LockCookie.__init__srcV^8dQhRR/#r r rr)rs"rrrs   rc :VPfR#\P!\4;_uu_4\P R8Xd:^RIpVPVPP4VP4M^RI pVPVP4RRR4\P!\4;_uu_4VPP4RRR4RVnR# +'giL^;i +'giL,;i)Nposix) r contextlibsuppress ExceptionosnamefcntlflockfilenoLOCK_UN portalockerunlockclose)rr%r)s& rrelease_LockCookie.releases 88     + +ww'! DHHOO-u}}="""488, ,  + + HHNN ,, +, +sA.C7 D 7 D D rN)__name__ __module__ __qualname____firstlineno____doc__rr,__static_attributes__rrrr r sJ  rr c V^8dQhRRRR/#)r r rr boolr)rs"rrr.sCDrc\PR8XdC^RIpVPVP 4VP VP ,4R#^RI pVPWP VP ,4R# \dKpTP\P\P\P39dRp?R#hRp?ii;i TPdR#i;i)zNon-blocking exclusive lock (fcntl on POSIX, portalocker elsewhere). False when another process holds it; unexpected errors propagate so the caller can treat locking as unavailable.rNFT)r#r$r%r&r'LOCK_EXLOCK_NBOSErrorerrnoEACCESEAGAIN EWOULDBLOCKr)lock LockException)r r%er)s& r_acquire_lock_on_fhrA.s ww'  KK U]]U]]%B C 00;3F3FFG  ww5<<u7H7HII    $ $s/;B ,C# C >CCC #C87C8cV^8dQhRR/#)r r rr)rs"rrrBsrc^RIHp^RIHpHpV!4e\ V!4R, 4pM6VP f\ V!4R, 4VnVP p\VRRR7p\T4pT'd \T4#TP4R# \d\Pu#i;i \d$TP4\Pu#i;i)z``_LockCookie`` (acquired), ``None`` (held by another process) or ``_LOCK_UNAVAILABLE`` (locking broken: run discovery unguarded).mcp_tool)get_hermes_homeget_hermes_home_overrideNz.mcp-discovery.lockwzutf-8)encoding)toolsrEhermes_constantsrFrGstr_MCP_DISCOVERY_LOCK_PATHopenr"r_LOCK_UNAVAILABLErAr+r )_originrFrG lock_pathr acquireds r_try_acquire_mcp_discovery_lockrSBs * 'N # % 1O-0EEFI//7367HK`7`3a088I )S7 3'&r*2HHJ  '&&&' '  &&&'s$A-B&6 C&CC+C54C5cVPR4p\V\4'dR\V49gVP V4R#R#)zSuppress the benign 'Event loop is closed' RuntimeError httpx finalizers raise against the dead loop during shutdown; forward the rest. exceptionzEvent loop is closedN)get isinstance RuntimeErrorrLdefault_exception_handler)loopcontextexcs&& r_mcp_loop_exception_handlerr]_s? ++k "C sL ) ).DC.P &&w//Qrc V^8dQhRRRR/#)r cororr r)rs"rrrgs9rcaaaa^RIHpHoHoV!4oS'gS#VVVV3RlpV!4# \dRoL)i;i)zCarry the caller's context-local HERMES_HOME override into ``coro`` (task-local on the MCP loop, so concurrent scopes don't interfere).)rGreset_hermes_home_overrideset_hermes_home_overrideNc`<"S!S4pSGRjxL S!V4#L S!T4i;i5irr)tokenr_ home_overriderarbs r_scoped)_wrap_with_home_override.._scopedrs0(7 .: &u - &u -s .!! .! +.)rKrGrarbr")r_rGrfrerarbsf @@@r_wrap_with_home_overriderhgsJss02   .. 9  s1 AAcxaaa^RIHoHpV!4oSfS#VVV3RlpV!4# \dRoL$i;i)zBPropagate a dashboard OAuth flow onto the dedicated MCP loop task.)dashboard_oauth_flowget_dashboard_oauth_flowNc<"S!S4;_uu_4SGRjxL uuRRR4#L +'giR#;i5irr)r_rjflowsrrf0_wrap_with_dashboard_oauth_flow.._scopeds, !$ ' ':( '( ' 's ?+)+ ?+ < ?)tools.mcp_dashboard_oauthrjrkr")r_rkrfrjrmsf @@r_wrap_with_dashboard_oauth_flowrp|sD\') |  9 s ) 99cV^8dQhRR/#)r r z#Optional[asyncio.AbstractEventLoop]r)rs"rrrsDD:Drc\P;_uu_4\PpRRR4XeVP4'dV#R# +'giL.;i)z=The MCP loop when it is up, else None (read under ``_lock``).N)r_lock _mcp_loop is_running)rZs r _running_looprvs=  #(9(94CtC s A A cV^8dQhRR/#)r timeoutfloatr)rs"rrrs#'#'u#'rc^RIHp^RIHp\ 4pVf8\ P !V4'dVP4\R4h\\\V4'dV!4MT44pV!WT\RR7pVf \R4h\P!4pVfRMWq,pV!4'dVP4\!R4hVfR MV\P!4, p V ^8:dHVP4\#R \P!4V, R R \%V4R R 24hVP'\)R V 4R7# \*P,P"d.TP/4'dTP'4u#EKi;i)uSchedule a coroutine (or zero-arg factory — avoids leaking a never-awaited coroutine when the loop is down) on the MCP loop and block until done, polling so user interrupts are honored.)is_interruptedsafe_schedule_threadsafeNzMCP event loop is not runningzMCP scheduling failed)logger log_messagez/MCP event loop unavailable (failed to schedule)zUser sent a new messageg?zMCP call timed out after z.1fzs (configured timeout: zs)rx)tools.interruptr{agent.async_utilsr}rvasyncio iscoroutiner+rXrprhcallabler~time monotoniccancelInterruptedError TimeoutErrorryresultmin concurrentfuturesdone) coro_or_factoryrxr{r}rZr_future start_timedeadline remainings && r_run_on_mcp_looprs/: ?D |    / /  ! ! #:;; ++C%o66O,M ND %dMd eF ~LMM!JtJ,@H     MMO"#<= =#+CDNN MMO!:4>>;Kj;XY\:]^77.__annotate__s"""rc<\SRR4\SRR4r\VR4'dVP4\VR4'dVP4R#R#)rNrclearr)rrrr)rreconnect_eventrs r_request_reconnect6_signal_reconnect_and_wait.._request_reconnectsR!(h!=wsL^`d?e 5' " " KKM ?E * *    ! +rrz2MCP server '%s': %s requesting transport reconnect)rrx)rrtrurr~inforr)rrrrxrZrrs&f$$ r_signal_reconnect_and_waitrsg ??D |4??,,""#y$/K KKDkb01 )#; XXrc^RIHp\P;_uu_4VPe,VPP 4'd RRR4R#\ P!4;qnVP\4\P!VPRRR7Vn VPP4RRR4R# +'giR#;i)zStart the background loop thread if not running. The loop/thread handles live on the ORIGIN module (tests read and reset ``tools.mcp_tool._mcp_loop``), so they are written there.rDNzmcp-event-loopT)targetr$daemon)rJrErrsrtrurnew_event_loopset_exception_handlerr] threadingThread run_forever _mcp_threadstart)rPrZs r_ensure_mcp_looprs*     (W->->-I-I-K-K  $+#9#9#;;  ""#>?'..d6F6FM]fjk!!# s.CCA2C C& only_if_idleFc V^8dQhRRRR/#)r rr5r r)rs"rrrs//D/T/rc^RIHp\P;_uu_4V'dM\P'g\P 'd!\ PR4RRR4R#VPVPr2R;VnVn RRR4XfR#RpVP4'dg^RI H pV!\P!4V\ R\P R7pVe*VP#\P$^,R 7MLMKVP-4'g6VP/\P0!\P$R 74Vf2VP4'dVP3VP44Xe>VP7^R 7VP94'd\ P)R 4VP;4\P>!RR7R# +'giEL;i \&d/\ P)R \P$^,4L\*d"p\ P)R T4Rp?ELRp?ii;i \*d"p\ P)R T4Rp?ELARp?ii;i \<d!p\ P)RT4Rp?LRp?ii;i)z3Stop the background event loop and join its thread.rDzKLeaving MCP event loop running; active servers are registered or connectingNFTr|z"MCP loop drain: failed to schedule)r~r log_levelrz0Timed out waiting for MCP loop drain after %.1fsz!Error draining MCP loop tasks: %sz)Error draining stopped MCP loop tasks: %sz.MCP event loop thread did not stop within 5.0sz*Unable to close MCP event loop cleanly: %s)include_active) rJrErrsr_server_connectingr~debugrtrrurr} _lifecycle_drain_and_stop_mcp_looploggingWARNINGr_MCP_LOOP_DRAIN_TIMEOUTrwarning BaseException is_closedrun_until_complete_drain_mcp_loop_tasksrstopjoinis_aliver+r"_kill_orphaned_mcp_children)rrPrZthreadrr}r\s$ r_stop_mcp_looprs )  U^^^u/G/G/G LLf g (('*=*=f266G/   |F >)  / / 14<Y   I e&C&Ca&G H ^^   M  # #J$D$DUMjMj$k l~$//++ !!$)),  A  ??   NNK LJ **$? Y .  vQSXSpSpstStu  IBCHH I  M NNF L L M JCSIIJspHHH4%H<'H$<4J 'J9 H! $6JJ%J&JJ J6J11J69 K$KK$))%r2 __future__rrconcurrent.futuresrr r:rr#rrtypingrrrtools.mcp_tool_commonrrJrr getLoggerr~r rArSr]rhrprvrrrrrrrrrrrsO #   ++'2   + ,.(:0*"D#'L <4Z^&YdhY( $/5//r