Da

✏️ Editing: popen_spawn.cpython-310.pyc

������!^����������������������@���s����d�Z�ddlZddlZddlZddlZddlZddlZddlZz
ddlm	Z	m
Z
�W�n�ey9���ddl	m	Z	m
Z
�Y�nw�ddlm
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�����������������������sr���e�Zd�Z			d��fdd�	ZdZdd	��Zd
d��Zdd
��Zdd��Zdd��Z	ddd�Z
dd��Zdd��Zdd��Z
���ZS�)�
PopenSpawn��������N�strictc�����������
���	������s��t�t|��j||||||	d��|d�u�rtj�d�|�_n|��tj�|�_tdt	j
t	jt	j
||
|d�}tj
dkrIt	���}|�jt	jO��_||d<�t	j|d<�t|t�r]tj
dkr]tj|tjdkd	�}t	j|fi�|��|�_|�jj|�_d
|�_|����|�_t��|�_tj|�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�encodeZcrlfZstring_type�dict�
subprocess�PIPEZSTDOUT�sys�platformZSTARTUPINFOZdwFlagsZSTARTF_USESHOWWINDOWZCREATE_NEW_PROCESS_GROUP�
isinstancer����shlex�split�name�Popen�proc�pid�closed�_bufr����_read_queue�	threadingZThread�_read_incomingZ_read_threadZ	setDaemon�start)
�self�cmdr
���r���r���r���r���r���r���r���r����kwargsr�����	__class__���5/usr/lib/python3/dist-packages/pexpect/popen_spawn.pyr ������s4�����

zPopenSpawn.__init__Fc�����������������C���s��|�j�}|�jr|r||d���|�_�|d�|��S�d|�_td��|dkr$|�j}n|d�u�r*d}t���}t���|�|k�rq|rqt|�|k�rqz|�j���}W�n	�t	yN���Y�n#w�|d�u�rWd|�_n||�j
j|dd�7�}t���|�|k�rq|rqt|�|k�s>|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)r6����sizer
����bufZt0Zincoming�rr;���r;���r<����read_nonblockingA���s4��� � �zPopenSpawn.read_nonblockingc��������������
���C���sv���|�j�j���}	�d}zt�|d�}W�n�ty)�}�z|��|d��W�Y�d}~nd}~ww�|s4|�j�d��dS�|�j�|��q)z6Run in a thread to move output from a pipe to a queue.r��������i���r@���N)	r.���r����filenor!���r@����OSErrorrE���r2���Zput)r6���rK���rG����er;���r;���r<���r4���d���s������zPopenSpawn._read_incomingc�����������������C���s���|���|��dS�)zHThis is similar to send() except that there is no return value.
        N��send)r6����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.
        NrN���)r6���ZsequencerP���r;���r;���r<����
writelinesz���s����zPopenSpawn.writelinesc�����������������C���sN���|���|�}|��|d��|�jj|dd�}tr|�jj�|�S�|�jj�|��t|�S�)zZSend data to the subprocess' stdin.

Returns the number of bytes written.
        rO���Fr>���)	Z_coerce_send_stringrE���Z_encoderr#���r���r.���r���rQ���rC���)r6���rP����br;���r;���r<���rO�������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. )rO���r"���)r6���rP����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
exitstatusZsignalstatusZ
terminated)r6����statusr;���r;���r<���rW�������s���
zPopenSpawn.waitc�����������������C���sT���t�jdkr |tjtjfv�rtj}n|tjtjfv�rtj}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�SIGINTZCTRL_C_EVENTZSIGBREAKZCTRL_BREAK_EVENT�SIGTERMr!����killr.���r/���)r6���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)r6���r;���r;���r<����sendeof����s���zPopenSpawn.sendeof)	r
���r���NNNNNr���N)rT���)�__name__�
__module__�__qualname__r ���rA���rI���r4���rQ���rR���rO���rV���rW���r\���r^����
__classcell__r;���r;���r9���r<���r	������s�����*#

r	���)�__doc__r!���r3���r%���r'���rB���rY���r*����queuer���r����ImportErrorZ	spawnbaser���r����
exceptionsr���Zutilsr���r	���r;���r;���r;���r<����<module>���s"�����

📁 Sid Gifari File Manager