jj$dZddlmZddlZddlZddlZddlZddlmZddl m Z m Z ejr6ddl mZddlmZmZdd lmZdd lmZmZed Zej0d Zd ZdddZGdde Zy)zKGLib based urwid EventLoop implementation. PyGObject library is required. ) annotationsN)GLib) EventLoop ExitMainLoop)Callable)ExecutorFuture) FrameType)Literal ParamSpec_Spec_T) GLibEventLoopcyN)_sig_frames c/home/ubuntu/.cache/pipx/cdb5059130eadca/lib/python3.12/site-packages/urwid/event_loop/glib_loop.py_ignore_handlerr3s ceZdZdZdfd Z ddZ ddZ ddZddZddZ ddZ dd Z dd Z d Z dd Zdd ZddZxZS)rz+ Event loop based on GLib.MainLoop cXt|tjtj |j j|_g|_i|_ d|_ d|_ i|_ tj|_d|_|j#i|_y)NrF)super__init__logging getLogger__name__getChild __class__logger_alarms _watch_files _idle_handle_glib_idle_enabled_idle_callbacksrMainLoop_loop_exc_enable_glib_idle_signal_handlers)selfr!s rrzGLibEventLoop.__init__<s ''1::4>>;R;RS "$ ,.!""'DF]]_ *.   02rc.|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 rrun_in_executorzGLibEventLoop.run_in_executorIs(xt5d5f55rcjdfd }tjt|dz|}jj ||fS)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 c4jyNFr+)callbackr-sr ret_falsez&GLibEventLoop.alarm..ret_falsens J  " " $ri)returnzLiteral[False]) handle_exitr timeout_addintr#append)r-secondsr9r:fds` ` ralarmzGLibEventLoop.alarm_sV         c'D.19 = BH~rctjtjtjtjtj g}t jddds|jtj||vry||jvr.t j|jj|tjjk(rtntjj k(rydfd }t j"t j$|||}||j|<y)a Sets the signal handler for signal signum. .. WARNING:: Because this method uses the `GLib`-specific `unix_signal_add` function, its behaviour is different than `signal.signal().` If `signum` is not `SIGHUP`, `SIGINT`, `SIGTERM`, `SIGUSR1`, `SIGUSR2` or `SIGWINCH`, this method performs no actions and immediately returns None. Returns None in all cases (unlike :func:`signal.signal()`). .. signum -- signal number handler -- function (taking signum as its single argument), or `signal.SIG_IGN`, or `signal.SIG_DFL` 6rNc6|dtjSr)rSOURCE_CONTINUE) signal_numberhandlers r final_handlerz7GLibEventLoop.set_signal_handler..final_handlers M4 ('' 'r)rHr>)signalSIGHUPSIGINTSIGTERMSIGUSR1SIGUSR2r check_versionr?SIGWINCHr, source_removepopHandlersSIG_IGNrSIG_DFLunix_signal_addPRIORITY_DEFAULT)r-signumrI glib_signalsrJsources ` rset_signal_handlerz GLibEventLoop.set_signal_handlerxs0 MM MM NN NN NN  !!!R+    0  %  T** *   t4488@ A foo-- -%G // /  ( %%d&;&;V]TZ[(.f%rc |jj|dtj|dy#t$rYywxYw)z] Remove an alarm. Returns True if the alarm exists, False otherwise rFT)r#removerrS ValueErrorr-handles r remove_alarmzGLibEventLoop.remove_alarmsH   LL  q *   vay )   s69 AAcjdfd }tj|tj|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 c4jyNTr8)r\ cb_conditionr9r-s r io_callbackz-GLibEventLoop.watch_file..io_callbacks J  " " $r)r;z Literal[True])r<r io_add_watchIO_INr$)r-rAr9rhs` ` r watch_filezGLibEventLoop.watch_filesG       !% 1 1"djj+ N" rc||jvr0tj|j||j|=yy)zg Remove an input file. Returns True if the input file exists, False otherwise TF)r$rrSras rremove_watch_filezGLibEventLoop.remove_watch_files? T&& &   t008 9!!&)rcv|xjdz c_||j|j<|jS)zw Add a callback for entering idle. Returns a handle that may be passed to remove_enter_idle() r)r%r'r-r9s r enter_idlezGLibEventLoop.enter_idles7 Q2:T../   rcj|jrytj|jd|_yrf)r&ridle_add_glib_idle_callback)r-s rr+zGLibEventLoop._enable_glib_idles(  " "  d../"&rc^|jjD] }| d|_yr7)r'valuesr&ros rrsz!GLibEventLoop._glib_idle_callbacks0,,335 H J "'rc> |j|=y#t$rYywxYw)z[ Remove an idle callback. Returns True if the handle was removed. FT)r'KeyErrorras rremove_enter_idlezGLibEventLoop.remove_enter_idles.  $$V,  s  c |jj|jjr|jj |jr.|j}d|_|j |j y#|jjr|jjwwxYw)z Start the event loop. Exit the loop when any callback raises an exception. If ExitMainLoop is raised, exit cleanly. N)r)run is_runningquitr*with_traceback __traceback__)r-excs rrzzGLibEventLoop.runs  " JJNN zz$$& ! 99))CDI$$S%6%67 7 zz$$& !'s B 7CcHtjdfd }|S)a, Decorator that cleanly exits the :class:`GLibEventLoop` if :exc:`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 c |i|S#t$rjjYyt$rE}|_jj rjjYd}~yd}~wwxYwr7)rr)r| BaseExceptionr*r{)r2r3rfr-s rwrapperz*GLibEventLoop.handle_exit..wrappersn &$)&)) " !  ! & ::((*JJOO%  &s #A=A=;A88A=)r2 _Spec.argsr3 _Spec.kwargsr;z_T | Literal[False]) functoolswraps)r-rrs`` rr<zGLibEventLoop.handle_exits'     r)r;None) r0r r1Callable[_Spec, _T]r2rr3rr;z Future[_T])r@floatr9Callable[[], typing.Any]r;z$tuple[int, Callable[[], typing.Any]])rZr>rIzECallable[[int, FrameType | None], typing.Any] | int | signal.Handlersr;r)r;bool)rAr>r9rr;r>)rbr>r;r)r9rr;r>)rrr;z$Callable[_Spec, _T | Literal[False]])r __module__ __qualname____doc__rr4rBr]rcrkrmrpr+rsrxrzr< __classcell__)r!s@rrr7s 366"6 6  6  6,+ . 25/5/W5/  5/n ( !'  8 rrr)rr>rzFrameType | Noner;r)r __future__rrrrKtyping gi.repositoryr abstract_looprr TYPE_CHECKINGcollections.abcrconcurrent.futuresr r typesr typing_extensionsr r rTypeVarr__all__rrrrrrsh, # 2 (34 g E  B oIor