o 6Zh8: @sdZddlmZdZgdZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZmZmZddlmZdd lmZz dd lmZmZWn eyid Zd ZYnwedZd dZdZZzej !edZej !edZWn(e"yzej !edZej !edZWne"ye\ZZYnwYnwdZ#dZ$e%e j&ddpdZ'e'(dkrdZ'd+ddZ)eddZ*GdddZ+ee$e$e'dfddZ,e'dfd d!Z-da.e /Z0e'dfd"d#Z1d$d%Z2d&a3d'd(Z4d)d*Z5dS),zhCapture C-level FD output on pipes Use `wurlitzer.pipes` or `wurlitzer.sys_pipes` as context managers. )print_functionz3.0.2)pipes sys_pipessys_pipes_foreverstop_sys_pipes WurlitzerN)contextmanager)F_GETFLF_SETFLfcntl) lru_cache)Queue) F_GETPIPE_SZ F_SETPIPE_SZiic Cszddl}Wn tytdwz+|}|d|d|dgd}t|}t| }W||fSt yX}zt d |WYd}~d Sd}~ww) zeUse CFFI to lookup stdout/stderr pointers Should work ~everywhere, but requires compilation rNz@Failed to lookup stdout symbols in libc. Fallback requires cffi.zconst size_t c_stdout_p();zconst size_t c_stderr_p(); )z#include z=const size_t c_stdout_p() { return (size_t) (void*) stdout; }z=const size_t c_stderr_p() { return (size_t) (void*) stderr; }zBFailed to lookup stdout with cffi: {}. Streams may not be flushed.)NN)cffi ImportErrorZFFIZcdefverifyjoinctypesc_void_p c_stdout_p c_stderr_p Exceptionwarningswarnformat)rZ_ffiZ_librrer@/var/www/html/lang_env/lib/python3.10/site-packages/wurlitzer.py_get_streams_cffi*s8      r stdoutstderrZ __stdoutpZ __stderrpencodingutf8asciic Cszd}ttd|D],}z t||WSty6}z|}|jtjkr+tdnWYd}~q d}~ww|r;|dS)z Like os.dup2, but retry on EBUSYN g?) rangeintosdup2OSErrorerrnoZEBUSYtimesleep)abtimeoutZdup_errirrrrr,fs   r,cCs|tdkrdSztdd}t|}Wdn1swYWn ty/YdSw|dkr6dS|dkr.flush_main)targetTc s$d}d}t}D] }||tjq r|||}|r d}n |r#nYdj}q|D]H\}}|j}|jkrOd} j| jt jq.|}t |d} | sk || |t |q.td|} | | q.sznsddd D| d S) z*Forward bytes on a pipe to stream messagesFrrcTiz _handle_%srgcSsg|]}t|qSr)r+rO).0rMrrr Ysz:Wurlitzer.__enter__..forwarder..N) selectorsDefaultSelectorregister EVENT_READselectputflush_intervalfd _control_rremove unregisterr+rOr:rIr) ZdrainingruZpollerZpipe_eventsZ selector_keyrTrvrQrYhandlerrjZ flush_threadnamesrrFrr forwarder$sJ             ) z&Wurlitzer.__enter__..forwarder)rerar+rMrw _control_wr=rUappendr?r threadingThreaddaemonstartthreadr_)rFrMrkr~rr|r __enter__s.      8 zWurlitzer.__enter__cCsj|t|jd|jt|j|jD]\}}|j |}t ||t|q| dS)N) rer+r]rrrrOrBitemsrAr,rb)rFexc_type exc_value tracebackrQrRrSrrr__exit__bs      zWurlitzer.__exit__)__name__ __module__ __qualname____doc__ru_default_encodingr<rHrUrZrErDrarbrerrrrrrrs" $  `rc csd}}|r tj}ntj}|tkr|}}d}n|}}|tkr'd} |} n|tkr3|} } d}n|} } t|| ||d} z*| || fVWdn1sRwYW|r_|d|rh| ddSdS|rq|d|ry| dww)ahCapture C-level stdout/stderr in a context manager. The return value for the context manager is (stdout, stderr). .. versionchanged:: 3.0 when using `PIPE` (default), the type of captured output is `io.StringIO/BytesIO` instead of an OS pipe. This eliminates max buffer size issues (and hang when output exceeds 65536 bytes), but also means the buffer cannot be read with `.read()` methods until after the context exits. Examples -------- >>> with capture() as (stdout, stderr): ... printf("C-level stdout") ... output = stdout.read() FTN)r!r"r%rGr)ioStringIOBytesIOPIPEr>rseek) r!r"r%rGZ stdout_pipeZ stderr_pipeZPipeIOZstdout_rZstdout_wZstderr_rZstderr_wwrrrrts@      rcCsttjtj||dS)zRedirect C-level stdout/stderr to sys.stdout/stderr This is useful of sys.sdout/stderr are already being forwarded somewhere. DO NOT USE THIS if sys.stdout and sys.stderr are not already being forwarded. r%rG)rrJr!r"rrrrrsrcCsTttdurt||atWddSWddS1s#wYdS)zvRedirect all C output to sys.stdout/err This is not a context manager; it turns on C-forwarding permanently. N) _mighty_lock_mighty_wurlitzerrrrrrrrs  "rcCsTttdurtddddaWddSWddS1s#wYdS)z7Stop permanent redirection started by sys_pipes_foreverN)rrrrrrrrs"rFcCsft|dds tddSdD]}tt|dur tddSq|jdt|jdtdadS) zRegister me as an IPython extension Captures all C output during execution and forwards to sys. Does nothing on terminal IPython. Use: %load_ext wurlitzer ZkernelNz;wurlitzer extension doesn't do anything in terminal IPython) __stdout__ __stderr__z:sys.{} is None. Wurlitzer can't capture output without it. pre_execute post_executeT) rIrrrJrzrqrr_extension_enabled)iprQrrrload_ipython_extensions  rcCs2tsdS|jdt|jdttdadS)zFUnload me as an IPython extension Use: %unload_ext wurlitzer NrrF)rrzryrr)rrrrunload_ipython_extensions r)r$)6r __future__r __version____all__rr.rr+r7rorJrr/r contextlibrr r r functoolsr queuer rrrCDLLrdr rrrZin_dll ValueErrorr>rrIstdinrlowerr,r<rrrrLockrrrrrrrrrrsv      &      "[6