MhdZddlZddlZddlZddlZddlZddlZddlZ ddlm Z m Z n#e $r ddl m Z m Z YnwxYwddl m Z mZddlmZddlmZGdd e ZdS) zJProvides an interface like pexpect.spawn interface using subprocess.Popen N)QueueEmpty) SpawnBasePY3)EOF) string_typescbeZdZ dfd ZdZdZdZd Zd Zd Z dd Z dZ dZ dZ xZS) PopenSpawnNstrictc tt||||||| |%tjd|_n$|tj|_tdtj tj tj || |} tj dkrAtj} | xjtjzc_| | d<tj| d<t%|t&r4tj dkr$t)j|tjdk }tj|fi| |_|jj|_d |_||_t9|_t=j|j |_!d |j!_"|j!#dS) N)timeoutmaxreadsearchwindowsizelogfileencoding codec_errorsasciir)bufsizestdinstderrstdoutcwd preexec_fnenvwin32 startupinfo creationflagsposix)r!F)targetT)$superr __init__oslinesepencodecrlf string_typedict subprocessPIPESTDOUTsysplatform STARTUPINFOdwFlagsSTARTF_USESHOWWINDOWCREATE_NEW_PROCESS_GROUP isinstancer shlexsplitnamePopenprocpidclosed_bufr _read_queue threadingThread_read_incoming _read_threaddaemonstart)selfcmdrrrrrrrrrkwargsr __class__s S/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/pexpect/popen_spawn.pyr$zPopenSpawn.__init__s j$(('!17!  ) > > >   ))733DII(("*55DIaz'.z*#??? <7 " "$022K   :#B B  $/F= !&0&IF? # c< ( ( =S\W-D-D+cG);<<|jj} d} tj|d}n-#t $r }||dYd}~nd}~wwxYw|s|jddS|j|)z6Run in a thread to move output from a pipe to a queue.rrIirNN) r9rfilenor%rNOSErrorrVr=put)rDr^rXes rHr@zPopenSpawn._read_incomingds!((** &C %gfd++ % % % !V$$$$$$$$ %  $$T***    % % % &s9 A#AA#c0||dS)zHThis is similar to send() except that there is no return value. Nsend)rDss rHwritezPopenSpawn.writeus ! rIc:|D]}||dS)zThis calls write() for each element in the sequence. The sequence can be any iterable object producing strings, typically a list of strings. This does not add line separators. There is no return value. Nrc)rDsequenceres rH writelineszPopenSpawn.writelineszs.  A IIaLLLL  rIc8||}||d|j|d}tr|jj|S|jj|t|S)zZSend data to the subprocess' stdin. Returns the number of bytes written. rdFrL) _coerce_send_stringrV_encoderr'rr9rrfrR)rDrebs rHrdzPopenSpawn.sends  $ $Q ' ' !V M % 0 0  9?((++ + IO ! !! $ $ $q66MrIcf||}|||jzS)zWraps send(), sending string ``s`` to child process, with os.linesep automatically appended. Returns number of bytes written. )rdr&)rDrens rHsendlinezPopenSpawn.sendlines, IIaLL499T\****rIc|j}|dkr||_d|_nd|_| |_d|_|S)zKWait for the subprocess to finish. Returns the exit code. rNT)r9wait exitstatus signalstatus terminated)rDstatuss rHrszPopenSpawn.waitsM !! Q;;$DO $D  "DO!'D  rIctjdkrZ|tjtjfvr tj}n3|tjtjfvr tj}n tj}tj |j j |dS)z}Sends a Unix signal to the subprocess. Use constants from the :mod:`signal` module to specify which signal. rN) r.r/signalSIGINT CTRL_C_EVENTSIGBREAKCTRL_BREAK_EVENTSIGTERMr%killr9r:)rDsigs rHrzPopenSpawn.killsr <7 " "v}f&9:::)&*ABBB-n  s#####rIcB|jjdS)z+Closes the stdin pipe from the writing end.N)r9rclose)rDs rHsendeofzPopenSpawn.sendeofs rI) r r NNNNNrN)rn)__name__ __module__ __qualname__r$rOr\r@rfrirdrqrsrr __classcell__)rGs@rHr r sGK<@37("("("("("("T!!!F&&&" "++++    $ $ $       rIr )__doc__r%r>r+r.rQryr5queuerr ImportError spawnbaserr exceptionsrutilsr r rIrHrs)  #"""""""""###""""""""""#&%%%%%%%h h h h h h h h h h s ) 99