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 sL e Zd Z‡ fdd„Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z ‡ Z
S )ÚSubprocessStreamProtocolc 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__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 r9 )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 d H S )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 r@ ‚ s zProcess.terminatec C s | j ¡ d S )N)r Úkill)r r r r rA … 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 ÚinputrD 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| j}| j ¡ rJ|dkr8dnd}t d| |¡ | ¡ I d H }| j ¡ r€|dkrndnd}t d| |¡ | ¡ |S )Nr! r r r z%r communicate: read %sz%r communicate: close %s)
r r$ r r r& rB r rD Ú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 ) rH rI r rN r r Zgatherr& r= )r rG r r r r r r Ú communicate s
zProcess.communicate)N)r r5 r6 r
r Úpropertyr< r= r> r@ rA rH rI rN rO r r r r r8 j s r8 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_shellr8 )
Ú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 rQ Ó s z(create_subprocess_exec..)r r r )r rR Zsubprocess_execr8 ) Zprogramr r r r r ÚargsrT rU r( r" r )r r r r Î s r )Ú__all__Ú
subprocessÚ r r r r Úlogr ÚPIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr
r8 Z_DEFAULT_LIMITr r r r r r Ú s" XV