File: //lib/python3.9/site-packages/pexpect/__pycache__/popen_spawn.cpython-39.pyc
a
��!^ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZzddlm Z m
Z
W n" e yr ddl m Z m
Z
Y n0 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 u r4tj�d�| _n| �tj�| _tdt j
t j t j
||
|d�} t j
dkr�t �� } | jt jO _| | d< t j| d< t|t�r�t j
dkr�tj|tjdkd �}t j|fi | ��| _| jj| _d
| _| �� | _t � | _ t j | j d �| _!| j!�"d � | j!�#� d S )
N)�timeout�maxread�searchwindowsize�logfile�encoding� codec_errors�asciir )�bufsize�stdin�stderr�stdout�cwd�
preexec_fn�env�win32� startupinfoZ
creationflags�posix)r F)�targetT)$�superr �__init__�os�linesep�encodeZcrlfZ string_type�dict�
subprocess�PIPEZSTDOUT�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__� �7/usr/lib/python3.9/site-packages/pexpect/popen_spawn.pyr s4 � �
zPopenSpawn.__init__Fc C s� | j }| jr8|r*||d � | _ |d |� S d| _td��|dkrH| j}n |d u rTd}t�� }t�� | |k r�|r�t|�|k r�z| j�� }W n t y� Y q�Y q\0 |d u r�d| _q�|| j
j |dd�7 }q\|d |� ||d � }| _ | � |d� |S )NTzEnd Of File (EOF).���g ��.AF��final�read)
r1 �_read_reached_eofZflag_eofr r
�time�lenr2 Z
get_nowaitr Z_decoder�decode�_log)r8 �sizer
�bufZt0Zincoming�rr= r= r> �read_nonblockingA s0
zPopenSpawn.read_nonblockingc
C sx | j j�� }d}zt�|d�}W n0 tyP } z| �|d� W Y d}~n
d}~0 0 |sf| j�d� dS | j�|� q dS )z6Run in a thread to move output from a pipe to a queue.� i rB N) r. r �filenor! rB �OSErrorrG r2 Zput)r8 rM rI �er= r= r> r5 d s " zPopenSpawn._read_incomingc C s | � |� dS )zHThis is similar to send() except that there is no return value.
N��send)r8 �sr= r= r> �writeu s zPopenSpawn.writec C s |D ]}| � |� qdS )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.
NrP )r8 ZsequencerR r= r= r> �
writelinesz s zPopenSpawn.writelinesc C sR | � |�}| �|d� | jj|dd�}tr8| jj�|�S | jj�|� t|�S dS )zZSend data to the subprocess' stdin.
Returns the number of bytes written.
rQ Fr@ N) Z_coerce_send_stringrG Z_encoderr# r r. r rS rE )r8 rR �br= r= r> rQ � s
zPopenSpawn.send� c C s | � |�}|| � | j� S )z�Wraps send(), sending string ``s`` to child process, with os.linesep
automatically appended. Returns number of bytes written. )rQ r" )r8 rR �nr= r= r> �sendline� s
zPopenSpawn.sendlinec C s8 | j �� }|dkr || _d| _nd| _| | _d| _|S )zKWait for the subprocess to finish.
Returns the exit code.
r NT)r. �waitZ
exitstatusZ signalstatusZ
terminated)r8 �statusr= r= r> rY � s
zPopenSpawn.waitc C sT t jdkr@|tjtjfv r"tj}n |tjtjfv r: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.
r N) r' r( �signal�SIGINTZ CTRL_C_EVENTZSIGBREAKZCTRL_BREAK_EVENT�SIGTERMr! �killr. r/ )r8 Zsigr= r= r> r^ � s
zPopenSpawn.killc C s | j j�� dS )z+Closes the stdin pipe from the writing end.N)r. r �close)r8 r= r= r> �sendeof� s zPopenSpawn.sendeof) r
r NNNNNr N)rV )�__name__�
__module__� __qualname__r rC rK r5 rS rT rQ rX rY r^ r` �
__classcell__r= r= r; r> r s �*#
r )�__doc__r! r3 r% r' rD r[ r* Zqueuer r � ImportErrorZ spawnbaser r �
exceptionsr Zutilsr r r= r= r= r> �<module> s