| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/pexpect/__pycache__/ |
Upload File : |
U
�C
[ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZzddlm 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 kr4tj�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|f| �| _| 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� 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 s> � �
zPopenSpawn.__init__Fc C s� | j }| jr8|r*||d � | _ |d |� S d| _td��|dkrH| j}n |d krTd}t�� }t�� | |k r�|r�t|�|k r�z| j�� }W n t k
r� Y q�Y q\X |d kr�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)r6 �sizer
�bufZt0Zincoming�rr; r; r< �read_nonblockingA s0
zPopenSpawn.read_nonblockingc
C sv | j j�� }d}zt�|d�}W n. tk
rN } z| �|d� W 5 d}~X Y nX |sd| j�d� dS | j�|� q dS )z6Run in a thread to move output from a pipe to a queue.� 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 sR | � |�}| �|d� | jj|dd�}tr8| jj�|�S | jj�|� t|�S dS )zZSend data to the subprocess' stdin.
Returns the number of bytes written.
rO Fr> N) 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
exitstatusZ signalstatusZ
terminated)r6 Zstatusr; r; r< rW � s
zPopenSpawn.waitc C sT t jdkr@|tjtjfkr"tj}n |tjtjfkr: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/ )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 rX r* Zqueuer r � ImportErrorZ spawnbaser r �
exceptionsr Zutilsr r r; r; r; r< �<module> s