jjndZddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZejr2ddlmZmZdd lmZmZdd lmZmZej2d Zed Zd ZGdde Zy)z,Select based urwid EventLoop implementation.) annotationsN)suppress)count) EventLoop ExitMainLoop)CallableIterator)ExecutorFuture)Literal ParamSpec_T_Spec)SelectEventLoopceZdZdZd fd Z ddZ ddZddZddZddZ ddZ dd Z d d Z d d Z d d ZxZS)rzF Event loop based on :func:`selectors.DefaultSelector.select` ct|tjtj |j j|_g|_i|_ d|_ i|_ t|_ d|_y)NrF)super__init__logging getLogger__name__getChild __class__logger_alarms _watch_files _idle_handle_idle_callbacksr _tie_break_did_something)selfrs e/home/ubuntu/.cache/pipx/cdb5059130eadca/lib/python3.12/site-packages/urwid/event_loop/select_loop.pyrzSelectEventLoop.__init__6se ''1::4>>;R;RS JL AC!"DF).$)c.|j|g|i|S)aRun callable in executor. :param executor: Executor to use for running the function :type executor: concurrent.futures.Executor :param func: function to call :type func: Callable :param args: positional arguments to function :type args: object :param kwargs: keyword arguments to function :type kwargs: object :return: future object for the function call outcome. :rtype: concurrent.futures.Future )submit)r"executorfuncargskwargss r#run_in_executorzSelectEventLoop.run_in_executor@s(xt5d5f55r$ctj|z}|t|j|f}tj|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 )timenextr heapqheappushr)r"secondscallbacktmhandles r#alarmzSelectEventLoop.alarmVs@YY[7 "d4??+X6 t||V, r$c |jj|tj|jy#t$rYywxYw)z] Remove an alarm. Returns True if the alarm exists, False otherwise FT)rremover/heapify ValueErrorr"r4s r# remove_alarmzSelectEventLoop.remove_alarmisB   LL   ' MM$,, '   s:= A A c$||j|<|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 r)r"fdr2s r# watch_filezSelectEventLoop.watch_filexs!)" r$c<||jvr|j|=yy)zg Remove an input file. Returns True if the input file exists, False otherwise TFr=r:s r#remove_watch_filez!SelectEventLoop.remove_watch_files& T&& &!!&)r$cv|xjdz c_||j|j<|jS)zq Add a callback for entering idle. Returns a handle that may be passed to remove_idle() r)rrr"r2s r# enter_idlezSelectEventLoop.enter_idles7 Q2:T../   r$c> |j|=y#t$rYywxYw)z[ Remove an idle callback. Returns True if the handle was removed. FT)rKeyErrorr:s r#remove_enter_idlez!SelectEventLoop.remove_enter_idles.  $$V,  s  cP|jjD] }| y)z9 Call all the registered idle callbacks. N)rvaluesrCs r#_entering_idlezSelectEventLoop._entering_idles',,335 H J r$ctjt5d|_ tt5|j ddd)#1swY xYw#1swYyxYw)z Start the event loop. Exit the loop when any callback raises an exception. If ExitMainLoop is raised, exit cleanly. TN) contextlibrrr!InterruptedError_loop)r"s r#runzSelectEventLoop.runsY   . !"&D ./!JJL!!! ! !s"AA  A A AA!cd}tj5}|jjD]&\}}|j |tj |(|j s |jrd}|j r5|j dd}|}t||tjz }|jr!|j r|j r |dkDrd}d}|jjd||j|Dcgc]\}}| } }}nL|jr>|jjd|jDcgc]\}}| } }}ng} ddd s|dk(r3|jjd|jd|_nQ|Otj|j \}} } |jjd | | d |_|jjd | D]} | j!d |_ycc}}wcc}}w#1swYxYw) z6 A single iteration of the event loop NgridlezWaiting for input: timeout=zWaiting for input: timeoutzNo input, entering IDLEFz'No input in timeout, calling scheduled TzProcessing input) selectorsDefaultSelectorritemsregister EVENT_READrr!maxr-rdebugselectrJr/heappopdata) r"r3selectorr>r2timeouttimeout_event_readyr alarm_callbackrecords r#rNzSelectEventLoop._loops .2  & & ( H $ 1 1 7 7 9 F H!!"i&:&:HE F||t22<<#||Aq1H!B!'8diik+ABG&& RY\]R]!GB !!$?{"KL/7w/GH85!HH"" !!">?/7/@A85!AA/ 2V| !!";<##%&+#16t||1L.J !!$KNK]"^_ &*# ,- 'F KKM"&D  '+IB+  s*C>I  H>!>I  I+I > I  I)returnNone) r'r r(zCallable[_Spec, _T]r)z _Spec.argsr*z _Spec.kwargsrdz Future[_T])r1floatr2Callable[[], typing.Any]rd+tuple[float, int, Callable[[], typing.Any]])r4rhrdbool)r>intr2rgrdrj)r4rjrdri)r2rgrdrj)r __module__ __qualname____doc__rr+r5r;r?rArDrGrJrOrN __classcell__)rs@r#rr1s*66"6 6  6  6,+ 5 &   !  !.'r$r)rm __future__rrLr/rrRr-typingr itertoolsr abstract_looprr TYPE_CHECKINGcollections.abcr r concurrent.futuresr r typing_extensionsr rTypeVarrr__all__rr$r#rzsg,3"  2 234  B g E u'iu'r$