Yf
@ 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_execcreate_subprocess_shell N )events) protocols)streams)tasks) coroutine)loggerc sp e Z d 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)SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c sR t j d | | | _ d | _ | _ | _ d | _ d | _ g | _ d S)NloopF) super__init___limitstdinstdoutstderr
_transport_process_exited _pipe_fds)selflimitr ) __class__ 7/opt/alt/python35/lib64/python3.5/asyncio/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 protocolreader)
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 fddatar# 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_eofZ
set_exceptionr remove_maybe_close_transport)r r* excpiper# r r r pipe_connection_lostJ s$
z-SubprocessStreamProtocol.pipe_connection_lostc C s d | _ | j d S)NT)r r/ )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 r/ e s
z/SubprocessStreamProtocol._maybe_close_transport) r
__module__ __qualname____doc__r r r) r, r2 r3 r/ 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_pidpid)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)zdWait until the process exit and return the process return code.
This method is a coroutine.N)r Z_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
debugr4 ZdrainBrokenPipeErrorConnectionResetErrorr- )r inputrB r0 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 | d k s< t | j } | j j r | d k rf 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 AssertionErrorr r& r@ r
rB readr- )r r* r( streamnameoutputr 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 ) rF rG r rM r r Zgatherr& r; )r rE r r r r r r communicate s zProcess.communicate)r r5 r6 r r propertyr: r r; r< r> r? rF rG 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 s z)create_subprocess_shell..r r r )r get_event_loopZsubprocess_shellr8 )
cmdr r r r r kwdsprotocol_factoryr( r" r )r r r r s r r r r r c / sr 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 rP s z(create_subprocess_exec..r r r )r rQ Zsubprocess_execr8 ) Zprogramr r r r r argsrS rT r( r" r )r r r r s )__all__
subprocess r r r r Z
coroutinesr logr
PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr r8 Z_DEFAULT_LIMITr r r r r r s( X]