߲jUdZddlmZddlZddlZddlZddlZddlmZm Z dgZ ejZ iZ ded<iZded <iZd ed <Gd d ZGddZddZej(ddZy)aThread-scoped stdout/stderr silencing for background worker threads. ``contextlib.redirect_stdout`` reassigns the *process-global* stream, so a daemon worker silencing itself also silences every other thread (gateway event loop included). This module installs a per-thread routing proxy as ``sys.stdout``/``sys.stderr``: silenced threads write to a sink, everyone else passes through to the original stream. Installed once, idempotently, and never uninstalled (that would race other threads mid-write). ) annotationsN)IteratorTextIOthread_scoped_silencez!dict[str, '_ThreadRoutingStream'] _installedzdict[str, TextIO]_sinkszdict[str, '_RoutingState']_routing_statesceZdZdZddZy) _RoutingStatezCSilencing registry shared by every proxy generation for one stream.cR||_i|_tj|_yN)sinksilenced threadingLocklock)selfrs ?/home/ubuntu/.hermes/hermes-agent/agent/thread_scoped_output.py__init__z_RoutingState.__init__ s (* NN$ N)rrreturnNone)__name__ __module__ __qualname____doc__rrrr r s M%rr c^eZdZdZddZddZddZddZddZdZ dZ d Z dd Z d Z d Zy )_ThreadRoutingStreamz``sys.stdout``/``sys.stderr`` stand-in routing writes per calling thread; unknown attributes delegate to the current thread's target.c ||_||_yr ) _passthrough_state)r passthroughstates rrz_ThreadRoutingStream.__init__*s' rc|jjjtjddkDr|jj S|j SNr)r"rgetr get_identrr!rs r_targetz_ThreadRoutingStream._target.sG#';;#7#7#;#;I*>*B*B5!*Lq*PDKK  ' Q Q Qs AA!!A*c6|jj5|jjj|ddz }|dkDr||jj|<n&|jjj |ddddy#1swYyxYwr,)r"rrr'pop)rr.depths r unsilencez_ThreadRoutingStream.unsilence5sz [[   6KK((,,UA6:Eqy.3 $$U+ $$((5  6 6 6s A/BBcf t|j||S#t$r||cYSwxYw)zaCall ``name`` on the current target; a dead target yields ``fallback(*args)`` instead of raising.)getattrr* Exception)rnamefallbackargss r_forwardz_ThreadRoutingStream._forward=s: #074<<>40$7 7 #T? " #s 00c*|jdd|S)Nwritec<t|tr t|SdSr&) isinstancestrlen)ds rz,_ThreadRoutingStream.write..Es*Q:LARSrr:)rdatas rr<z_ThreadRoutingStream.writeDs}}W&SUYZZrc(|jddS)Nflushcyr rrrrrBz,_ThreadRoutingStream.flush..HrrCr)s rrFz_ThreadRoutingStream.flushGs}}Wl33rc*|jdd|S)N writelinescyr r)_ls rrBz1_ThreadRoutingStream.writelines..KrHrrC)rliness rrJz_ThreadRoutingStream.writelinesJs}}\?EBBrcp t|jjS#t$rYywxYw)NF)boolr*isattyr6r)s rrPz_ThreadRoutingStream.isattyMs3  --/0 0  s &) 55c>|jjSr )r*filenor)s rrRz_ThreadRoutingStream.filenoSs||~$$&&rc6t|j|Sr )r5r*)rr7s r __getattr__z _ThreadRoutingStream.__getattr__Vst||~t,,rN)r#rr$r rr)rr)r.intrr)r7r?)rrO)rrrrrr*r/r3r:r<rFrJrPrRrTrrrrr&sCCqQ6#[4C '-rrctt5tj|}tt|d}t |t r'|t|<|jt|<|cdddS|||ur |cdddS||n|}tj|}| |jr%ttjddx}t|<tj|}||j|urt|x}t|<t ||x}t|<t!t|||cdddS#1swYyxYw)zGInstall (idempotently) a routing proxy as ``sys.`` and return it.Nwzutf-8)encoding) _install_lockrr'r5sysr>rr"r rclosedopenosdevnullrr setattr)attrr#proxycurrentrr$s r_ensure_installedrcZs t$#tT* g3 4 'Jt $+NNOD !  E!1")!4g+ zz$ <4;;"&rzz3"I ID6$<##D) =EJJd2,9$,? ?EOD)#7 U#KK 4 T5!-sAD.%D.6B.D..D7c#Ktj}tdtjxstj tdtj xstjf}|D]}|j| d|D]}|j|y#|D]}|j|wxYww)z>+GSZZHJ[\dfiftftgCx{yCyCKDEG e#  #E OOE " #W #E OOE " #sBCB% C%B??C)r`r?r#rrz'_ThreadRoutingStream')rzIterator[None])r __future__r contextlibr]rZrtypingrr__all__rrYr__annotations__rr r rrccontextmanagerrrrrrps# # " #  02 -2.0+0%%1-1-h6  # #r