B
Éá¿àRN» ã @ s° d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ej Z ej
Z
ej Z G d d
„ d
ej ej
ƒZG d d „ d ƒZddddejfd
d„Zddddejdœdd„ZdS ))Úcreate_subprocess_execÚcreate_subprocess_shellé Né )Úevents)Ú protocols)Ústreams)Útasks)Úloggerc sP e Zd ZdZ‡ fdd„Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Z dd„ Z
‡ Z S )ÚSubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c s< t ƒ j|d || _d | _ | _| _d | _d| _g | _d S )N)ÚloopF) ÚsuperÚ__init__Ú_limitÚstdinÚstdoutÚstderrÚ
_transportÚ_process_exitedÚ _pipe_fds)ÚselfÚlimitr )Ú __class__© ú7/opt/alt/python37/lib64/python3.7/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›¡ d d |¡¡S )Nzstdin=zstdout=zstderr=z<{}>ú )r Ú__name__r Úappendr r ÚformatÚjoin)r Úinfor r r Ú__repr__ s
z!SubprocessStreamProtocol.__repr__c C s® || _ | d¡}|d k rDtj| j| jd| _| j |¡ | j d¡ | d¡}|d k r‚tj| j| jd| _
| j
|¡ | j d¡ | d¡}|d k rªtj || d | jd| _ d S )Nr )r r é r )ÚprotocolÚreaderr )
r Úget_pipe_transportr Ú StreamReaderr Ú_loopr 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 ÚfdÚdatar# r r r Úpipe_data_received? s z+SubprocessStreamProtocol.pipe_data_receivedc C s– |dkr,| j }|d k r | ¡ | |¡ d S |dkr<| j}n|dkrL| j}nd }|d k rt|d krj| ¡ n
| |¡ || jkrŠ| j |¡ | ¡ d S )Nr r r! )
r ÚcloseZconnection_lostr r Zfeed_eofZ
set_exceptionr ÚremoveÚ_maybe_close_transport)r r* ÚexcÚpiper# r r r Úpipe_connection_lostI s$
z-SubprocessStreamProtocol.pipe_connection_lostc C s d| _ | ¡ d S )NT)r r/ )r r r r Úprocess_exited` s z'SubprocessStreamProtocol.process_exitedc C s( t | jƒdkr$| jr$| j ¡ d | _d S )Nr )Úlenr r r r- )r r r r r/ d s
z/SubprocessStreamProtocol._maybe_close_transport) r Ú
__module__Ú __qualname__Ú__doc__r
r r) r, r2 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
ddd„ZdS )ÚProcessc C s8 || _ || _|| _|j| _|j| _|j| _| ¡ | _d S )N)r Z _protocolr& r r r Zget_pidÚpid)r r( r" r r r r r
k s zProcess.__init__c C s d| j j› d| j› dS )Nú)r r r: )r r r r r t s zProcess.__repr__c C s
| j ¡ S )N)r Zget_returncode)r r r r Ú
returncodew s zProcess.returncodec à s | j ¡ I dH S )z?Wait until the process exit and return the process return code.N)r Z_wait)r r r r Úwait{ s z Process.waitc C s | j |¡ d S )N)r Ú send_signal)r Úsignalr r r r? s zProcess.send_signalc C s | j ¡ d S )N)r Ú terminate)r r r r rA ‚ s zProcess.terminatec C s | j ¡ d S )N)r Úkill)r r r r rB … s z Process.killc
à s˜ | j ¡ }| j |¡ |r,t d| t|ƒ¡ y| j ¡ I d H W n8 tt fk
rx } z|rht d| |¡ W d d }~X Y nX |rŠt d| ¡ | j
¡ d S )Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r& Ú get_debugr Úwriter Údebugr4 ZdrainÚBrokenPipeErrorÚConnectionResetErrorr- )r ÚinputrE r0 r r r Ú _feed_stdinˆ s
zProcess._feed_stdinc à s d S )Nr )r r r r Ú_noop™ s z
Process._noopc à s˜ | j |¡}|dkr | j}n|dks(t‚| j}| j ¡ rV|dkrDdnd}t d| |¡ | ¡ I d H }| j ¡ rŒ|dkrzdnd}t d| |¡ |
¡ |S )Nr! r r r z%r communicate: read %sz%r communicate: close %s) r r$ r ÚAssertionErrorr r& rC r rE Úreadr- )r r* r( ÚstreamÚnameÚoutputr r r Ú _read_streamœ s
zProcess._read_streamNc à sŽ |d k r| |¡}n| ¡ }| jd k r2| d¡}n| ¡ }| jd k rP| d¡}n| ¡ }tj|||| jdI d H \}}}| ¡ I d H ||fS )Nr r! )r ) rI rJ r rP r r Zgatherr& r> )r rH r r r r r r Ú communicate s
zProcess.communicate)N)r r5 r6 r
r Úpropertyr= r> r? rA rB rI rJ rP rQ r r r r r9 j s r9 c
‹ sP ˆd krt ¡ ‰‡ ‡fdd„}ˆj|| f|||dœ|—ŽI d H \}} t|| ˆƒS )Nc s t ˆ ˆdS )N)r r )r
r )r r r r ÚÅ s z)create_subprocess_shell..)r r r )r Úget_event_loopZsubprocess_shellr9 )
Úcmdr r r r r ÚkwdsÚprotocol_factoryr( r" r )r r r r À s r )r r r r r c sT ˆd krt ¡ ‰‡ ‡fdd„}ˆj|| f|ž|||dœ|—ŽI d H \} }
t| |
ˆƒS )Nc s t ˆ ˆdS )N)r r )r
r )r r r r rS Ó s z(create_subprocess_exec..)r r r )r rT Zsubprocess_execr9 ) Zprogramr r r r r ÚargsrV rW r( r" r )r r r r Î s r )Ú__all__Ú
subprocessÚ r r r r Úlogr ÚPIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr
r9 Z_DEFAULT_LIMITr r r r r r Ú s" XV