j f
@ 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 sd 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 S)SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c s@ t j d | | | _ d | _ | _ | _ d | _ d S)Nloop)super__init___limitstdinstdoutstderr
_transport)selflimitr ) __class__ 7/opt/alt/python34/lib64/python3.4/asyncio/subprocess.pyr s z!SubprocessStreamProtocol.__init__c C s | j j g } | j d k r5 | j d | j n | j d k r[ | j d | j n | j d k r | j d | j n 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 rX t j d | j d | j | _ | j j | n | j d } | d k r t j d | j d | j | _ | j j | n | j d } | d k r t j | d | d d d | j | _
n d S)Nr r r r protocolreader) r get_pipe_transportr StreamReaderr _loopr Z
set_transportr StreamWriterr )r transportZstdout_transportZstderr_transportZstdin_transportr r r connection_made& s" z(SubprocessStreamProtocol.connection_madec C sV | d k r | j } n | d k r0 | j } n d } | d k rR | j | n 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 n | j | d S| d k rW | j } n | d k ro | j } n d } | d k r | d k r | j q | j | n d S)Nr r r )r closeZconnection_lostr r Zfeed_eofZ
set_exception)r r( excpiper! r r r pipe_connection_lostF s
z-SubprocessStreamProtocol.pipe_connection_lostc C s | j j d | _ d S)N)r r+ )r r r r process_exitedY s
z'SubprocessStreamProtocol.process_exited)
r
__module__ __qualname____doc__r r r' r* r. 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 _ s zProcess.__init__c C s d | j j | j f S)Nz<%s %s>)r r r4 )r r r r r h s zProcess.__repr__c C s
| j j S)N)r Zget_returncode)r r r r
returncodek s zProcess.returncodec c s | j j Dd 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 waito s z Process.waitc C s | j j | d S)N)r send_signal)r signalr r r r7 v s zProcess.send_signalc C s | j j d S)N)r terminate)r r r r r9 y 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 | | rA t j d | t | n y | j j Dd HWnG t t f k
r } z! | r t j d | | n WYd d } ~ Xn X| r t j d | n | 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
debuglenZdrainBrokenPipeErrorConnectionResetErrorr+ )r inputr= r, 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 rp | d k rT d n d } t j d | | n | j Dd H} | j j r | d k r d n d } t j d | | n | j | S)Nr r r r z%r communicate: read %sz%r communicate: close %s)
r r" r r r$ r; r
r= readr+ )r r( r& streamnameoutputr r r _read_stream s
zProcess._read_streamNc c s | r | j | } n | j } | j d k rE | j d } n | j } | j d k rr | j d } n | j } t j | | | d | j Dd H\ } } } | j Dd H| | f S)Nr r r ) rB rC r rH r r Zgatherr$ r6 )r rA r r r r r r communicate s zProcess.communicate)r r0 r1 r r propertyr5 r r6 r7 r9 r: rB rC rH rI r r r r r3 ^ s r3 c
+ sr d k r t j n f d d } j | | d | d | d | | Dd 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_shellr3 )
cmdr r r r r kwdsprotocol_factoryr& r r )r r r r s r r r r r c / su d k r t j n f d d } j | | d | d | d | | | Dd H\ } }
t | |
S)Nc s t d d S)Nr r )r r )r r r r rK s z(create_subprocess_exec..r r r )r rL Zsubprocess_execr3 ) Zprogramr r r r r argsrN rO r& r r )r r r r s )__all__
subprocess r r r r Z
coroutinesr logr
PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr r3 Z_DEFAULT_LIMITr r r r r r s( K]