Š¹¼]Ê ã
@ s d d g Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d
l m
Z
e j Z e j Z e j
Z
Gd d „ d e j e j ƒ Z Gd
d „ d ƒ Z e d d d d e j d d „ ƒ Z e d d d d d d d d d e j d d „ ƒ Z d S)Úcreate_subprocess_execÚcreate_subprocess_shellé Né )Úevents)Ú protocols)Ústreams)Útasks)Ú coroutine)Úloggerc sj e Z d Z ‡ f d d † Z d d „ Z d d „ Z d d „ Z d d
„ Z d d „ Z d
d „ Z ‡ S)ÚSubprocessStreamProtocolc sR 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__© ú//opt/alt/python35/lib64/python3.5/subprocess.pyr s z!SubprocessStreamProtocol.__init__c C s‰ | j j g } | j d k r2 | j d | j ƒ | j d k rU | j d | j ƒ | j d k rx | j d | j ƒ d d j | ƒ S)Nzstdin=%rz stdout=%rz stderr=%rz<%s>ú )r Ú__name__r Úappendr r Újoin)r Úinfor r r Ú__repr__ s z!SubprocessStreamProtocol.__repr__c C s | | _ | j d ƒ } | d k re t j d | j d | j ƒ | _ | j j | ƒ | j j d ƒ | j d ƒ } | d k rÁ t j d | j d | j ƒ | _
| j
j | ƒ | j j d ƒ | j d ƒ } | d k rt j | d | d d d | j ƒ| _ d S)Nr r r é r ÚprotocolÚreader)
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 sS | d k r | j } n | d k r0 | j } n d } | d k rO | j | ƒ 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Ñ | d k r< | j } | d k r+ | j ƒ | j | ƒ d S| d k rT | j } n | d k rl | j } n d } | d k r¤ | d k r— | j ƒ n
| j | ƒ | | j k rà | j j | ƒ | j ƒ d S)Nr r r! )
r ÚcloseZconnection_lostr r Zfeed_eofÚ
set_exceptionr ÚremoveÚ_maybe_close_transport)r r* ÚexcÚpiper# r r r Úpipe_connection_lostJ s$
z-SubprocessStreamProtocol.pipe_connection_lostc C s d | _ | j ƒ d S)NT)r r0 )r r r r Úprocess_exiteda s z'SubprocessStreamProtocol.process_exitedc C s8 t | j ƒ d k r4 | j r4 | j j ƒ d | _ d S)Nr )Úlenr r r r- )r r r r r0 e s
z/SubprocessStreamProtocol._maybe_close_transport)
r Ú
__module__Ú __qualname__r r r) r, r3 r4 r0 r r )r r r s
r c @ s» e Z d Z d d „ Z d d „ Z e d d „ ƒ Z e d d „ ƒ Z d d
„ Z d d „ Z
d
d „ Z e d d „ ƒ Z e d d „ ƒ Z
e d d „ ƒ Z e d d d „ ƒ Z d S)ÚProcessc C sR | | _ | | _ | | _ | j | _ | j | _ | j | _ | j ƒ | _ d S)N)r Z _protocolr& r r r Zget_pidÚpid)r r( r" r r r r r l s zProcess.__init__c C s d | j j | j f S)Nz<%s %s>)r r r9 )r r r r r u s zProcess.__repr__c C s
| j j ƒ S)N)r Zget_returncode)r r r r Ú
returncodex s zProcess.returncodec c s | j j ƒ Ed HS)N)r Ú_wait)r r r r Úwait| s z Process.waitc C s | j j | ƒ d S)N)r Ú send_signal)r Úsignalr r r r= ƒ s zProcess.send_signalc C s | j j ƒ d S)N)r Ú terminate)r r r r r? † s zProcess.terminatec C s | j j ƒ d S)N)r Úkill)r r r r r@ ‰ s z Process.killc c s | j j ƒ } | j j | ƒ | r> t j d | t | ƒ ƒ y | j j ƒ Ed HWnD t t f k
rš } z | rˆ t j d | | ƒ WYd d } ~ Xn X| r± t j d | ƒ | j j
ƒ d S)Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r& Ú get_debugr Úwriter
Údebugr5 ZdrainÚBrokenPipeErrorÚConnectionResetErrorr- )r ÚinputrC r1 r r r Ú _feed_stdinŒ s &zProcess._feed_stdinc C s d S)Nr )r r r r Ú_noopž s z
Process._noopc c sÆ | j j | ƒ } | d k r* | j } n | j } | j j ƒ rm | d k rT d n d } t j d | | ƒ | j ƒ Ed H} | j j ƒ r¸ | d k rŸ d n d } t j d | | ƒ | j ƒ | S)Nr! r r r z%r communicate: read %sz%r communicate: close %s)
r r$ r r r& rA r
rC Úreadr- )r r* r( ÚstreamÚnameÚoutputr r r Ú _read_stream¢ s
zProcess._read_streamNc c sÉ | d k r | j | ƒ } n | j ƒ } | j d k rK | j d ƒ } n | j ƒ } | j d k rx | j d ƒ } n | j ƒ } t j | | | d | j ƒEd H\ } } } | j ƒ Ed H| | f S)Nr r! r ) rG rH r rM r r Zgatherr& r< )r rF r r r r r r Ú communicate´ s zProcess.communicate)r r6 r7 r r Úpropertyr: r r< r= r? r@ rG rH rM rN r r r r r8 k s r8 c
+ so ˆ d k r t j ƒ ‰ ‡ ‡ f d d † } ˆ j | | d | d | d | | Ed H\ } } t | | ˆ ƒ S)Nc s t d ˆ d ˆ ƒ S)Nr r )r r )r r r r Ú