3
\ @ s4 d dl Z e jdkZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dlm
Z G dd de Z
G dd de
ZG dd d e
Zerd dlZd dlZd dlZG d
d d Znhd dlZd dlZd dlZy d dlZW n ek
r d dlZY nX eed d
Zeedrej Z nej Z ddddddddddddd dgZ erd dlm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' e j(dd d d d d d!d"d g G d#d$ d$e)Z*g Z+d%d& Z,d;Z-d<Z.d=Z/d*d+ Z0d,d- Z1dd.d/dZ2d0d Z3dd.d1dZ4G d2d de5Z6ddd3d4d5dZ7d6d7 Z8d8d Z9d9d Z:e5 Z;G d:d de5Z<dS )> NZwin32) monotonicc @ s e Zd ZdS )SubprocessErrorN)__name__
__module__ __qualname__ r r "/usr/lib64/python3.6/subprocess.pyr 9 s r c @ s8 e Zd Zd ddZdd Zedd Zejdd ZdS )
CalledProcessErrorNc C s || _ || _|| _|| _d S )N)
returncodecmdoutputstderr)selfr
r r r
r r r __init__C s zCalledProcessError.__init__c C sb | j rN| j dk rNyd| jtj| j f S tk
rJ d| j| j f S X nd| j| j f S d S )Nr zCommand '%s' died with %r.z)Command '%s' died with unknown signal %d.z.Command '%s' returned non-zero exit status %d.)r
r signalZSignals
ValueError)r r r r __str__I s zCalledProcessError.__str__c C s | j S )N)r )r r r r stdoutU s zCalledProcessError.stdoutc C s
|| _ d S )N)r )r valuer r r r Z s )NN)r r r r r propertyr setterr r r r r < s
r c @ s8 e Zd Zd ddZdd Zedd Zejdd ZdS )
TimeoutExpiredNc C s || _ || _|| _|| _d S )N)r timeoutr r
)r r r r r
r r r r h s zTimeoutExpired.__init__c C s d| j | jf S )Nz'Command '%s' timed out after %s seconds)r r )r r r r r n s zTimeoutExpired.__str__c C s | j S )N)r )r r r r r r s zTimeoutExpired.stdoutc C s
|| _ d S )N)r )r r r r r r v s )NN)r r r r r r r r r r r r r a s
r c @ s e Zd ZdZdZdZdZdZdS ) STARTUPINFOr N)r r r dwFlags hStdInput
hStdOutput hStdError wShowWindowr r r r r s
r ZPIPE_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 @ s6 e Zd ZdZejfddZdd Zdd ZeZ eZ
dS ) HandleFc C s | j sd| _ || d S )NT)closed)r CloseHandler r r Close s z Handle.Closec C s | j sd| _ t| S tdd S )NTzalready closed)r4 intr )r r r r Detach s z
Handle.Detachc C s d| j jt| f S )Nz%s(%d)) __class__r r7 )r r r r __repr__ s zHandle.__repr__N) r r r r4 _winapir5 r6 r8 r: __del__r r r r r r3 s r3 c C sT xNt d d D ]>} | jtjd}|d k ryt j| W q tk
rJ Y qX qW d S )N)
_deadstate)_active_internal_pollsysmaxsizeremover )Zinstresr r r _cleanup s rD c C s* g } t jj}|dkr&| jdd| | S )Nr -O)r@ flagsoptimizeappend)argsr r r r "_optim_args_from_interpreter_flags s
rN c C s ddddddd} t }x:| j D ].\}}ttj|}|dkr"|jd || q"W tjjrh|jd
n$tjjrz|jd tjjr|jd x tj D ]}|jd
| qW ttdi }xDdD ]<}||kr|| }|dkr|}n d||f }|j
d|f qW |S )NdBSvbq)debugdont_write_bytecodeno_siteverbose
bytes_warningquietr rH z-Iz-Ez-sz-W _xoptions faulthandler tracemallocshowalloccount showrefcountutf8Tz%s=%sz-X)r\ r] r^ r_ r` ) rN itemsgetattrr@ rJ rL isolatedignore_environment no_user_site warnoptionsextend)Z flag_opt_maprM flagoptrR Zxoptionsr argr r r _args_from_interpreter_flags s:
rk )r c O sF t ||2}y |j| dS |j |j Y nX W d Q R X d S )N)r )r waitkill)r popenargskwargspr r r r# s c O s6 t | |}|r2|jd}|d kr(| d }t||dS )NrM r )r# getr )rn ro retcoder r r r r$ ( s
c O sT d|krt dd|kr<|d d kr<|jddr4dnd|d< t|t| dd |jS )
Nr z3stdout argument not allowed, it will be overridden.inputuniversal_newlinesF T)r r check)r rq r( r! r )r rn ro r r r r' ; s c @ s& e Zd ZdddZdd Zdd ZdS ) r* Nc C s || _ || _|| _|| _d S )N)rM r
r r
)r rM r
r r
r r r r r s zCompletedProcess.__init__c C sh dj | jdj | jg}| jd k r4|jdj | j | jd k rP|jdj | j dj t| jdj|S )Nz args={!r}zreturncode={!r}z stdout={!r}z stderr={!r}z{}({})z, ) formatrM r
r rL r
typer join)r rM r r r r: x s
zCompletedProcess.__repr__c C s | j r t| j | j| j| jd S )N)r
r rM r r
)r r r r check_returncode s z!CompletedProcess.check_returncode)NN)r r r r r: r{ r r r r r* g s
F)rs r rw c O s | d k r d|krt dt|d< t||}y|j| |d\}}W nV tk
r| |j |j \}}t|j|||dY n |j |j Y nX |j }|r|rt ||j||dW d Q R X t
|j|||S )Nstdinz/stdin and input arguments may not both be used.)r )r r
) r r! r communicater rm rM rl pollr r* ) rs r rw rn ro Zprocessr r
rr r r r r( s*
c C s g }d}x| D ]}g }|r$|j d d|kp8d|kp8| }|rH|j d xj|D ]b}|dkrf|j | qN|dkr|j dt| d g }|j d qN|r|j| g }|j | qNW |r|j| |r|j| |j d qW dj|S ) NF "\rF z\"ru )rL lenrg rz )seqresultZ needquoterj Zbs_bufcr r r list2cmdline s4
r c C sl yt | ddtd}d}W n. tk
rF } z|j}|j}W Y d d }~X nX |dd dkrd|d d }||fS )NT)shellrt r
r rE
r )r' r" r r r
)r dataZexitcodeZexr r r r% s c C s t | d S )NrE )r% )r r r r r& " s
c @ s e Zd ZdZd>dddddeddddddddf fdddddZd d
Zd d Zd
d Ze j
e j fddZ
dd Zdd Zd?ddZdd Zdd Zdd Zer d d Zd d Zd!d" Zdejejejfd#d$Z d@d%d&Z d'd( Z d)d* Z d+d, Z d-d. Z!e!Z"nd/d Zd0d" Ze#j$e#j%e#j&e#j'e#j(e#j)fd1d2Z*de#j+e#j,e-j.fd3d$Z d4d5 Z/dAd6d&Z d7d* Z d8d9 Z0d:d, Z d;d. Z!d<d= Z"dS )Br FrE Nr T)encodingerrorsc C sr t tj | _d | _d| _|d kr(d}t|ts:tdt r|d k rNt
d|d k pd|d k pd|d k }|t kr~|rxd}qd}q|r|rt
dnF|t krd}|r| rt j
dt d}|
d k rt
d|d krt
d
|| _d | _d | _d | _d | _d | _| | _|| _|| _| j|||\}}}}}}t rz|dkrFtj|j d }|dkr`tj|j d }|dkrztj|j d }|p|p| }d| _ y|dkrt j |d || _|rt j | jd|dk||d | _|dkrt j |d
|| _|rt j | j||d| _|dkr6t j |d
|| _|r6t j | j||d| _| j ||||||
| |
|| |||||||| W n xDt!d | j| j| jfD ]*} y | j" W n t#k
r Y nX qW | j sfg } |t$kr| j%| |t$kr| j%| |t$kr| j%| t&| dr| j%| j' xP| D ]H} y*t r<t| t(r<| j) n
t*j"| W n t#k
r^ Y nX qW Y nX d S )NFrE 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_bufferingr r rb)r r _devnullr r r r r r r )+rD threadingZLock
_waitpid_lock_input_communication_started
isinstancer7 TypeError
_mswindowsr _PLATFORM_DEFAULT_CLOSE_FDSwarningswarnRuntimeWarningrM r| r r
pidr
rt r r _get_handlesmsvcrtZopen_osfhandler8 _closed_child_pipe_fdsioopen
TextIOWrapper_execute_childfiltercloseOSErrorr! rL hasattrr r3 r6 os) r rM bufsize
executabler| r r
preexec_fn close_fdsr cwdenvrt startupinfo
creationflagsrestore_signalsstart_new_sessionpass_fdsr r Z
any_stdio_setp2creadp2cwritec2preadc2pwriteerrreaderrwriteZ text_modefZto_closefdr r r r ` s
zPopen.__init__c C s |j ||}|jddjddS )Nz
r
)decodereplace)r r r r r r r _translate_newlines s zPopen._translate_newlinesc C s | S )Nr )r r r r __enter__ s zPopen.__enter__c
C sD | j r| j j | jr | jj z| jr2| jj W d | j X d S )N)r r r
r| rl )r ry r tracebackr r r __exit__ s
zPopen.__exit__c C sT | j s
d S | jd kr(|d| j t| d | j|d | jd krPtd k rPtj| d S )Nz subprocess %s is still running)source)r= )_child_createdr
r ResourceWarningr? r> rL )r Z_maxsizeZ_warnr r r r<
s
z
Popen.__del__c C s" t | ds tjtjtj| _| jS )Nr )r r r devnullO_RDWRr )r r r r _get_devnull s
zPopen._get_devnullc C s |rZy| j j| W nD tk
r( Y n2 tk
rX } z|jtjkrFn W Y d d }~X nX y| j j W nD tk
r| Y n2 tk
r } z|jtjkrn W Y d d }~X nX d S )N)r| writeBrokenPipeErrorr errnoZEINVALr )r rs excr r r _stdin_write s" zPopen._stdin_writec C s | j r|rtd|d kr| j r| j| j| jgjd dkrd }d }| jrV| j| n6| jrr| jj }| jj n| jr| jj }| jj | j nJ|d k rt
| }nd }z| j |||\}}W d d| _ X | j | j |d}||fS )Nz.Cannot send input after starting communicationrF T)r )
r r r| r r
countr readr rl _time _communicate_remaining_time)r rs r r r
endtimestsr r r r} 7 s.
zPopen.communicatec C s | j S )N)r? )r r r r r~ h s z
Popen.pollc C s |d kr d S |t S d S )N)r )r r r r r r n s zPopen._remaining_timec C s& |d kr d S t |kr"t| j|d S )N)r r rM )r r orig_timeoutr r r _check_timeoutv s
zPopen._check_timeoutc C s |d kr |d kr |d kr d S d \}}d\}}d\}} |d krtt jt j}|d krrt jd d\}}
t|}t j|
nj|tkrt jd d\}}t|t| }}n>|tkrtj | j
}n&t |t rtj |}ntj |j
}| j|}|d kr,t jt j}|d krt jd d\}
}t|}t j|
nn|tkrZt jd d\}}t|t| }}n@|tkrttj | j
}n&t |t rtj |}ntj |j
}| j|}|d krt jt j} | d krft jd d\}
} t| } t j|
n~|tkrt jd d\}} t|t| }} nP|tkr&|} n@|tkr@tj | j
} n&t |t rXtj |} ntj |j
} | j| } |||||| fS )NrE 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 r| r r
r r r r r r _r r r r sn
zPopen._get_handlesc C s& t jt j |t j ddt j}t|S )Nr rE )r; ZDuplicateHandleZGetCurrentProcessZDUPLICATE_SAME_ACCESSr3 )r Zhandlehr r r r s
zPopen._make_inheritablec C s< t |tst|}|d kr t }d| ||fkrP| jtjO _| |_||_||_ |
r| jtj
O _tj |_ t
jjdd}dj||}z>tj||d d t| | ||d k rt
j|nd | \}}}}W d | dkr| j |d kr|j |d
k r|j t| drt
j| j d| _X d| _t|| _|| _ tj | d S ) NrE ZCOMSPECzcmd.exez
{} /c "{}"r Tr r r r ) r strr r r r; r1 r r r r2 r0 r r environrq rx Z
CreateProcessr7 fspathr6 r r r r r r3 _handler r5 )r rM 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 sF
zPopen._execute_childc C s, | j d kr&|| jd|kr&|| 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"t jdtdd | j|}|d kr2tj}n t|d }| jd krztj| j |}|tj
krlt | j |tj
| j | _| jS )Nz0'endtime' argument is deprecated; use 'timeout'.rF )
stackleveli )r r DeprecationWarningr r; ZINFINITEr7 r
WaitForSingleObjectr Z WAIT_TIMEOUTr rM GetExitCodeProcess)r r r Ztimeout_millisr r r r rl $ s
z
Popen.waitc C s |j |j |j d S )N)rL r r )r Zfhbufferr r r
_readerthread: s zPopen._readerthreadc C s` | j rDt| d rDg | _tj| j| j | jfd| _d| j_| jj | j rt| d rg | _
tj| j| j | j
fd| _ d| j _| j j | j r| j
| | j d k r| jj| j| | jj rt| j|| j d k r| j j| j| | j j rt| j|d }d }| j r | j}| j j | j r4| j
}| j j |d k rF|d }|d k rX|d }||fS )N _stdout_buff)targetrM T _stderr_buffr )r r r r ZThreadr Z
stdout_threadZdaemonstartr
r Z
stderr_threadr| r rz r Zis_aliver rM r )r rs r r r r
r r r r ? sF
zPopen._communicatec C sl | j d k rd S |tjkr"| j nF|tjkr>tj| jtj n*|tjkrZtj| jtj nt dj
|d S )NzUnsupported signal: {}) r
r SIGTERM terminateZ CTRL_C_EVENTr rm r ZCTRL_BREAK_EVENTr rx )r sigr r r send_signals s
zPopen.send_signalc C sX | j d k rd S ytj| jd W n2 tk
rR tj| j}|tjkrH || _ Y nX d S )NrE )r
r; ZTerminateProcessr PermissionErrorr Z STILL_ACTIVE)r Zrcr r r r s
zPopen.terminatec
C s. d\}}d\}}d
\}} |d kr"n@|t kr8tj \}}n*|tkrJ| j }nt|trZ|}n|j }|d krln@|t krtj \}}n*|tkr| j }nt|tr|}n|j }|d krnh|t krtj \}} nR|tk r|d kr|} n
t j
j } n.|tkr| j } nt|tr|} n|j } |||||| fS ) NrE r r )r r r r )r r r r )r r r ) r! r piper) r r r7 r r" r@
__stdout__)
r r| r r
r r r r r r r r r r sJ
c ) " s t |ttfr|g}nt|}|
r:ddg| } r: |d< d krJ|d }tj \}}g }x |dk r~|j| tj|}q`W x|D ]}tj| qW zz|d k rg }xL|j D ]:\}}tj
|}d|krt d|j|d tj
| qW nd }tj
tj j
r f}n t fddtj|D }t|} | j| tj|||tttt| ||| | |
||||||||| _d | _W d tj| X t| d
d } | dkr| dkr| | krtj| |dkr|
dkr|| krtj| |dkr|d kr|| krtj| | d k r.tj| d | _t } x2tj |d } | | 7 } | sft | d kr<P q<W W d tj| X | ry6tj | jd\} }!| | jkr| j |! nt j!| _"W n t#k
r Y nX y | j$d
d\}"}#}$|$j% }$W n, t k
r d}"d}#dj&t| }$Y nX tt'|"j%dt(}%t)|%t*r|#rt|#d}&|$dk}'|'rdd}$|}(n|}(|&dkrtj+|&}$|&t,j-kr|$dt.|( 7 }$|%|&|$|(|%|$d S ) Nz/bin/shz-cr rG =z!illegal environment variable namec 3 s" | ]}t jjt j| V qd S )N)r pathrz fsencode).0dir)r r r <genexpr> s z'Popen._execute_child.<locals>.<genexpr>Tr rE iP :rF s SubprocessError 0z#Bad exception data from child: {!r}ascii Znoexecru z: r r r r r r )/r r byteslistr r rL dupr ra r r r dirnametuple
get_exec_pathsetadd_posixsubprocessZ fork_execsortedmapr7 r r rb r bytearrayr r waitpid_handle_exitstatusr@ rA r
ChildProcessErrorsplitr rx builtinsr
issubclassr strerrorr ENOENTrepr))r rM r r r r r r r r r r r r r r r r r Zorig_executableZ errpipe_readZ
errpipe_writeZlow_fds_to_closeZlow_fdZenv_listkrR Zexecutable_listZ fds_to_keepZ
devnull_fdZ errpipe_datapartr r Zexception_nameZ hex_errnoZerr_msgZchild_exception_typeZ errno_numZchild_exec_never_calledZ err_filenamer )r r r s
c C sL ||r|| | _ n2||r*||| _ n ||r@|| | _ ntdd S )NzUnknown child exit status!)r
r )r r Z _WIFSIGNALEDZ _WTERMSIGZ
_WIFEXITEDZ _WEXITSTATUSZ _WIFSTOPPEDZ _WSTOPSIGr r r r
X s zPopen._handle_exitstatusc C s | j d kr| jjdsd S zy8| j d k r.| j S || j|\}}|| jkrR| j| W nB tk
r } z&|d k rv|| _ n|j|krd| _ W Y d d }~X nX W d | jj X | j S )NFr )r
r acquirer r
r r release)r r= Z_waitpidZ_WNOHANGZ_ECHILDr r er r r r? j s
c C s> yt j| j|\}}W n tk
r4 | j}d}Y nX ||fS )Nr )r r r r )r Z
wait_flagsr r r r r _try_wait s
zPopen._try_waitc C sV | j d k r| j S |d k r(tjdtdd |d k s8|d k r^|d krLt | }n|d kr^| j|}|d k rd}x| jjdrz6| j d k rP | jt j
\}}|| j kr| j | P W d | jj
X | j|}|dkrt| j|t|d |d}tj| qlW nVxT| j d krN| j8 | j d k r P | jd\}}|| j krB| j | W d Q R X qW | j S )Nz0'endtime' argument is deprecated; use 'timeout'.rF )r gMb@?Fr g?)r
r r r r r r r r r WNOHANGr r
r r rM mintimeZsleep)r r r Zdelayr r Z remainingr r r rl sJ
c # C s | j rZ| j rZy| j j W n tk
r0 Y nX |sZy| j j W n tk
rX Y nX d }d }| jsi | _| jrg | j| j< | jrg | j| j< | jr| j| j }| jr| j| j }| j| | j rt
| j }t }| j r|r|j | j t
j | jr |j | jt
j | jr$|j | jt
j xJ|j rp| j|}|d k r\|dk r\t| j||j|} | j|| x| D ]\}
} |
j| j kr|| j| jt } y | jtj|
j| 7 _W n, tk
r |j |
j |
jj Y n*X | jt | j krf|j |
j |
jj nP|
j| j| jfkrxtj |
jd}
|
sT|j |
j |
jj | j|
j j |
qxW q(W W d Q R X | j | j|d |d k rdj!|}|d k rdj!|}| j"s| j#s| j$r|d k r| j%|| jj"| jj#}|d k r| j%|| jj"| jj#}||fS )Nr i )r rv )&r| r flushr r Z_fileobj2outputr r
_save_inputr
memoryview_PopenSelectorregister selectorsZ EVENT_WRITEZ
EVENT_READZget_mapr r rM selectr Zfileobj
_input_offset _PIPE_BUFr r r Z
unregisterr r rL rl rz r r rt r )r rs r r r r
Z
input_viewZselectorr ZreadykeyZeventschunkr r r r r s
(
c C sR | j rN| jd krNd| _|| _|d k rN| js6| js6| jrN| jj| j j| j j| _d S )Nr )r| r r" r r rt encode)r rs r r r r / s zPopen._save_inputc C s | j d krtj| j| d S )N)r
r rm r )r r r r r r < s
c C s | j tj d S )N)r r r )r r r r r B s c C s | j tj d S )N)r r SIGKILL)r r r r rm G s z
Popen.killr )NN)NN)NN)1r r r r r r r r r r@ rA r r r< r r r} r~ r r r r r r r; r Z
WAIT_OBJECT_0r r? rl r r r r rm r WIFSIGNALEDWTERMSIG WIFEXITED WEXITSTATUS
WIFSTOPPEDWSTOPSIGr
r r r ZECHILDr r r r r r r 2 sb ,
1H @
46
"
4a
r )=r@ platformr r r r r r
r r r r Exceptionr r r r r r; r r r! r ImportErrorZdummy_threadingrb r# r r r ZSelectSelector__all__r+ r, r- r. r/ r0 r1 r2 rg r7 r3 r> rD r! r" r) rN rk r# r$ r' objectr* r( r r% r& r r r r r r <module>, sp
%
(
.,!2I