] @ s d d l Z e j d k Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m
Z Gd d d e Z
Gd d d e
Z Gd d d e
Z e rd d l Z d d l Z d d l Z Gd
d d Z n d d l Z d d l Z d d l Z y d d l Z Wn e k
rUd d l Z Yn Xe e d d
Z e e d re j Z n e j Z d d d d d d d d d d d d d d g Z e r7d d l m Z m! Z! m" Z" m# Z# m$ Z$ m% Z% m& Z& m' Z' e j( d d d d d d d! d" g Gd# d$ d$ e) Z* g Z+ d% d& Z, d: Z- d; Z. d< Z/ d* d+ Z0 d, d d- d Z1 d. d Z2 d, d d/ d Z3 Gd0 d d e4 Z5 d1 d d, d d2 d3 d4 d Z6 d5 d6 Z7 d7 d Z8 d8 d Z9 e4 Z: Gd9 d d e4 Z; d S)= Nwin32) monotonicc @ s e Z d Z d S)SubprocessErrorN)__name__
__module__ __qualname__ r r //opt/alt/python35/lib64/python3.5/subprocess.pyr 9 s r c @ sU e Z d Z d d d d Z d d Z e d d Z e j d d Z d S) CalledProcessErrorNc C s( | | _ | | _ | | _ | | _ d S)N)
returncodecmdoutputstderr)selfr r r
r r r r __init__C s zCalledProcessError.__init__c C s d | j | j f S)Nz-Command '%s' returned non-zero exit status %d)r r )r r r r __str__I s zCalledProcessError.__str__c C s | j S)N)r
)r r r r stdoutL s zCalledProcessError.stdoutc C s
| | _ d S)N)r
)r valuer r r r Q s )r r r r r propertyr setterr r r r r
< s r
c @ sU e Z d Z d d d d Z d d Z e d d Z e j d d Z d S) TimeoutExpiredNc C s( | | _ | | _ | | _ | | _ d S)N)r timeoutr
r )r r r r
r r r r r _ s zTimeoutExpired.__init__c C s d | j | j f S)Nz'Command '%s' timed out after %s seconds)r r )r r r r r e s zTimeoutExpired.__str__c C s | j S)N)r
)r r r r r i s zTimeoutExpired.stdoutc C s
| | _ d S)N)r
)r r r r r r m s )r r r r r r r r r r r r r X s r c @ s. e Z d Z d Z d Z d Z d Z d Z d S) STARTUPINFOr N)r r r dwFlags hStdInput
hStdOutput hStdError wShowWindowr r r r r x s
r PIPE_BUFi PollSelectorPopenPIPESTDOUTcall
check_callgetstatusoutput getoutput check_outputrunDEVNULLCompletedProcess)CREATE_NEW_CONSOLECREATE_NEW_PROCESS_GROUPSTD_INPUT_HANDLESTD_OUTPUT_HANDLESTD_ERROR_HANDLESW_HIDESTARTF_USESTDHANDLESSTARTF_USESHOWWINDOWr+ r, r- r. r/ r0 r1 r2 c @ sL e Z d Z d Z e j d d Z d d Z d d Z e Z e Z
d S) HandleFc C s | j s d | _ | | d S)NT)closed)r CloseHandler r r Close s z Handle.Closec C s, | j s d | _ t | St d d S)NTzalready closed)r4 int
ValueError)r r r r Detach s
z
Handle.Detachc C s d | j j t | f S)Nz%s(%d)) __class__r r7 )r r r r __repr__ s zHandle.__repr__N) r r r r4 _winapir5 r6 r9 r; __del__r r r r r r3 s r3 c C sf x_ t d d D]M } | j d t j } | d k r y t j | Wq t k
r] Yq Xq Wd S)N
_deadstate)_active_internal_pollsysmaxsizeremover8 )instresr r r _cleanup s
rF c C s d d d d d d d d d d
d d d
d d d d d i } g } xM | j D]? \ } } t t j | } | d k rO | j d | | qO Wx" t j D] } | j d | q W| S)NdebugdoptimizeOdont_write_bytecodeB no_user_sitesno_siteSignore_environmentEverbosev
bytes_warningbquietqr -z-W)itemsgetattrrA flagsappend warnoptions) flag_opt_mapargsflagoptrW r r r _args_from_interpreter_flags s" rf r c O sS t | | = } y | j d | SWn | j | j Yn XWd QRXd S)Nr )r waitkill)r popenargskwargspr r r r# s
c O sM t | | } | rI | j d } | d k r: | d } t | | d S)Nrc r )r# getr
)ri rj retcoder r r r r$ s
c O sx d | k r t d d | k rV | d d k rV | j d d rL d n d | d <t | d t d | d d
| j S) Nr z3stdout argument not allowed, it will be overridden.inputuniversal_newlinesF r checkT)r8 rl r( r! r )r ri rj r r r r' s "c @ s: e Z d Z d d d d Z d d Z d d Z d S)r* Nc C s( | | _ | | _ | | _ | | _ d S)N)rc r r r )r rc r r r r r r r J s zCompletedProcess.__init__c C s d j | j d j | j g } | j d k rL | j d j | j | j d k rt | j d j | j d j t | j d j | S)Nz args={!r}zreturncode={!r}z stdout={!r}z stderr={!r}z{}({})z, ) formatrc r r r` r typer join)r rc r r r r; P s zCompletedProcess.__repr__c C s. | j r* t | j | j | j | j d S)N)r r
rc r r )r r r r check_returncodeY s z!CompletedProcess.check_returncode)r r r r r; rv r r r r r* ? s rn rr Fc O s | d k r. d | k r$ t d t | d <t | | } y | j | d | \ } } Wnj t k
r | j | j \ } } t | j | d | d | Yn | j | j Yn X| j } | r| rt | | j d | d | Wd QRXt
| j | | | S)Nstdinz/stdin and input arguments may not both be used.r r
r ) r8 r! r communicater rh rc rg pollr
r* ) rn r rr ri rj processr r rm r r r r( ` s*
c C s8 g } d } x | D]} g } | r2 | j d d | k pN d | k pN | } | rd | j d x | D] } | d k r | j | qk | d k r | j d t | d g } | j d qk | r | j | g } | j | qk W| r| j | | r | j | | j d q Wd j | S) NF "\rH z\"rp )r` lenextendru )seqresult needquoteargbs_bufcr r r list2cmdline s4
r c C s y( t | d d d d d t } d } Wn7 t k
ra } z | j } | j } WYd d } ~ Xn X| d d d k r | d d } | | f S)
NshellTro r r rG
r )r' r" r
r
r )r datastatusexr r r r% s
c C s t | d S)NrG )r% )r r r r r& s
c @ s/ e Z d Z d Z d= d d d d d e d d d d d d d d f d d Z d d Z d
d Z d d
Z e j
d d Z d d Z d d Z
d d d d Z d d Z d d Z d d Z e rhd d Z d d Z d d! Z d e j e j e j d" d# Z d d d$ d% Z d& d' Z d( d) Z d* d+ Z d, d- Z e Z n d. d Z d/ d! Z e! j" e! j# e! j$ e! j% e! j& e! j' d0 d1 Z( d e! j) e! j* e+ j, d2 d# Z d3 d4 Z- d d d5 d% Z d6 d) Z d7 d8 Z. d9 d+ Z d: d- Z d; d< Z d S)>r FrG Nr Tc C s@ t t j | _ d | _ d | _ | d k r: d } t | t sU t d t r | d k rs t
d | d k p | d k p | d k } | t k r | r d } q d } q;| r;| r;t
d ne | t k r d } | r | r t j
d t d } |
d k r#t
d | d k r;t
d
| | _ d | _ d | _ d | _ d | _ d | _ | | _ | j | | | \ } } } } } } t r| d k rt j | j d } | d k rt j | j d } | d k rt j | j d } | d k rdt j | d | | _ | rdt j | j d d d
| d k | _ | d k rt j | d | | _ | rt j | j | _ | d k rt j | d | | _ | rt j | j | _ d | _ yD | j | | | | | |
| |
| | | | | | | | | | Wn
xL t d | j | j | j f D]) } y | j WqWt! k
rYqWXqWW| j s4g } | t" k r| j# | | t" k r| j# | | t" k r| j# | t$ | d r| j# | j% x4 | D], } y t& j | Wqt! k
r/YqXqW Yn Xd S)NFrG zbufsize must be an integerz0preexec_fn is not supported on Windows platformsTzSclose_fds is not supported on Windows platforms if you redirect stdin/stdout/stderrz pass_fds overriding close_fds.z2startupinfo is only supported on Windows platformsr z4creationflags is only supported on Windows platformswb
write_throughline_bufferingrb_devnullr r r r r r r )'rF threadingLock
_waitpid_lock_input_communication_started
isinstancer7 TypeError
_mswindowsr8 _PLATFORM_DEFAULT_CLOSE_FDSwarningswarnRuntimeWarningrc rw r r pidr ro _get_handlesmsvcrtopen_osfhandler9 ioopen
TextIOWrapper_closed_child_pipe_fds_execute_childfiltercloseOSErrorr! r` hasattrr os) r rc bufsize
executablerw r r
preexec_fn close_fdsr cwdenvro startupinfo
creationflagsrestore_signalsstart_new_sessionpass_fds
any_stdio_setp2creadp2cwritec2preadc2pwriteerrreaderrwritefto_closefdr r r r 3 s
' (
zPopen.__init__c C s+ | j | } | j d d j d d S)Nz
r
)decodereplace)r r encodingr r r _translate_newlines s zPopen._translate_newlinesc C s | S)Nr )r r r r __enter__ s zPopen.__enter__c
C sX | j r | j j | j r, | j j z | j rE | j j Wd | j Xd S)N)r r r rw rg )r rt r tracebackr r r __exit__ s
zPopen.__exit__c C sI | j s
d S| j d | | j d k rE t d k rE t j | d S)Nr> )_child_createdr@ r r? r` )r _maxsizer r r r= s
z
Popen.__del__c C s1 t | d s* t j t j t j | _ | j S)Nr )r r r devnullO_RDWRr )r r r r _get_devnull s zPopen._get_devnullc C s | rk y | j j | WnN t k
r. Yn= t k
rj } z | j t j k rU n WYd d } ~ Xn Xy | j j WnN t k
r Yn= t k
r } z | j t j k r n WYd d } ~ Xn Xd S)N)rw writeBrokenPipeErrorr errnoEINVALr )r rn excr r r _stdin_write s"
zPopen._stdin_writec C sJ | j r | r t d | d k r | j r | j | j | j g j d d k r d } d } | j r} | j | nM | j r | j j } | j j n% | j r | j j } | j j | j ni | d k r t
| } n d } z | j | | | \ } } Wd d | _ X| j d | j | } | | f S)Nz.Cannot send input after starting communicationrH Tr )
r r8 rw r r countr readr rg _time _communicate_remaining_time)r rn r r r endtimestsr r r rx s. '
zPopen.communicatec C s
| j S)N)r@ )r r r r ry , s z
Popen.pollc C s | d k r d S| t Sd S)N)r )r r r r r r 2 s zPopen._remaining_timec C s5 | d k r d St | k r1 t | j | d S)N)r r rc )r r orig_timeoutr r r _check_timeout: s zPopen._check_timeoutc C s | d k r( | d k r( | d k r( d Sd \ } } d \ } } d \ } } | d k r t j t j } | d k rDt j d d \ } }
t | } t j |
n | t k r t j d d \ } } t | t | } } nZ | t k rt j | j
} n6 t | t r/t j | } n t j | j
} | j | } | d k rt j t j } | d k rKt j d d \ }
} t | } t j |
n | t k rt j d d \ } } t | t | } } nZ | t k rt j | j
} n6 t | t r6t j | } n t j | j
} | j | } | d k rt j t j } | d k rgt j d d \ }
} t | } t j |
n | t k rt j d d \ } } t | t | } } no | t k r
| } nZ | t k r1t j | j
} n6 t | t rRt j | } n t j | j
} | j | } | | | | | | f S)NrG r r r r r r r )r r r r r r r r )r r r r )r r r r )r r )r< Z GetStdHandler- Z
CreatePiper3 r5 r! r) r Z
get_osfhandler r r7 fileno_make_inheritabler. r/ r" ) r rw r r r r r r r r _r r r r F sn $ zPopen._get_handlesc C s7 t j t j | t j d d t j } t | S)Nr rG )r< ZDuplicateHandleZGetCurrentProcessZDUPLICATE_SAME_ACCESSr3 )r handlehr r r r s
zPopen._make_inheritablec C s t | t s t | } | d k r0 t } d | | | f k rr | j t j O_ | | _ | | _ | | _ |
r | j t j
O_ t j | _ t
j j d d } d j | | } z> t j | | d d t | | | | | \ } } } } Wd | d k r| j | d k r*| j | d
k r@| j t | d r_t
j | j Xd | _ t | | _ | | _ t j | d S) NrG ZCOMSPECzcmd.exez
{} /c "{}"r Tr r r r ) r strr r r r< r1 r r r r2 r0 r r environrl rs Z
CreateProcessr7 r6 r r r r r3 _handler r5 )r rc r r r r r r r r r r r r r r r Zunused_restore_signalsZunused_start_new_sessionZcomspecZhpZhtr tidr r r r sD
zPopen._execute_childc C s@ | j d k r9 | | j d | k r9 | | j | _ | j S)Nr )r r )r r> Z_WaitForSingleObjectZ_WAIT_OBJECT_0Z_GetExitCodeProcessr r r r@ s zPopen._internal_pollc C s | d k r | j | } | d k r3 t j } n t | d } | j d k r t j | j | } | t j k r t | j | t j
| j | _ | j S)Ni ) r r< ZINFINITEr7 r WaitForSingleObjectr Z WAIT_TIMEOUTr rc GetExitCodeProcess)r r r Ztimeout_millisr r r r rg s z
Popen.waitc C s! | j | j | j d S)N)r` r r )r Zfhbufferr r r
_readerthread s zPopen._readerthreadc C s | j re t | d re g | _ t j d | j d | j | j f | _ d | j _ | j j | j r t | d r g | _
t j d | j d | j | j
f | _ d | j _ | j j | j r | j
| | j d k r)| j j | j | | j j r)t | j | | j d k rr| j j | j | | j j rrt | j | d } d } | j r| j } | j j | j r| j
} | j j | d k r| d } | d k r| d } | | f S)N _stdout_bufftargetrc T _stderr_buffr )r r r r Threadr Z
stdout_threaddaemonstartr r Z
stderr_threadrw r ru r is_aliver rc r )r rn r r r r r r r r sF
zPopen._communicatec C s | j d k r d S| t j k r/ | j ne | t j k rW t j | j t j n= | t j k r t j | j t j n t d j
| d S)NzUnsupported signal: {}) r signalSIGTERM terminateZ CTRL_C_EVENTr rh r ZCTRL_BREAK_EVENTr8 rs )r sigr r r send_signal0 s
zPopen.send_signalc C sp | j d k r d Sy t j | j d Wn? t k
rk t j | j } | t j k r^ | | _ Yn Xd S)NrG )r r< ZTerminateProcessr PermissionErrorr Z STILL_ACTIVE)r rcr r r r > s
zPopen.terminatec
C s d \ } } d \ } } d
\ } } | d k r3 n` | t k rT t j \ } } n? | t k ro | j } n$ t | t r | } n | j } | d k r n` | t k r t j \ } } n? | t k r | j } n$ t | t r | } n | j } | d k rn | t k r2t j \ } } nr | t k re| d k rS| } qt j
j } n? | t k r| j } n$ t | t r| } n | j } | | | | | | f S) NrG r r )r r r r )r r r r )r r r ) r! r piper) r r r7 r r" rA
__stdout__)
r rw r r r r r r r r r r r r S sJ c & " s t | t t f r! | g } n t | } |
rS d d g | } rS | d < d k ri | d } t j \ } } g } x, | d k r | j | t j | } q Wx | D] } t j | q WzqzO| d k rQg } xh | j D]Q \ } } t j
| } d | k r,t d | j | d t j
| q Wn d } t j
t j j
r f } n( t f d d t j | D } t | } | j | t j | | | t t t t | | | | | |
| | | | | | | | | _ d | _ Wd t j | Xt | d
d } | d k rz| d k rz| | k rzt j | | d k r|
d k r| | k rt j | | d k r| d k r| | k rt j | | d k rt j | d | _ t } x: t j | d } | | 7} | s?t | d k r
Pq
WWd t j | X| ry t j | j d Wn t k
rYn Xy | j d
d \ } }! }" Wn. t k
rd } d }! d t! | }" Yn Xt t" | j# d t$ }# |" j# d d }" t% |# t& r|! rt |! d }$ |" d k }% |% rAd }" |$ d k rt j' |$ }" |$ t( j) k r|% r|" d t! | 7}" n |" d t! | 7}" |# |$ |" |# |" d S) Nz/bin/shz-cr rI =z!illegal environment variable namec 3 s- | ]# } t j j t j | Vq d S)N)r pathru fsencode).0dir)r r r <genexpr> s z'Popen._execute_child.<locals>.<genexpr>Tr rG iP :rH s SubprocessError 0s Bad exception data from child: asciierrors
surrogatepass noexecrp z: r r r r r r )*r r byteslistr r r` dupr r] r r8 r dirnametuple
get_exec_pathsetadd_posixsubprocess fork_execsortedmapr7 r r r^ r bytearrayr r waitpidChildProcessErrorsplitreprbuiltinsr r
issubclassr strerrorr ENOENT)&r rc r r r r r r r r r r r r r r r r r orig_executable errpipe_read
errpipe_writelow_fds_to_closelow_fdenv_listkrW executable_list fds_to_keep
devnull_fd errpipe_datapartexception_name hex_errnoerr_msgchild_exception_type errno_numchild_exec_never_calledr )r r r s
%
$
$
$
c C sl | | r | | | _ nI | | r= | | | _ n+ | | r\ | | | _ n t d d S)NzUnknown child exit status!)r r )r r _WIFSIGNALED _WTERMSIG
_WIFEXITED _WEXITSTATUS _WIFSTOPPED _WSTOPSIGr r r _handle_exitstatus
s zPopen._handle_exitstatusc C s | j d k r | j j d s% d Sz yN | j d k rA | j S| | j | \ } } | | j k ru | j | WnU t k
r } z5 | d k r | | _ n | j | k r d | _ WYd d } ~ Xn XWd | j j X| j S)NFr )r r acquirer r5 r r release)r r> _waitpid_WNOHANG_ECHILDr r er r r r@ s c C sM y t j | j | \ } } Wn! t k
rB | j } d } Yn X| | f S)Nr )r r r r )r
wait_flagsr r r r r _try_waitB s
zPopen._try_waitc C s | j d k r | j S| d k s. | d k re | d k rJ t | } n | d k re | j | } | d k r=d } x+| j j d r zI | j d k r P| j t j \ } } | | j k r | j | PWd | j j
X| j | } | d k rt | j | t
| d | d } t j | qz Wnh xe | j d k r| j F | j d k riP| j d \ } } | | j k r| j | Wd QRXq@W| j S)NgMb@?Fr rH g?)r r r r r6 r= r WNOHANGr r5 r7 r rc mintimesleep)r r r delayr r remainingr r r rg O s@
c # C s | j re | j re y | j j Wn t k
r8 Yn X| se y | j j Wn t k
rd Yn Xd } d } | j s i | _ | j r g | j | j <| j r g | j | j <| j r | j | j } | j r | j | j } | j | | j r t
| j } t } | j r=| r=| j | j t
j | j r\| j | j t
j | j r{| j | j t
j x| j r | j | } | d k r| d k rt | j | | j | } | j | | x6| D].\ }
} |
j | j k r| | j | j t } y" | j t j |
j | 7_ Wn/ t k
rt| j |
j |
j j YqX| j t | j k r| j |
j |
j j q|
j | j | j f k rt j |
j d }
|
s | j |
j |
j j | j |
j j |
qWq~WWd QRX| j d | j | | d k rZd j! | } | d k rud j! | } | j" r| d k r| j# | | j j$ } | d k r| j# | | j j$ } | | f S)Nr i r rq )%rw r flushr r _fileobj2outputr r _save_inputr
memoryview_PopenSelectorregister selectors EVENT_WRITE
EVENT_READget_mapr r rc selectr fileobj
_input_offset _PIPE_BUFr r r
unregisterr r r` rg ru ro r r )r rn r r r r
input_viewselectorr readykeyeventschunkr r r r r s
"
& c C s^ | j rZ | j d k rZ d | _ | | _ | j rZ | d k rZ | j j | j j | _ d S)Nr )rw r rP ro encoder )r rn r r r rF s
zPopen._save_inputc C s& | j d k r" t j | j | d S)N)r r rh r )r r r r r r s c C s | j t j d S)N)r r r )r r r r r s c C s | j t j d S)N)r r SIGKILL)r r r r rh s z
Popen.killr )/r r r r r r r r r rA rB r= r r rx ry r r r r r r r< r Z
WAIT_OBJECT_0r r@ rg r r r r rh r WIFSIGNALEDWTERMSIG WIFEXITED WEXITSTATUS
WIFSTOPPEDWSTOPSIGr5 r r> r ZECHILDr= rF r r r r r s^ )
1 H = 4 6 "
1 _ r )<rA platformr r r r@ r r r r r r Exceptionr r
r r r r< r r rN rJ ImportErrordummy_threadingr^ rQ r r rH SelectSelector__all__r+ r, r- r. r/ r0 r1 r2 r r7 r3 r? rF r! r" r) rf r# r$ r' objectr* r( r r% r& r r r r r r <module>, sl
:
,! 2 I