U
if1 @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dlm
Z ddddddd d
d d d
dddgZ zd dl
Z
d dlZdZW n0 ek
r dZd dlZd dlZd dlZY nX d dlmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% e &ddddddddd d d d d d!d"d#d$d%d&g G d'd de'Z(G d(d d e(Z)G d)d de(Z*erG d*d d Z+G d+d, d,e,Z-n&e.ed-d.Z/e0ed/rej1Z2nej3Z2erdZ4d0d1 Z5n g Z4d2d1 Z5d3Z6d4Z7d5Z8d6d7 Z9d8d9 Z:dd:d;dZ;dd de>Z?ddddd?d@d Z@dAdB ZAdCd ZBdDd ZCdEdF ZDeD ZEG dGd de>ZFdS )H N) monotonicPopenPIPESTDOUTcall
check_callgetstatusoutput getoutput check_outputrunCalledProcessErrorDEVNULLSubprocessErrorTimeoutExpiredCompletedProcessTF)CREATE_NEW_CONSOLECREATE_NEW_PROCESS_GROUPSTD_INPUT_HANDLESTD_OUTPUT_HANDLESTD_ERROR_HANDLESW_HIDESTARTF_USESTDHANDLESSTARTF_USESHOWWINDOWABOVE_NORMAL_PRIORITY_CLASSBELOW_NORMAL_PRIORITY_CLASSHIGH_PRIORITY_CLASSIDLE_PRIORITY_CLASSNORMAL_PRIORITY_CLASSREALTIME_PRIORITY_CLASSCREATE_NO_WINDOWDETACHED_PROCESSCREATE_DEFAULT_ERROR_MODECREATE_BREAKAWAY_FROM_JOBr r r r r r r r STARTUPINFOr r r r r r r r r! r" c @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r' r' //opt/alt/python38/lib64/python3.8/subprocess.pyr ` s c @ s8 e Zd Zd ddZdd Zedd Zejdd ZdS )
r Nc C s || _ || _|| _|| _d S N)
returncodecmdoutputstderr)selfr* r+ r, r- r' r' r( __init__j s zCalledProcessError.__init__c C sh | j rT| j dk rTzd| jt| j f W S tk
rP d| j| j f Y 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
ValueErrorr. r' r' r( __str__p s zCalledProcessError.__str__c C s | j S r) r, r2 r' r' r( stdout| s zCalledProcessError.stdoutc C s
|| _ d S r) r4 r. valuer' r' r( r5 s )NNr$ r% r& r/ r3 propertyr5 setterr' r' r' r( r c s
c @ s8 e Zd Zd ddZdd Zedd Zejdd ZdS )
r Nc C s || _ || _|| _|| _d S r) )r+ timeoutr, r- )r. r+ r; r, r- r' r' r( r/ s zTimeoutExpired.__init__c C s d| j | jf S )Nz'Command '%s' timed out after %s seconds)r+ r; r2 r' r' r( r3 s
zTimeoutExpired.__str__c C s | j S r) r4 r2 r' r' r( r5 s zTimeoutExpired.stdoutc C s
|| _ d S r) r4 r6 r' r' r( r5 s )NNr8 r' r' r' r( r s
c @ s, e Zd ZdddddddddZdd ZdS )r# r NdwFlags hStdInput
hStdOutput hStdError wShowWindowlpAttributeListc C s0 || _ || _|| _|| _|| _|p(dg i| _d S )N handle_listr< )r. r= r> r? r@ rA rB r' r' r( r/ s zSTARTUPINFO.__init__c C s@ | j }d|kr"t|d |d< t| j| j| j| j| j|dS )NrC r< ) rB copylistr# r= r> r? r@ rA )r. Z attr_listr' r' r( rD s
zSTARTUPINFO.copy)r$ r% r& r/ rD r' r' r' r( r# s c @ s2 e Zd ZdZejfddZdd Zdd ZeZ 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)rG intr1 r2 r' r' r( Detach s z
Handle.Detachc C s d| j jt| f S )Nz%s(%d)) __class__r$ rJ r2 r' r' r( __repr__ s zHandle.__repr__N)
r$ r% r& rG _winapirH rI rK rM __del__r' r' r' r( rF s
rF ZPIPE_BUFi PollSelectorc C s d S r) r' r' r' r' r( _cleanup s rQ c C s\ t d kr d S t d d D ]>} | jtjd}|d k rzt | W q tk
rT Y qX qd S )N
_deadstate)_active_internal_pollsysmaxsizeremover1 )instresr' r' r( rQ s c C s* g } t jj}|dkr&| dd| | S )Nr -O)rV flagsoptimizeappend)argsr7 r' r' r( "_optim_args_from_interpreter_flags s
rd c C sV ddddddd} t }| D ].\}}ttj|}|dkr |d || q tjjrd|d
n$tjjrv|d tjjr|d tj d d }tjj
}ttd
i }d|k}|dkr| d n|r| d |r| d |D ]}|d| q|r
| d dD ]B}||kr|| } | dkr4|}
n d|| f }
| d|
f q|S )NdBSvbq)debugdont_write_bytecodeno_siteverbose
bytes_warningquietr r^ z-Iz-Ez-s _xoptionsdev zerror::BytesWarningzdefault::BytesWarningdefaultz-W)-Xrr )Z faulthandler tracemallocZ
importtimeZshowalloccountZ showrefcountutf8Tz%s=%sru )
rd itemsgetattrrV r` rb isolatedignore_environment no_user_site warnoptionsro rX extend) Z flag_opt_maprc flagoptrh Zwarnoptsro Zxoptionsdev_moder7 argr' r' r( _args_from_interpreter_flags sP
r r; c
O sL t ||8}z|j| dW W 5 Q R S | Y nX W 5 Q R X d S )Nr )r waitkill)r; popenargskwargspr' r' r( r L s c O s6 t | |}|r2|d}|d kr(| d }t||dS )Nrc r )r getr )r r retcoder+ r' r' r( r ] s
c O sb d|krt dd|krJ|d d krJ|ds8|dr>d}nd}||d< t|t| dd |jS )
Nr5 z3stdout argument not allowed, it will be overridden.inputuniversal_newlinestext T)r5 r; check)r1 r r r r5 )r; r r emptyr' r' r( r
p s #c @ s& e Zd ZdddZdd Zdd ZdS ) r Nc C s || _ || _|| _|| _d S r) )rc r* r5 r- )r. rc r* r5 r- r' r' r( r/ s zCompletedProcess.__init__c C sh d | jd | jg}| jd k r4|d | j | jd k rP|d | j d t| jd|S )Nz args={!r}zreturncode={!r}z stdout={!r}z stderr={!r}z{}({})z, ) formatrc r* r5 rb r- typer$ join)r. rc r' r' r( rM s
zCompletedProcess.__repr__c C s | j r t| j | j| j| jd S r) )r* r rc r5 r- r2 r' r' r( check_returncode s z!CompletedProcess.check_returncode)NN)r$ r% r& r/ rM r r' r' r' r( r s
)r capture_outputr; r c O s | d k r&| dd k r tdt|d< |r^| dd k sF| dd k rNtdt|d< t|d< t||}z|j| |d\}}W n^ tk
r } z,| tr| \| _| _ n|
W 5 d } ~ X Y n | Y nX | }
|r|
rt |
|j
||dW 5 Q R X t|j
|
||S )Nstdinz/stdin and input arguments may not both be used.r5 r- z@stdout and stderr arguments may not be used with capture_output.r r, r- )r r1 r r communicater r
_mswindowsr5 r- r pollr rc r ) r r r; r r r Zprocessr5 r- excr r' r' r( r s8 c C s g }d}t tj| D ]}g }|r*|d d|kp>d|kp>| }|rN|d |D ]b}|dkrj|| qR|dkr|dt| d g }|d qR|r|| g }|| qR|r|| |r|| |d qd|S ) NF "\ z\"r )maposfsdecoderb lenr~ r )seqresultZ needquoter Zbs_bufcr' r' r( list2cmdline s4
r c
C sl zt | ddtd}d}W n. tk
rF } z|j}|j}W 5 d }~X Y nX |dd dkrd|d d }||fS )NT)shellr r- r r[
)r
r r r, r* )r+ dataZexitcodeZexr' r' r( r R s c C s t | d S Nrs )r )r+ r' r' r( r q s
c
C s t sttdsdS tjdkr dS zjtd} | jdd}t|dkrHt|d }t t
t |d d
}tjd kr|d kr|d
krW dS W n t tt
fk
r Y nX dS )N posix_spawnFdarwinTCS_GNU_LIBC_VERSIONrs )maxsplitr r .ZlinuxZglibc)r )r hasattrr rV platformconfstrsplitr r1 tupler rJ AttributeErrorOSError)ZverpartsZlibcversionr' r' r( _use_posix_spawn~ s
r c @ s e Zd ZdZdJdddddd Zed
d Zejd d Zd
d Zdd Z dd Z
e j e
jfddZdd Zdd ZdKddZdd Zd d ZdLd d ZdMd!d"Zd#d$ Zerd%d& Zd'd( Zd)d* Zd+d, Z de j e j e j fd-d.Z!d/d0 Z"d1d2 Z#d3d4 Z$d5d6 Z%d7d8 Z&e&Z'nd9d& Zd:d; Z(dZ0de)j1e)j2e3j4fd?d.Z!d@dA Z5dBd0 Z"dCd4 Z$dDdE Z6dFd6 Z%dGd8 Z&dHdI Z'dS )Nr Fr[ NTr r' )encodingerrorsr c C sl t t | _d | _d| _|d kr(d}t|ts:tdt rP|d k rt
dn8|rh|sht dt
d}|
d k rxt
d|dkrt
d || _d | _d | _d | _d | _d | _|| _|| _|d k r| d k rt| t|krtd
| |||\}}}}}}t rN|dkrt| d}|dkr4t| d}|dkrNt| d}|pb|pb|pb| | _ d | _ d| _ | j r|d krd}d}nd}z|dkrt |d
|| _| j rt j!| jd|||d| _|dkrt |d|| _| j rt j!| j||d| _|dkr:t |d|| _| j r:t j!| j||d| _| "||||||
| |
|| |||||||| W n t#d | j| j| jfD ]*} z | $ W n t%k
r Y nX q| j s`g } |t&kr| '| |t&kr| '| |t&kr| '| t(| dr| '| j) | D ]H} z*t r8t| t*r8| + n
t,$| W n t%k
rZ Y nX q Y nX d S )NFr[ zbufsize must be an integerz0preexec_fn is not supported on Windows platformsz pass_fds overriding close_fds.Tz2startupinfo is only supported on Windows platformsr z4creationflags is only supported on Windows platformszlCannot disambiguate when both text and universal_newlines are supplied but different. Pass one or the other.g ?rs wb)
write_throughline_bufferingr r rb)r r _devnull)-rQ threadingZLock
_waitpid_lock_input_communication_started
isinstancerJ TypeErrorr r1 warningswarnRuntimeWarningrc r r5 r- pidr* r r boolr _get_handlesmsvcrtZopen_osfhandlerK text_mode_sigint_wait_secs_closed_child_pipe_fdsioopen
TextIOWrapper_execute_childfiltercloser r rb r r rF rI r ) r. rc bufsize
executabler r5 r-
preexec_fn close_fdsr cwdenvr startupinfo
creationflagsrestore_signalsstart_new_sessionpass_fdsr r r p2creadp2cwritec2preadc2pwriteerrreaderrwriter fZto_closefdr' r' r( r/ s
zPopen.__init__c C s | j S r) )r r2 r' r' r( r ~ s zPopen.universal_newlinesc C s t || _d S r) )r r )r. r r' r' r( r s c C s | ||}|ddddS )Nz
r
)decodereplace)r. r r r r' r' r( _translate_newlines s zPopen._translate_newlinesc C s | S r) r' r2 r' r' r( __enter__ s zPopen.__enter__c C s | j r| j | jr | j d z| jr4| j W 5 |tkr| jdkrrz| j| jd W n tk
rp Y nX d| _ d S | X d S )Nr r ) r5 r r- KeyboardInterruptr _waitr r r )r. exc_typer7 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 rPt| d S )Nz subprocess %s is still running)sourcerR )_child_createdr* r ResourceWarningrU rT rb )r. Z_maxsizeZ_warnr' r' r( rO s
z
Popen.__del__c C s" t | ds ttjtj| _| jS )Nr )r r r devnullO_RDWRr r2 r' r' r( _get_devnull s
zPopen._get_devnullc
C s |rZz| j | W nD tk
r( Y n2 tk
rX } z|jtjkrFn W 5 d }~X Y nX z| j W nD tk
r| Y n2 tk
r } z|jtjkrn W 5 d }~X Y nX d S r) )r writeBrokenPipeErrorr errnoZEINVALr )r. r r r' r' r( _stdin_write s" zPopen._stdin_writec C sT | j r|rtd|d kr| j s| j| j| jgd dkrd }d }| jrT| | n6| jrp| j }| j n| jr| j }| j | n|d k rt
| }nd }zz| |||\}}W nh t k
r, |d k rt
| j| |}n| j}d| _z| j|d W n tk
r$ Y nX Y nX W 5 d| _ X | j | |d}||fS )Nz.Cannot send input after starting communicationr Tr r )r r1 r r5 r- countr readr r _time _communicater minr _remaining_timer r )r. r r; r5 r- endtimesigint_timeoutstsr' r' r( r sH
zPopen.communicatec C s | S r) )rU r2 r' r' r( r s z
Popen.pollc C s |d kr d S |t S d S r) )r )r. r r' r' r( r " s zPopen._remaining_timec C sL |d kr d S |st |krHt| j||r0d|nd |r@d|nd dd S )Nr r )r r rc r )r. r orig_timeoutZ
stdout_seqZ
stderr_seqskip_check_and_raiser' r' r( _check_timeout* s zPopen._check_timeoutc C s |d k rt | }z| j|dW S tk
r |d k rLt| j| |}n| j}d| _z| j|d W n tk
r| Y nX Y nX d S )Nr r )r r r r r r r )r. r; r r
r' r' r( r 6 s
z
Popen.waitc C s t | dd }t }trX|dkr.||j |dkrB||j |dkr||j nr|dkr~|dkr~||kr~|tj| |dkr|dkr||kr|tj| |dkr|dkr||kr|tj| |d k r|tj| W 5 Q R X d| _d S )Nr r[ T) ry
contextlib ExitStackr callbackrI r r r ) r. r r r r r r Z
devnull_fdstackr' r' r( _close_pipe_fdsM s$
zPopen._close_pipe_fdsc C s~ |d kr |d kr |d kr dS d\}}d\}}d\}} |d krtt t j}|d krt d d\}}
t|}t |
nh|tkrt d d\}}t|t| }}n<|tkrt |
}n$t |t rt |}nt |
}| |}|d kr*t t j}|d krt d d\}
}t|}t |
nn|tkrXt d d\}}t|t| }}n@|tkrrt |
}n&t |t rt |}nt |
}| |}|d krt t j} | d krdt d d\}
} t| } t |
n~|tkrt d d\}} t|t| }} nP|tkr$|} n@|tkr>t |
} n&t |t rVt |} nt |
} | | } |||||| fS )N)r[ r[ r[ r[ r[ r[ r[ r[ r )rN Z GetStdHandler Z
CreatePiperF rH r r
r Z
get_osfhandler r rJ fileno_make_inheritabler r r ) r. r r5 r- r r r r r r _r' r' r( r n st
zPopen._get_handlesc C s& t t |t ddt j}t|S )Nr rs )rN ZDuplicateHandleZGetCurrentProcessZDUPLICATE_SAME_ACCESSrF )r. handlehr' r' r( r s zPopen._make_inheritablec C s t dd |D S )Nc S s, h | ]$}|d @ d ks$t |t jkr|qS ) )rN Z GetFileTypeZFILE_TYPE_CHAR).0r r' r' r( s z,Popen._filter_handle_list..)rE )r. rC r' r' r( _filter_handle_list s zPopen._filter_handle_listc C sz t |tr nNt |tr.|
r"tdt|g}n,t |tjrR|
rFtdt|g}nt|}|d k rlt|}|d kr|t }n| }d| ||fk}|r| j
t j O _
| |_
||_||_|j}t|od|ko|d }|s|r^|r^|d kri }|_t|dg }|d< |r0|t| t|t|g7 }| ||d d < |r^|sZtdt d}|
r| j
t jO _
t j|_|stj d}|stj dd }tj |d
d }tj |st d tj |r|}n|}d
!||}|d k r t|}t"#d|||| z,t %||d d t| | ||| \}}}} W 5 | $| | |
||| X d| _&t'|| _(|| _)t *| d S )Nz$bytes args is not allowed on Windows0path-like args is not allowed when shell is truer[ rC z?startupinfo.lpAttributeList['handle_list'] overriding close_fdsFZComSpecZ
SystemRootr ZSystem32zcmd.exez:shell not found: neither %ComSpec% nor %SystemRoot% is setz
{} /c "{}"subprocess.PopenT)+r strbytesr r r PathLiker r# rD r= rN r r> r? r@ rB r rE r rJ r r r r r r rA environpathr isabsFileNotFoundErrorr rV auditr Z
CreateProcessr rF _handler rH ) r. rc r r r r r r r r r r r r r r r Zunused_restore_signalsZunused_start_new_sessionZuse_std_handlesZattribute_listZhave_handle_listrC ZcomspecZ system_rootZhpZhtr tidr' r' r( r s
zPopen._execute_childc C s, | j d kr&|| jd|kr&|| j| _ | j S Nr )r* r( )r. rS Z_WaitForSingleObjectZ_WAIT_OBJECT_0Z_GetExitCodeProcessr' r' r( rU H s
zPopen._internal_pollc C s^ |d krt j}n t|d }| jd krXt | j|}|t jkrJt| j|t | j| _| jS )Ni )
rN ZINFINITErJ r* WaitForSingleObjectr( Z WAIT_TIMEOUTr rc GetExitCodeProcess)r. r; Ztimeout_millisr r' r' r( r Y s
z Popen._waitc C s | | | d S r) )rb r r )r. Zfhbufferr' r' r(
_readerthreadi s zPopen._readerthreadc C s\ | j rBt| dsBg | _tj| j| j | jfd| _d| j_| j | j rt| dsg | _
tj| j| j | j
fd| _ d| j _| j | j r|
| | j d k r| j| | | j rt| j|| j d k r| j | | | j rt| j|d }d }| j r| j}| j | j r0| j
}| j |r>|d nd }|rP|d nd }||fS )N _stdout_buff)targetrc T _stderr_buffr )r5 r r/ r ZThreadr. Z
stdout_threadZdaemonstartr- r1 Z
stderr_threadr r r r Zis_aliver rc r )r. r r r r5 r- r' r' r( r n sJ
zPopen._communicatec C sl | j d k rd S |tjkr"| nF|tjkr>t| jtj n*|tjkrZt| jtj nt d
|d S )NzUnsupported signal: {}) r* r0 SIGTERM terminateZ CTRL_C_EVENTr r r ZCTRL_BREAK_EVENTr1 r r. Zsigr' r' r( send_signal s
zPopen.send_signalc C sX | j d k rd S zt| jd W n2 tk
rR t| j}|tjkrH || _ Y nX d S r )r* rN ZTerminateProcessr( PermissionErrorr, Z STILL_ACTIVE)r. Zrcr' r' r( r4 s
zPopen.terminatec
C s, d\}}d\}}d\}} |d kr"n@|t kr8t \}}n*|tkrJ| }nt|trZ|}n| }|d krln@|t krt \}}n*|tkr| }nt|tr|}n| }|d krnf|t krt \}} nP|tkr|dkr|} n
t j
} n.|tkr| } nt|tr|} n| } |||||| fS )Nr r[ ) r r piper
r r rJ r r rV
__stdout__)
r. r r5 r- r r r r r r r' r' r( r sP
c C s |d krt j}i } |rJg } dD ]"}
tt|
d }|d k r | | q | | d< g }||| fD ] }|dkrX|t j|f qX|df|df|
dffD ]"\}}|dkr|t j||f q|r|| d< t j|||f| | _d| _ |
||||| |
d S ) N)SIGPIPEZSIGXFZSIGXFSZZ setsigdefr[ r rs r file_actionsT) r r# ry r0 rb POSIX_SPAWN_CLOSEPOSIX_SPAWN_DUP2r r r r )r. rc r r r r r r r r r r ZsigsetZsignameZsignumr< r Zfd2r' r' r( _posix_spawn s< zPopen._posix_spawnc ) s t |ttfr|g}n(t |tjr6|
r.td|g}nt|}|
rlttdrPdnd}|dg| } rl |d< d kr||d t d ||| t
r tj r |d kr |s |s |d kr | dks| d kr |dks|d kr |dks|d kr |s |
| ||| | |
|||
d S }t \}}g }|d
k rT|| t|}q2|D ]}t| qXzJz|d k rg }| D ]>\}}t|}d |krtd ||d t| qnd }t tj r f} n t fd
dt|D } t|} | | t|| |ttt t | ||| | |
||||||||| _ d| _ W 5 t| X | | | |
||| t! } t"|d} | | 7 } | rt#| dkrqqW 5 t| X | rz6t$| j d\} }!| | j kr| %|! ntj&| _'W n t(k
r Y nX z | )dd \}"}#}$|$* }$W n, tk
rb d}"d}#d+t| }$Y nX t,t-|"*dt.}%t/|%t0r|#rt |#d}&|$dk}'|'rd}$|}(n|}(|&dkrt1|&}$|%|&|$|(|%|$d S )Nr Zgetandroidapilevelz/system/bin/shz/bin/shz-cr r r[ r r =z!illegal environment variable namec 3 s" | ]}t jt | V qd S r) )r r$ r fsencode)r dirr r' r( r s z'Popen._execute_child..TiP :s SubprocessError 0z#Bad exception data from child: {!r}ascii Znoexecr )2r r r! r r" r rE r rV r' _USE_POSIX_SPAWNr$ dirnamer? r8 rb dupr rx rA r1 r
get_exec_pathsetadd_posixsubprocessZ fork_execsortedr rJ r r r bytearrayr r waitpid_handle_exitstatusrW r* ChildProcessErrorr r r ry builtinsr
issubclassr strerror))r. rc r r r r r r r r r r r r r r r r r Z
unix_shellZorig_executableZ errpipe_readZ
errpipe_writeZlow_fds_to_closeZlow_fdZenv_listkrh Zexecutable_listZ fds_to_keepZ errpipe_datapartr r Zexception_nameZ hex_errnoerr_msgZchild_exception_typeZ errno_numZchild_exec_never_calledZ err_filenamer' rC 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( rS s zPopen._handle_exitstatusc
C s | j d kr| jdsd S zz>| j d k r4| j W W pS || j|\}}|| jkrX| | W nB tk
r } z$|d k r||| _ n|j|krd| _ W 5 d }~X Y nX W 5 | j X | j S )NFr )r* r acquirereleaser rS r r )r. rS Z_waitpidZ_WNOHANGZ_ECHILDr r er' r' r( rU s
c C s> zt | j|\}}W n tk
r4 | j}d}Y nX ||fS r* )r rR r rT )r. Z
wait_flagsr r r' r' r( _try_wait s
zPopen._try_waitc C s | j d k r| j S |d k rt | }d}| jdr~z>| j d k rDW 0q| tj\}}|| jkrn| | W qW 5 | j X |
|}|dkrt | j |t
|d |d}t| q&n\| j d kr| jB | j d k rW 5 Q R q| d\}}|| jkr
| | W 5 Q R X q| j S )NgMb@?Fr r g?)r* r r r[ r\ r^ r WNOHANGr rS r r rc r timesleep)r. r; r Zdelayr r Z remainingr' r' r( r s6
c
C s" | j rX| jsXz| j W n tk
r. Y nX |sXz| j W n tk
rV Y nX d }d }| jsi | _| jr~g | j| j< | jrg | j| j< | jr| j| j }| jr| j| j }| | | j rt
| j }t }| j r|r| | j t
j | jr| jjs| | jt
j | jr6| jjs6| | jt
j | r| |}|d k rz|dk rz| j||||dd td||} | |||| | D ]\}
} |
j| j kr6|| j| jt } z | jt|
j| 7 _W n, tk
r
| |
j |
j Y n*X | jt | j kr| |
j |
j nP|
j| j| jfkrt |
jd}
|
st| |
j |
j | j|
j |
qq6W 5 Q R X | j | |d |d k rd!|}|d k rd!|}| j"r|d k r| #|| jj$| jj%}|d k r| #|| jj$| jj%}||fS )Nr T)r
zN_check_timeout(..., skip_check_and_raise=True) failed to raise TimeoutExpired.i r r )&r r flushr r Z_fileobj2outputr5 r- _save_inputr
memoryview_PopenSelectorregister selectorsZ EVENT_WRITErG Z
EVENT_READZget_mapr r RuntimeErrorselectZfileobj
_input_offset _PIPE_BUFr r r Z
unregisterr r rb r r r r r r )r. r r r r5 r- Z
input_viewZselectorr; ZreadykeyZeventschunkr r' r' r( r ' s
$
c C sF | j rB| jd krBd| _|| _|d k rB| jrB| j| j j| j j| _d S r* )r r rj r encoder r )r. r r' r' r( rc s zPopen._save_inputc C s | j d krt| j| d S r) )r* r r r r5 r' r' r( r6 s
c C s | tj d S r) )r6 r0 r3 r2 r' r' r( r4 s c C s | tj d S r) )r6 r0 SIGKILLr2 r' r' r( r s z
Popen.kill)r[ NNNNNTFNNNNr TFr' )NN)F)N)7r$ r% r& r r/ r9 r r: r r r rV rW r r rO r r r r r r r r r r r r r rN r+ Z
WAIT_OBJECT_0r, rU r r. r r6 r4 r r? r WIFSIGNALEDWTERMSIG WIFEXITED WEXITSTATUS
WIFSTOPPEDWSTOPSIGrS rR r_ r ZECHILDr^ rc r' r' r' r( r s .
D
H
|
26'
#
)f )GrU r r r r` r0 rV r r r r r __all__r rN r ModuleNotFoundErrorrO ri rg r r r r r r r r r r r r r r r r r! r" r~ Exceptionr r r r# rJ rF ry rk r rP re ZSelectSelectorrT rQ r r r
rd r r r r
objectr r r r r r rI r r' r' r' r( , s P
%
;3" EI
/