4dZddlmZddlmZddlmZddlmZm Z ddl m Z dd l m Z dd lmZmZdd lmZmZmZdd lZdd lZd ZdZede zZGddeZddZdZy )zg Win32 event loop. Windows notes: - Somehow it doesn't seem to work with the 'ProactorEventLoop'. )unicode_literals)ConsoleInputReader)SECURITY_ATTRIBUTES) EventLoop INPUT_TIMEOUT)InputHookContext)TimeIt)windllpointer)DWORDBOOLHANDLEN)Win32EventLoopicReZdZdZd dZdZddZdZdZdZ dd Z d Z d Z d Z y)rz Event loop for Windows systems. :param recognize_paste: When True, try to discover paste actions and turn the event into a BracketedPaste. Nc| t|sJt|_t||_g|_d|_d|_i|_|rt||_ yd|_ y)N)recognize_pasteF) callable _create_event_eventr_console_input_reader_calls_from_executorclosed_running _read_fdsr _inputhook_context)self inputhookrs 1lib/third_party/prompt_toolkit/eventloop/win32.py__init__zWin32EventLoop.__init__$sf HY$777#o %7%X"$&!  BK"29"=PTcB jr tdt d_jr_t 5}j r! fd}j j |ddd dk(rd}n%td tdjzz }j|}|jjk(r9jj}|D]}|j|t n|jk(r:t j"j%jj'n7|j(vrj(|} | n|j+d jr^yy#1swY*xYw)NzEvent loop already closed.TcPtj|r SdS)zF True when there is input ready. The inputhook should return control. r)bool_ready_for_reading)waitcurrent_timeoutrs r!readyz!Win32EventLoop.run..ready?s'#D$;$;tO$[\\YZ$[\\r#rr)r ExceptionINPUT_TIMEOUT_MSrr rcall_inputhookmaxintdurationr'rhandlereadfeed_keyrr kernel32 ResetEvent#_process_queued_calls_from_executorr input_timeout) rstdin callbacksinputhook_timerr*remaining_timeoutr2keyskcallbackr)s ` @r!runzWin32EventLoop.run4sT ;;89 9* mm_**]++::5A "$$&!$'?SH`H`A`=a+a$b!,,->?F33:::11668A&&q)"24;;&**4;;788:4>>)>>&1 '')"$Imms .FFc|j|jjg}|j|jj t ||S)zS Return the handle that is ready for reading or `None` on timeout. )rrr2extendrr=_wait_for_handles)rtimeouthandless r!r'z!Win32EventLoop._ready_for_readingasD;; : : A ABt~~**,- '22r#cd|_y)NF)rrs r!stopzWin32EventLoop.stopis  r#cd|_tjj|j|j r|j j |jj yNT)rr r5 CloseHandlerrcloserrGs r!rLzWin32EventLoop.closelsN  ##DKK0  " "  # # ) ) + ""((*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) threadingThreadstart)r?sr!start_executorz6Win32EventLoop.run_in_executor..start_executors   H - 3 3 5r#N)call_from_executor)rr?rSs ` r!run_in_executorzWin32EventLoop.run_in_executorws 6 /r#c|jj|tjj |j y)zm Call this function in the main event loop. Similar to Twisted's ``callFromThread``. N)rappendr r5SetEventr)rr?_max_postpone_untils r!rTz!Win32EventLoop.call_from_executors0 !!((2   -r#cH|jgc}|_|D] }| yN)r)rcalls_from_executorcs r!r7z2Win32EventLoop._process_queued_calls_from_executors(9=9R9RTV6T6$A C%r#cLtj|}||j|<y)z; Start watching the file descriptor for read availability. Nmsvcrt get_osfhandler)rfdr?hs r! add_readerzWin32EventLoop.add_readers   $$qr#cftj|}||jvr|j|=yy)z: Stop watching the file descriptor for read availability. Nr_)rrbrcs r! remove_readerzWin32EventLoop.remove_readers/   $  q! r#rJr[)__name__ __module__ __qualname____doc__r"r@r'rHrLrUrTr7rdrfr#r!rrs; U +%Z3 + 0 . % "r#rctt|z}||}tjj t||t dt |}|tk(ry||}|S)z Waits for multiple handles. (Similar to 'select') Returns the handle which is ready. Returns `None` on timeout. http://msdn.microsoft.com/en-us/library/windows/desktop/ms687025(v=vs.85).aspx FN)rlenr r5WaitForMultipleObjectsrr WAIT_TIMEOUT)rErDarrtype handle_arrayretrcs r!rCrCscs7|#GG$L // 0 0 L<eeGn FC l  r#ctjjtt t dt ddS)z} Creates a Win32 unnamed Event . http://msdn.microsoft.com/en-us/library/windows/desktop/ms682396(v=vs.85).aspx TFN)r r5 CreateEventAr rrrkr#r!rrs4 ?? ' '0C0E(FT TXY^T_ae ffr#)r+)rj __future__rterminal.win32_inputr win32_typesrbaserr r r utilsr ctypesr r ctypes.wintypesrrrr`rP__all__ror0r-rrCrrkr#r!r}se (5-*'"//   tm+,A"YA"H(gr#