jj$dZddlmZddlZddlZddlZddlZddlmZddl m Z m Z ddl m Z mZejr6ddlmZdd lmZmZdd lmZmZdd lmZed Zej6d ZdZGddeZGdde Zy)zTTwisted Reactor based urwid EventLoop implementation. Twisted library is required. ) annotationsN)FileDescriptor) AlreadyCalledAlreadyCancelled) EventLoop ExitMainLoop)Callable)ExecutorFuture) DelayedCall ReactorBase) ParamSpec_Spec_T)TwistedEventLoopcBeZdZdfd ZddZdZdZdZd dZxZ S) _TwistedInputDescriptorc@||_||_t| |yN)_filenocbsuper__init__)selfreactorfdr __class__s f/home/ubuntu/.cache/pipx/cdb5059130eadca/lib/python3.12/site-packages/urwid/event_loop/twisted_loop.pyrz _TwistedInputDescriptor.__init__5s  !c|jSr)rrs rfilenoz_TwistedInputDescriptor.fileno:s ||r c"|jSr)rr"s rdoReadz_TwistedInputDescriptor.doRead=swwyr ctdNzNo network operation expectedNotImplementedErrorr"s rgetHostz_TwistedInputDescriptor.getHost@!"ABBr ctdr'r(r"s rgetPeerz_TwistedInputDescriptor.getPeerCr+r ctd)Nz Reduced functionality: read-onlyr()rdatas r writeSomeDataz%_TwistedInputDescriptor.writeSomeDataFs!"DEEr )rrrintrCallable[[], typing.Any]returnNone)r3r1)r/bytesr3r4) __name__ __module__ __qualname__rr#r%r*r-r0 __classcell__rs@rrr4s$" CCFr rceZdZdZdZddfd Z ddZddZddZddZ ddZ dd Z dd Z dd Z dd Zdd ZdddZxZS)rz& Event loop based on Twisted_ gp?c^t|tjtj |j j|_|ddl}|jj}||_ i|_ d|_ d|_ i|_d|_||_|j#y)a# :param reactor: reactor to use :type reactor: :class:`twisted.internet.reactor`. :param: manage_reactor: `True` if you want this event loop to run and stop the reactor. :type manage_reactor: boolean .. WARNING:: Twisted's reactor doesn't like to be stopped and run again. If you need to stop and run your :class:`MainLoop`, consider setting ``manage_reactor=False`` and take care of running/stopping the reactor at the beginning/ending of your program yourself. You can also forego using :class:`MainLoop`'s run() entirely, and instead call start() and stop() before and after starting the reactor. .. _Twisted: https://twisted.org/ NrF)rrlogging getLoggerr6getChildrloggertwisted.internet.reactorinternetr _watch_files _idle_handle_twisted_idle_enabled_idle_callbacks_excmanage_reactor_enable_twisted_idle)rrrHtwistedrs rrzTwistedEventLoop.__init__Qs( ''1::4>>;R;RS ? +&&..G$+ @B!"%*"DF*. , !!#r ctd)NaTwisted implement it's own ThreadPool executor. Please use native API for call: 'threads.deferToThread(Callable[..., Any], *args, **kwargs)' And use 'addCallback' api for callbacks: 'threads.deferToThread(Callable[..., T], *args, **kwargs).addCallback(Callable[[T], None])'r()rexecutorfuncargskwargss rrun_in_executorz TwistedEventLoop.run_in_executorts" j  r c\|jj||j|}|S)a# Call callback() a given time from now. No parameters are passed to callback. Returns a handle that may be passed to remove_alarm() seconds -- floating point time to wait before calling callback callback -- function to call from event loop )r callLater handle_exit)rsecondscallbackhandles ralarmzTwistedEventLoop.alarms*''1A1A(1KL r cP |jy#ttf$rYywxYw)z] Remove an alarm. Returns True if the alarm exists, False otherwise FT)cancelrrrrVs r remove_alarmzTwistedEventLoop.remove_alarms.   MMO !-0  s %%ct|j||j|}||j|<|jj ||S)a" Call callback() when fd has some data to read. No parameters are passed to callback. Returns a handle that may be passed to remove_watch_file() fd -- file descriptor to watch for input callback -- function to call when input is available )rrrSrC addReader)rrrUinds r watch_filezTwistedEventLoop.watch_filesH&dllB8H8H8RS #" s# r c||jvr6|jj|j||j|=yy)zg Remove an input file. Returns True if the input file exists, False otherwise TF)rCr removeReaderrZs rremove_watch_filez"TwistedEventLoop.remove_watch_filesC T&& & LL % %d&7&7&? @!!&)r cv|xjdz c_||j|j<|jS)zw Add a callback for entering idle. Returns a handle that may be passed to remove_enter_idle() r)rDrFrrUs r enter_idlezTwistedEventLoop.enter_idles7 Q2:T../   r c|jry|jj|j|j |j dd|_y)aU Twisted's reactors don't have an idle or enter-idle callback so the best we can do for now is to set a timer event in a very short time to approximate an enter-idle callback. .. WARNING:: This will perform worse than the other event loops until we can find a fix or workaround NF) enable_idleT)rErrR_idle_emulation_delayrS_twisted_idle_callbackr"s rrIz%TwistedEventLoop._enable_twisted_idlesN  % %    & &   T88e  L &*"r c^|jjD] }| d|_y)NF)rFvaluesrErds rriz'TwistedEventLoop._twisted_idle_callbacks-,,335 H J %*"r c> |j|=y#t$rYywxYw)z[ Remove an idle callback. Returns True if the handle was removed. FT)rFKeyErrorrZs rremove_enter_idlez"TwistedEventLoop.remove_enter_idles.  $$V,  s  c|jsy|jj|jr.|j}d|_|j |j y)z Start the event loop. Exit the loop when any callback raises an exception. If ExitMainLoop is raised, exit cleanly. N)rHrrunrGwith_traceback __traceback__)rexcs rrpzTwistedEventLoop.runsS ""   99))CDI$$S%6%67 7 r cLtjdfd }|S)a1 Decorator that cleanly exits the :class:`TwistedEventLoop` if :class:`ExitMainLoop` is thrown inside of the wrapped function. Store the exception info if some other exception occurs, it will be reraised after the loop quits. *f* -- function to be wrapped cbd} |i|}rj|S#t$r)jrjjYEt$rT}t t j|_jrjjYd}~d}~wwxYwr) r rHrstop BaseExceptionprintsysexc_inforGcrashrI)rNrOrvalrsrgfrs rwrapperz-TwistedEventLoop.handle_exit..wrappersD )$)&)))+K  (&&LL%%'  )clln% &&LL&&(  )s!/B.B.A B))B.)rNz _Spec.argsrOz _Spec.kwargsr3z _T | None) functoolswraps)rr}rgr~s``` rrSzTwistedEventLoop.handle_exits'      r )NT)rzReactorBase | NonerHboolr3r4) rLr rMzCallable[..., _T]rNobjectrOrr3z Future[_T])rTfloatrUr2r3r )rVr r3r)rr1rUr2r3r1)rVr1r3r)rUr2r3r1)r3r4)T)r}zCallable[_Spec, _T]rgrr3zCallable[_Spec, _T | None])r6r7r8__doc__rhrrPrWr[r_rbrerIrirnrprSr9r:s@rrrJs&!$F                 !*$+  8r r) r __future__rrr=rytypingtwisted.internet.abstractrtwisted.internet.errorrr abstract_looprr TYPE_CHECKINGcollections.abcr concurrent.futuresr r twisted.internet.baser rtyping_extensionsrrTypeVarr__all__rrr rrst, # 4B2 (3>+ g E  B FnF,DyDr