U
,a @ s d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ej
Z
ej Z ej Z G d d
d
ej
ejZG d d d Zddddejfd
dZddddejdddZdS ))create_subprocess_execcreate_subprocess_shell N )events) protocols)streams)tasks)loggerc sT e Zd Z fddZdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
Z S )SubprocessStreamProtocolc sH t j|d || _d | _ | _| _d | _d| _g | _| j
| _ d S )NloopF) super__init___limitstdinstdoutstderr
_transport_process_exited _pipe_fds_loopZ
create_future
_stdin_closed)selflimitr __class__ 7/opt/alt/python38/lib64/python3.8/asyncio/subprocess.pyr s z!SubprocessStreamProtocol.__init__c C sn | j jg}| jd k r&|d| j | jd k rB|d| j | jd k r^|d| j dd|S )Nzstdin=zstdout=zstderr=z<{}> )r __name__r appendr r formatjoin)r infor r r __repr__ s
z!SubprocessStreamProtocol.__repr__c C s || _ |d}|d k rDtj| j| jd| _| j| | j d |d}|d k rtj| j| jd| _
| j
| | j d |d}|d k rtj || d | jd| _ d S )Nr r r r )protocolreaderr )
r get_pipe_transportr StreamReaderr r r Z
set_transportr r r StreamWriterr )r transportZstdout_transportZstderr_transportZstdin_transportr r r connection_made) s,
z(SubprocessStreamProtocol.connection_madec C s: |dkr| j }n|dkr | j}nd }|d k r6|| d S )Nr r& )r r Z feed_data)r fddatar( r r r pipe_data_receivedA s z+SubprocessStreamProtocol.pipe_data_receivedc C s |dkrN| j }|d k r | | | |d kr>| jd n | j| d S |dkr^| j}n|dkrn| j}nd }|d k r|d kr| n
|| || j kr| j
| | d S )Nr r r& ) r closeZconnection_lostr Z
set_resultZ
set_exceptionr r Zfeed_eofr remove_maybe_close_transport)r r. excpiper( r r r pipe_connection_lostK s*
z-SubprocessStreamProtocol.pipe_connection_lostc C s d| _ | d S )NT)r r3 r r r r process_exitedf s z'SubprocessStreamProtocol.process_exitedc C s( t | jdkr$| jr$| j d | _d S )Nr )lenr r r r1 r7 r r r r3 j s
z/SubprocessStreamProtocol._maybe_close_transportc C s || j kr| jS d S N)r r )r streamr r r _get_close_waitero s
z*SubprocessStreamProtocol._get_close_waiter) r
__module__ __qualname__r r$ r- r0 r6 r8 r3 r<
__classcell__r r r r r
s
r
c @ sj e Zd Zdd Zdd Zedd Zdd Zd d
Zd d Z d
d Z
dd Z dd Z dd Z
dddZdS )Processc C s8 || _ || _|| _|j| _|j| _|j| _| | _d S r: )r Z _protocolr r r r Zget_pidpid)r r, r' r r r r r u s zProcess.__init__c C s d| j j d| j dS )N