관리-도구
편집 파일: 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