HEX

File: //usr/lib/python3.6/site-packages/pexpect/__pycache__/popen_spawn.cpython-36.pyc
3


.�]!�@s�dZddlZddlZddlZddlZddlZddlZddlZyddlm	Z	m
Z
Wn$ek
rtddl	m	Z	m
Z
YnXddlm
Z
mZddlmZddlmZGdd	�d	e
�ZdS)
zJProvides an interface like pexpect.spawn interface using subprocess.Popen
�N)�Queue�Empty�)�	SpawnBase�PY3)�EOF)�string_typescs�eZdZerdjd�ZndZd�fdd�	Zd	Zd
d�Zdd
�Z	dd�Z
dd�Zdd�Zddd�Z
dd�Zdd�Zdd�Z�ZS)�
PopenSpawn�
�ascii���N�strictc
s�tt|�j||||||	d�tdtjtjtj||d�}
tjdkrjtj	�}|j
tjO_
||
d<tj|
d<t
|t�r�tjdkr�tj|tjdkd�}tj|f|
�|_|jj|_d	|_|j�|_t�|_tj|jd
�|_|jjd�|jj �dS)N)�timeout�maxread�searchwindowsize�logfile�encoding�codec_errorsr)�bufsize�stdin�stderr�stdout�cwd�env�win32�startupinfoZ
creationflags�posix)rF)�targetT)!�superr	�__init__�dict�
subprocess�PIPEZSTDOUT�sys�platformZSTARTUPINFOZdwFlagsZSTARTF_USESHOWWINDOWZCREATE_NEW_PROCESS_GROUP�
isinstancer�shlex�split�os�name�Popen�proc�pid�closedZstring_type�_bufr�_read_queue�	threadingZThread�_read_incomingZ_read_threadZ	setDaemon�start)�self�cmdrrrrrrrr�kwargsr)�	__class__��!/usr/lib/python3.6/popen_spawn.pyr s*





zPopenSpawn.__init__Fc
Cs�|j}|jr8|r*||d�|_|d|�Sd|_td��|dkrH|j}n|dkrTd}tj�}xntj�||kr�|r�t|�|kr�y|jj�}Wnt	k
r�PYq^X|dkr�d|_P||j
j|dd�7}q^W|d|�||d�}|_|j|d�|S)	NTzEnd Of File (EOF).rg��.AF)�final�read���)
r/�_read_reached_eofZflag_eofrr�time�lenr0Z
get_nowaitrZ_decoder�decode�_log)r4�sizer�bufZt0Zincoming�rr8r8r9�read_nonblocking:s0"zPopenSpawn.read_nonblockingcCsz|jjj�}xhd}ytj|d�}Wn.tk
rP}z|j|d�WYdd}~XnX|sf|jjd�dS|jj|�qWdS)z6Run in a thread to move output from a pipe to a queue.�ir;N)	r,r�filenor)r;�OSErrorrAr0Zput)r4rGrC�er8r8r9r2]szPopenSpawn._read_incomingcCs|j|�dS)zHThis is similar to send() except that there is no return value.
        N)�send)r4�sr8r8r9�writenszPopenSpawn.writecCsx|D]}|j|�qWdS)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)rJ)r4ZsequencerKr8r8r9�
writelinesss
zPopenSpawn.writelinescCsR|j|�}|j|d�|jj|dd�}tr8|jjj|�S|jjj|�t|�SdS)zbSend data to the subprocess' stdin.
        
        Returns the number of bytes written.
        rJF)r:N)	Z_coerce_send_stringrAZ_encoder�encoderr,rrLr?)r4rK�br8r8r9rJ}s
zPopenSpawn.send�cCs|j|�}||j|j�S)z�Wraps send(), sending string ``s`` to child process, with os.linesep
        automatically appended. Returns number of bytes written. )rJ�linesep)r4rK�nr8r8r9�sendline�s
zPopenSpawn.sendlinecCs8|jj�}|dkr ||_d|_nd|_||_d|_|S)zSWait for the subprocess to finish.
        
        Returns the exit code.
        rNT)r,�waitZ
exitstatusZsignalstatusZ
terminated)r4Zstatusr8r8r9rT�s
zPopenSpawn.waitcCsTtjdkr@|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.
        rN)r$r%�signal�SIGINTZCTRL_C_EVENTZSIGBREAKZCTRL_BREAK_EVENT�SIGTERMr)�killr,r-)r4Zsigr8r8r9rX�s
zPopenSpawn.killcCs|jjj�dS)z+Closes the stdin pipe from the writing end.N)r,r�close)r4r8r8r9�sendeof�szPopenSpawn.sendeof)rr
NNNNNr)rP)�__name__�
__module__�__qualname__rrNZcrlfr r=rEr2rLrMrJrSrTrXrZ�
__classcell__r8r8)r7r9r	s #

r	)�__doc__r)r1r"r$r>rUr'Zqueuerr�ImportErrorZ	spawnbaserr�
exceptionsrZutilsrr	r8r8r8r9�<module>s