B +d@sdZddlZddlZddlZddlZddlZddlZddlZyddlm Z m Z Wn$e k rtddl m Z m Z YnXddl m Z mZddlmZddlmZGdd d e ZdS) zJProvides an interface like pexpect.spawn interface using subprocess.Popen N)QueueEmpty) SpawnBasePY3)EOF) string_typesc sleZdZdfdd ZdZdd Zd d Zd d ZddZddZ dddZ ddZ ddZ ddZ ZS) PopenSpawnNstrictc stt|j|||||| d|dkr4tjd|_n|tj|_tdt j t j t j || |d} t j dkrt } | jt jO_| | d<t j| d<t|trt j dkrtj|tjdkd }t j|f| |_|jj|_d |_||_t|_tj|j d |_!|j!"d |j!#dS) N)timeoutmaxreadsearchwindowsizelogfileencoding codec_errorsasciir)bufsizestdinstderrstdoutcwd preexec_fnenvwin32 startupinfo creationflagsposix)rF)targetT)$superr __init__oslinesepencodeZcrlfZ string_typedict subprocessPIPESTDOUTsysplatformZ STARTUPINFOZdwFlagsZSTARTF_USESHOWWINDOWZCREATE_NEW_PROCESS_GROUP isinstancershlexsplitnamePopenprocpidclosed_bufr _read_queue threadingThread_read_incomingZ _read_thread setDaemonstart) selfcmdr rrrrrrrrkwargsr) __class__`/work/yifan.wang/ringdown/master-ringdown-env/lib/python3.7/site-packages/pexpect/popen_spawn.pyr!s0       zPopenSpawn.__init__FcCs|j}|jr8|r*||d|_|d|Sd|_td|dkrH|j}n |dkrTd}t}xnt||kr|rt||kry|j}Wnt k rPYq^X|dkrd|_P||j j |dd7}q^W|d|||d}|_| |d|S)NTzEnd Of File (EOF).g.AF)finalread) r3_read_reached_eofZflag_eofrr timelenr4 get_nowaitr_decoderdecode_log)r:sizer buft0incomingrr>r>r?read_nonblockingAs0 " zPopenSpawn.read_nonblockingc Csz|jj}xhd}yt|d}Wn.tk rP}z||dWdd}~XYnX|sf|jddS|j|qWdS)z6Run in a thread to move output from a pipe to a queue.irBN) r0rfilenor"rBOSErrorrIr4put)r:rQrKer>r>r?r7ds  zPopenSpawn._read_incomingcCs||dS)zHThis is similar to send() except that there is no return value. N)send)r:sr>r>r?writeuszPopenSpawn.writecCsx|D]}||qWdS)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. N)rU)r:sequencerVr>r>r? writelineszs zPopenSpawn.writelinescCsR||}||d|jj|dd}tr8|jj|S|jj|t|SdS)zZSend data to the subprocess' stdin. Returns the number of bytes written. rUF)rAN) Z_coerce_send_stringrI_encoderr$rr0rrWrE)r:rVbr>r>r?rUs  zPopenSpawn.sendcCs||}|||jS)zWraps send(), sending string ``s`` to child process, with os.linesep automatically appended. Returns number of bytes written. )rUr#)r:rVnr>r>r?sendlines zPopenSpawn.sendlinecCs8|j}|dkr ||_d|_nd|_| |_d|_|S)zKWait for the subprocess to finish. Returns the exit code. rNT)r0waitZ exitstatusZ signalstatusZ terminated)r:statusr>r>r?r_s zPopenSpawn.waitcCsTtjdkr@|tjtjgkr"tj}n|tjtjgkr:tj}ntj}t |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*signalSIGINTZ CTRL_C_EVENTZSIGBREAKZCTRL_BREAK_EVENTSIGTERMr"killr0r1)r:sigr>r>r?rds zPopenSpawn.killcCs|jjdS)z+Closes the stdin pipe from the writing end.N)r0rclose)r:r>r>r?sendeofszPopenSpawn.sendeof) r r NNNNNr N)r\)__name__ __module__ __qualname__r!rCrOr7rWrYrUr^r_rdrg __classcell__r>r>)r=r?r s(#  r )__doc__r"r5r&r)rDrar,queuerr ImportErrorZ spawnbaserr exceptionsrutilsrr r>r>r>r?s