File "subprocess.cpython-35.opt-1.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python35/lib64/python3.5/asyncio/__pycache__/subprocess.cpython-35.opt-1.pyc
File size: 7.3 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
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 | 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& 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 rL 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 rL rM 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 <lambda> s z)create_subprocess_shell.<locals>.<lambda>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 rO s z(create_subprocess_exec.<locals>.<lambda>r r r )r rP Zsubprocess_execr8 ) Zprogramr r r r r argsrR rS 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 <module> s( X]