B 't\H)@sddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z mZmZddlmZdd lmZd gZejZGd d d eZdS) )unicode_literalsN) EventLoop)Future)InputHookContext) AutoSelectorSelector fd_to_int)ThreadWithFuture)wrap_in_current_contextPosixEventLoopcs|eZdZdZeffdd ZdddZddZd d Zdd d Z d dZ dddZ dddZ ddZ ddZddZZS)r z9 Event loop for posix systems (Linux, Mac os X). cst|tsttt|d|_d|_g|_i|_ ||_ i|_ t |_t|jdtjt j|j |jdd|_dS)NFr) issubclassrAssertionErrorsuperr __init__closed_running_calls_from_executor _read_fdsselector_signal_handler_mappingsospipe_schedule_pipefcntlZF_SETFL O_NONBLOCKregister_inputhook_context)selfr) __class__=lib/python3.7/site-packages/prompt_toolkit/eventloop/posix.pyrs zPosixEventLoop.__init__NcCs~t|tst|dks"t|s"t|jr0td|jr>tdz2d|_x|s\||qHW|j rn||Wdd|_XdS)z Keep running the event loop until `future` has been set. :param future: :class:`prompt_toolkit.eventloop.future.Future` object. NzEvent loop is already runningzEvent loop already closed.TF) isinstancerrcallabler ExceptionrZdone _run_oncer)rfuture inputhookr r r!run_until_complete/s z!PosixEventLoop.run_until_completecsh|r0jdkrt_fdd}j||d}|rdg}g}d}x|D]}|jdkrtjddjdd}jdd=xl|D]H\} } | dkr|| q|pt }| |kr|| q|| | fqWqRj |} | rR|| qRW|rFx|D]} | qWx@|D]\} } j | | dq(Wnx|D]\} } | qLWdS)Ncs|r dndgkS)zF True when there is input ready. The inputhook should return control. Nr)_ready_for_reading)wait)rr r!readyRsz'PosixEventLoop._run_once..readyri)_max_postpone_until)rrZcall_inputhookr)rrreadrappend_nowrget _run_taskcall_from_executor)rr'r+fdsZtasksZlow_priority_tasksZnowfdZcalls_from_executorcZmax_postpone_untilhandlert_r )rr!r%Ks@           zPosixEventLoop._run_oncec Cs@y |Wn0tk r:}z|d|iWdd}~XYnXdS)aN Run a task in the event loop. If it fails, print the exception. By default, the event loop is not supposed to exit if one fd callback raises an exception. Doing so, would leave many coroutines in a not cleaned-up state. If this happens, this is a bug, and we have to print the stack. Z exceptionN) BaseExceptionZcall_exception_handler)rr7er r r!r1s  zPosixEventLoop._run_taskcCs|j|}|S)zI Return the file descriptors that are ready for reading. )rselect)rZtimeoutr3r r r!r)s z!PosixEventLoop._ready_for_readingcsddkr dtjdfkr2t|}j|<n$fdd}t||}j|<j||S)z Register a signal handler. Call `handler` when `signal` was received. The given handler will always be called in the same thread as the eventloop. (Like `call_from_executor`.) NrcsdS)N)r2)a)r6rr r!call_signal_handlersz>PosixEventLoop.add_signal_handler..call_signal_handler)signalSIG_IGNrr0)rZsignumr6Zpreviousr=r )r6rr!add_signal_handlers    z!PosixEventLoop.add_signal_handlerFcCst||d}||j|jS)z Run a long running function in a background thread. (This is recommended for code that could block the event loop.) Similar to Twisted's ``deferToThread``. )Zdaemon)r r2startr&)rcallbackZ_daemonZthr r r!run_in_executors zPosixEventLoop.run_in_executorc Csj|dkst|tstt|}|j||f|jrfyt|jddWnt t t fk rdYnXdS)a Call this function in the main event loop. Similar to Twisted's ``callFromThread``. :param _max_postpone_until: `None` or `time.time` value. For internal use. If the eventloop is saturated, consider this task to be low priority and postpone maximum until this timestamp. (For instance, repaint is done using low priority.) Nrx) r"floatrr rr.rrwriteAttributeError IndexErrorOSError)rrBr,r r r!r2s z!PosixEventLoop.call_from_executorcCsP|jr td|_|j}d|_|rZtimebaserr&rr'rr;rrr Zutilsr contextr __all__r/r r r r r!s