File: //usr/local/lib/python3.6/site-packages/pexpect/__pycache__/popen_spawn.cpython-36.pyc
3
��Zd � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZyddlm Z m
Z
W n$ e k
rt ddl m Z m
Z
Y nX ddl m
Z
mZ ddlmZ ddlmZ G dd � d e
�ZdS )
zJProvides an interface like pexpect.spawn interface using subprocess.Popen
� N)�Queue�Empty� )� SpawnBase�PY3)�EOF)� string_typesc sl e Zd Zd� fdd� ZdZdd � Zd
d � Zd d
� Zdd� Zdd� Z d dd�Z
dd� Z dd� Z dd� Z
� ZS ) �
PopenSpawn� �� N�strictc
s t t| �j|||||| d� |d kr4tjjd�| _n| jtj�| _tdt j
t j t j
||
|d�} t j
dkr�t j� } | jt jO _| | d< t j| d< t|t�r�t j
dkr�tj|tjdkd �}t j|f| �| _| jj| _d
| _| j� | _t � | _ t j | j d �| _!| j!j"d � | j!j#� d S )
N)�timeout�maxread�searchwindowsize�logfile�encoding� codec_errors�asciir )�bufsize�stdin�stderr�stdout�cwd�
preexec_fn�env�win32� startupinfo�
creationflags�posix)r F)�targetT)$�superr �__init__�os�linesep�encodeZcrlfZ string_type�dict�
subprocess�PIPE�STDOUT�sys�platformZ STARTUPINFOZdwFlagsZSTARTF_USESHOWWINDOWZCREATE_NEW_PROCESS_GROUP�
isinstancer �shlex�split�name�Popen�proc�pid�closed�_bufr � _read_queue� threading�Thread�_read_incomingZ _read_thread� setDaemon�start)
�self�cmdr
r r r r r r r r �kwargsr )� __class__� �6/tmp/pip-build-hc5bmb4z/pexpect/pexpect/popen_spawn.pyr! s0
zPopenSpawn.__init__Fc
C s� | j }| jr8|r*||d � | _ |d |� S d| _td��|dkrH| j}n |d krTd}tj� }xntj� | |k r�|r�t|�|k r�y| jj� }W n t k
r� P Y q^X |d kr�d| _P || j
j |dd�7 }q^W |d |� ||d � }| _ | j |d� |S ) NTzEnd Of File (EOF).r g ��.AF)�final�read���)
r3 �_read_reached_eofZflag_eofr r
�time�lenr4 �
get_nowaitr �_decoder�decode�_log)r: �sizer
�buf�t0�incoming�rr> r> r? �read_nonblockingA s0 " zPopenSpawn.read_nonblockingc C sz | j jj� }xhd}ytj|d�}W n. tk
rP } z| j|d� W Y dd}~X nX |sf| jjd� dS | jj|� qW dS )z6Run in a thread to move output from a pipe to a queue.� i rA N) r0 r �filenor" rA �OSErrorrI r4 �put)r: rQ rK �er> r> r? r7 d s zPopenSpawn._read_incomingc C s | j |� dS )zHThis is similar to send() except that there is no return value.
N)�send)r: �sr> r> r? �writeu s zPopenSpawn.writec C s x|D ]}| j |� qW dS )z�This 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: �sequencerV r> r> r? �
writelinesz s
zPopenSpawn.writelinesc C sR | j |�}| j|d� | jj|dd�}tr8| jjj|�S | jjj|� t|�S dS )zZSend data to the subprocess' stdin.
Returns the number of bytes written.
rU F)r@ N) Z_coerce_send_stringrI �_encoderr$ r r0 r rW rE )r: rV �br> r> r? rU � s
zPopenSpawn.send� c C s | j |�}|| j | j� S )z�Wraps send(), sending string ``s`` to child process, with os.linesep
automatically appended. Returns number of bytes written. )rU r# )r: rV �nr> r> r? �sendline� s
zPopenSpawn.sendlinec C s8 | j j� }|dkr || _d| _nd| _| | _d| _|S )zKWait for the subprocess to finish.
Returns the exit code.
r NT)r0 �waitZ
exitstatusZ signalstatusZ
terminated)r: �statusr> r> r? r_ � s
zPopenSpawn.waitc C sT t jdkr@|tjtjgkr"tj}n |tjtjgkr:tj}ntj}tj | j
j |� dS )z}Sends a Unix signal to the subprocess.
Use constants from the :mod:`signal` module to specify which signal.
r N) r) r* �signal�SIGINTZ CTRL_C_EVENTZSIGBREAKZCTRL_BREAK_EVENT�SIGTERMr" �killr0 r1 )r: �sigr> r> r? rd � s
zPopenSpawn.killc C s | j jj� dS )z+Closes the stdin pipe from the writing end.N)r0 r �close)r: r> r> r? �sendeof� s zPopenSpawn.sendeof) r
r NNNNNr N)r\ )�__name__�
__module__� __qualname__r! rC rO r7 rW rY rU r^ r_ rd rg �
__classcell__r> r> )r= r? r s (#
r )�__doc__r" r5 r& r) rD ra r, �queuer r � ImportErrorZ spawnbaser r �
exceptionsr �utilsr r r> r> r> r? �<module> s