e/ddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z ddl mZddlmZmZddlmZdd lmZdd lmZdd lmZdd lmZmZmZd ZejZGddeZ Gdde!Z"y))unicode_literalsN) InputStream) DummyContextin_main_thread)Input) EventLoop INPUT_TIMEOUT)EventLoopCallbacks)InputHookContext)PosixStdinReader)TimeIt) AutoSelectorSelector fd_to_int)PosixEventLoopcVeZdZdZdefdZdZd dZdZdZ d dZ d Z d Z d Z d Zy)rz9 Event loop for posix systems (Linux, Mac os X). Nc| t|sJt|tsJd|_d|_d|_d|_g|_i|_||_ tj|_ tj|jdtjtj|rt!||_yd|_y)NFr)callable issubclassrrunningclosed_running _callbacks_calls_from_executor _read_fdsselectorospipe_schedule_pipefcntlF_SETFL O_NONBLOCKr _inputhook_context)self inputhookrs 1lib/third_party/prompt_toolkit/eventloop/posix.py__init__zPosixEventLoop.__init__s HY$777(H---   $&!  !ggi D''*EMM2==IBK"29"=PTct|tsJt|tsJjrJjr t dd_|_t|jtgt|jtrtj}n t}fd}j!||j!j"dd|5jrj$rAt'5}fd}j$j)|dddj*}nd}dd}nt-dd|z }j/|} | rCg} g} d} | D]} | j"dk(rj0D]Q\}}|| j3|| xs t5} || kr| j3|?| j3||fSg_t7j8j"ddj:j=| }|s| j3|t?j@| t?j@| | r,| D] }| | D]\}}jC||n7| D] \}}|n%jE|jGdd<jrdddjI|jIj"dd_y#1swYxYw#1swYMxYw) z) The input 'event loop'. zEvent loop already closed.Tcj}j|td<jrj yy)z Read user input. rN)readfeedr rstop)datacurrent_timeout inputstreamr% stdin_readers r'read_from_stdinz+PosixEventLoop.run..read_from_stdinOsF $$&D   T ""/OA "" #r)rNcHj|r dgk7Sdgk7S)zF True when there is input ready. The inputhook should return control. r)_ready_for_reading)waitr0r%s r'readyz!PosixEventLoop.run..readyds1#'#:#:QU?1;M#]ac#cc[\#]ac#ccr)i)_max_postpone_until)% isinstancerr rr Exceptionrrfeed_keyr r filenorcall_on_sigwinchreceived_winchr add_readerr r$rcall_inputhookdurationmaxr5rappend_nowrr,rgetrandomshufflecall_from_executorflush input_timeout remove_reader)r%stdin callbacksctxr3inputhook_timerr7inputhook_durationremaining_timeoutfdstaskslow_priority_tasksnowfdcmax_postpone_untilhandlert_r0r1r2s` @@@r'runzPosixEventLoop.run2s%''')%7888==  ;;89 9 #!)"4"45 (/( 7  "4#6#67C.C  / ++A.5 --**_d//>>uE " *9)A)A&)*&#1%-(,%(+Aq/ADV/V(W%--.?@E)+&C!!4!4Q!779=9R9R 5#5#5#=$)LLO+.-C'9C'?(- Q(:(A(A1FXBY(Z:S9;D5GGD$7$7$:DA&*nn&8&8&.process_winchs557r)NrH)r%res` r'r>zPosixEventLoop.received_winchs 8  .r)c2fd}|j|y)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``. cNtjjy)N)target) threadingThreadstartcallbacksr'start_executorz6PosixEventLoop.run_in_executor..start_executors   H - 3 3 5r)Nrf)r%rnros ` r'run_in_executorzPosixEventLoop.run_in_executors 6 /r)c|t|tsJ|jj||f|jr% t j |jddyy#tttf$rYywxYw)a Call this function in the main event loop. Similar to Twisted's ``callFromThread``. :param _max_postpone_until: `None` or `time.time` value. For interal 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) r9floatrrCr rwriteAttributeError IndexErrorOSError)r%rnr8s r'rHz!PosixEventLoop.call_from_executors}#*j9Le.TTT !!(((4G)HI    ,,Q/6 #J8    s#A$$A;:A;cd|_y)z& Stop the event loop. FN)rrds r'r.zPosixEventLoop.stops  r)cd|_|j}d|_|r0tj|dtj|d|jr|jjyy)NTrr)rr rcloser$)r% schedule_pipes r'rzzPosixEventLoop.closesc ++ "  HH]1% & HH]1% &  " "  # # ) ) + #r)cnt|}||j|<|jj|y)z- Add read file descriptor to the event loop. N)rrrregister)r%rVrns r'r?zPosixEventLoop.add_readers+ r]%r r"r)ct|}||jvr |j|=|jj|y)z2 Remove read file descriptor from the event loop. N)rrr unregister)r%rVs r'rKzPosixEventLoop.remove_readers5 r]  r"   $r)rb)__name__ __module__ __qualname____doc__rr(r\r5r>rprHr.rzr?rKr)r'rrsC"& U(IV/$0&. ,# %r)rc"eZdZdZdZdZdZy)r=zv Context manager which Installs a SIGWINCH callback. (This signal occurs when the terminal size changes.) c ||_d|_yrb)rnprevious_callback)r%rns r'r(zcall_on_sigwinch.__init__)s  !%r)c^tjtjfd_y)Nc$jSrbrm)ar%s r'z,call_on_sigwinch.__enter__...s 4==?r))signalSIGWINCHrrds`r' __enter__zcall_on_sigwinch.__enter__-s!'v@Z![r)c|j%tjtjdytjtj|jy)Nr)rrr)r%rkws r'__exit__zcall_on_sigwinch.__exit__0s:  ! ! ) MM&//1 - MM&//4+A+A Br)N)rrrrr(rrrr)r'r=r=$s&\Cr)r=)# __future__rr!rrFrrjtime#prompt_toolkit.terminal.vt100_inputrprompt_toolkit.utilsrrprompt_toolkit.inputrbaser r rMr r&r posix_utilsr utilsrr^rrr__all__rDrobjectr=rr)r'rsg'  ;=&*)')55  yyG%YG%TCvCr)