File: //usr/lib/python3.5/asyncio/__pycache__/subprocess.cpython-35.pyc
Fa
@ 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__ (/usr/lib/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 rU t j d | j d | j | _ | j j | | j d } | d k r t j d | j d | j | _ | j j | | j d } | d k r t j | d | d d d | j | _
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 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 | 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 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 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 | | 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
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 | 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
r= 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 ) rB rC r rI 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 rI rJ r r r r r3 ^ s r3 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 <lambda> s z)create_subprocess_shell.<locals>.<lambda>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 / 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 rL s z(create_subprocess_exec.<locals>.<lambda>r r r )r rM Zsubprocess_execr3 ) Zprogramr r r r r argsrO rP 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 <module> s( K]