o !^@sdZddlZddlZddlZddlZddlZddlZddlZz ddlm Z m Z Wne y9ddl m Z m Z Ynwddl m Z mZddlmZddlmZGdd d e ZdS) zJProvides an interface like pexpect.spawn interface using subprocess.Popen N)QueueEmpty) SpawnBasePY3)EOF) string_typescsreZdZ   dfdd ZdZdd Zd d Zd d ZddZddZ dddZ ddZ ddZ ddZ ZS) PopenSpawnNstrictc stt|j|||||| d|durtjd|_n|tj|_tdt j t j t j || |d} t j dkrIt } | jt jO_| | d<t j| d<t|tr]t j dkr]tj|tjdkd }t j|fi| |_|jj|_d |_||_t|_tj|j d |_!|j!"d |j!#dS) N)timeoutmaxreadsearchwindowsizelogfileencoding codec_errorsasciir)bufsizestdinstderrstdoutcwd preexec_fnenvwin32 startupinfo creationflagsposix)rF)targetT)$superr __init__oslinesepencodecrlf string_typedict subprocessPIPESTDOUTsysplatform STARTUPINFOdwFlagsSTARTF_USESHOWWINDOWCREATE_NEW_PROCESS_GROUP isinstancershlexsplitnamePopenprocpidclosed_bufr _read_queue threadingThread_read_incoming _read_thread setDaemonstart) selfcmdr rrrrrrrrkwargsr __class__5/usr/lib/python3/dist-packages/pexpect/popen_spawn.pyr!s4      zPopenSpawn.__init__FcCs|j}|jr|r||d|_|d|Sd|_td|dkr$|j}n|dur*d}t}t||krq|rqt||krqz|j}Wn t yNYn#w|durWd|_n||j j |dd7}t||krq|rqt||ks>|d|||d}|_| |d|S)NTzEnd Of File (EOF).g.AFfinalread) r9_read_reached_eofflag_eofrr timelenr: get_nowaitr_decoderdecode_log)rAsizer buft0incomingrrFrFrGread_nonblockingAs4     zPopenSpawn.read_nonblockingc Csv|jj} d}zt|d}Wnty)}z ||dWYd}~nd}~ww|s4|jddS|j|q)z6Run in a thread to move output from a pipe to a queue.rirKN) r6rfilenor"rKOSErrorrSr:put)rAr[rUerFrFrGr=ds   zPopenSpawn._read_incomingcCs||dS)zHThis is similar to send() except that there is no return value. Nsend)rAsrFrFrGwriteuszPopenSpawn.writecCs|D]}||qdS)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. Nr_)rAsequencerarFrFrG writelineszs zPopenSpawn.writelinescCsN||}||d|jj|dd}tr|jj|S|jj|t|S)zZSend data to the subprocess' stdin. Returns the number of bytes written. r`FrI) _coerce_send_stringrS_encoderr$rr6rrbrO)rArabrFrFrGr`s  zPopenSpawn.sendcCs||}|||jS)zWraps send(), sending string ``s`` to child process, with os.linesep automatically appended. Returns number of bytes written. )r`r#)rAranrFrFrGsendlines zPopenSpawn.sendlinecCs8|j}|dkr||_d|_nd|_| |_d|_|S)zKWait for the subprocess to finish. Returns the exit code. rNT)r6wait exitstatus signalstatus terminated)rAstatusrFrFrGrks zPopenSpawn.waitcCsTtjdkr |tjtjfvrtj}n|tjtjfvrtj}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,signalSIGINT CTRL_C_EVENTSIGBREAKCTRL_BREAK_EVENTSIGTERMr"killr6r7)rAsigrFrFrGrvs zPopenSpawn.killcCs|jjdS)z+Closes the stdin pipe from the writing end.N)r6rclose)rArFrFrGsendeofszPopenSpawn.sendeof) r r NNNNNr N)rh)__name__ __module__ __qualname__r!rLrYr=rbrdr`rjrkrvry __classcell__rFrFrDrGr s*# r )__doc__r"r;r(r+rNrpr2queuerr ImportError spawnbaserr exceptionsrutilsrr rFrFrFrGs"