o
0iK @ sn d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dlm
Z d dl Z zd dl
Z
W n eyD dZ
Y nw g dZz d dlZd dlZdZW n eyl dZd dlZd dlZd dlZY n0w d dlmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z( e)g d G dd d e*Z+G d
d d e+Z,G d d
d
e+Z-erG dd dZ.G dd de/Z0ne1eddZ2e3edrej4Z5nej6Z5erdZ7dd Z8ng Z7dd Z8dZ9dZ:dZ;dd Zd"d# Z?dd d$d%Z@G d&d' d'eAZBddddd(d)d*ZCd+d, ZDd-d. ZEd/d0 ZFd1d2 ZGeG ZHdZIG d3d4 d4ZJdS )5 N) monotonic)PopenPIPESTDOUTcall
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_JOB)r 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' 1/opt/alt/python310/lib64/python3.10/subprocess.pyr e s r c @ : e Zd Z d ddZdd Zedd Zejdd ZdS )
r Nc C || _ || _|| _|| _d S N)
returncodecmdoutputstderr)selfr, r- r. r/ r' r' r( __init__o
zCalledProcessError.__init__c C s` | j r(| j dk r(z
d| jt| j f W S ty' d| j| j f Y S w d| j| j f 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
ValueErrorr0 r' r' r( __str__u s
zCalledProcessError.__str__c C s | j S r+ r. r5 r' r' r( stdout s zCalledProcessError.stdoutc C
|| _ d S r+ r7 r0 valuer' r' r( r8
NNr$ r% r& r1 r6 propertyr8 setterr' r' r' r( r h s
r c @ r) )
r Nc C r* r+ )r- timeoutr. r/ )r0 r- rA r. r/ r' r' r( r1 r2 zTimeoutExpired.__init__c C s d| j | jf S )Nz'Command '%s' timed out after %s seconds)r- rA r5 r' r' r( r6 s
zTimeoutExpired.__str__c C | j S r+ r7 r5 r' r' r( r8 s zTimeoutExpired.stdoutc C r9 r+ r7 r: r' r' r( r8 r< r= r> r' r' r' r( r s
r c @ s, e Zd ZdddddddddZdd ZdS )r# r NdwFlags hStdInput
hStdOutput hStdError wShowWindowlpAttributeListc C s0 || _ || _|| _|| _|| _|pdg i| _d S )N handle_listrC )r0 rD rE rF rG rH rI r' r' r( r1 s zSTARTUPINFO.__init__c C s@ | j }d|v rt|d |d< t| j| j| j| j| j|dS )NrJ rC ) rI copylistr# rD rE rF rG rH )r0 Z attr_listr' r' r( rK s
zSTARTUPINFO.copy)r$ r% r& r1 rK r' r' r' r( r# s
r# c @ s2 e Zd ZdZejfddZdd Zdd ZeZ dS ) HandleFc C s | j s d| _ || d S d S )NT)closed)r0 CloseHandler' r' r( Close s z Handle.Closec C s | j s
d| _ t| S td)NTzalready closed)rN intr4 r5 r' r' r( Detach s z
Handle.Detachc C s d| j jt| f S )Nz%s(%d)) __class__r$ rQ r5 r' r' r( __repr__ s zHandle.__repr__N)
r$ r% r& rN _winapirO rP rR rT __del__r' r' r' r( rM s rM ZPIPE_BUFi PollSelectorc C s d S r+ r' r' r' r' r( _cleanup rX c C sZ t d u rd S t d d D ] } | jtjd}|d ur*zt | W q ty) Y q w q d S )N
_deadstate)_active_internal_pollsysmaxsizeremover4 )instresr' r' r( rX s c C s, g } t jj}|dkr| dd| | S )Nr -O)r^ flagsoptimizeappend)argsr; r' r' r( "_optim_args_from_interpreter_flags s rl c C sP ddddddd} t }| D ]\}}ttj|}|dkr(|d || qtjjr3|d
ntjjr<|d tjjrE|d tj d d }tjj
}ttd
i }d|v }|dkrd| d n|rk| d |rr| d |D ] }|d| qt|r| d dD ] }||v r|| } | du r|}
nd|| f }
| d|
f q|S )NdBSvbq)debugdont_write_bytecodeno_siteverbose
bytes_warningquietr rf z-Iz-Ez-s _xoptionsdev zerror::BytesWarningzdefault::BytesWarningdefaultz-W)-Xrz )Z faulthandler tracemallocZ
importtimeZ showrefcountutf8Tz%s=%sr} )
rl itemsgetattrr^ rh rj isolatedignore_environment no_user_site warnoptionsrw r` extend) Z flag_opt_maprk flagoptrp Zwarnoptsrw Zxoptionsdev_moder; argr' r' r( _args_from_interpreter_flags sV
r rA c O sT t |i |}z|j| dW W d S | 1 s#w Y d S )Nr )r waitkill)rA popenargskwargspr' r' r( r Q s r c O s< t | i |}|r |d}|d u r| d }t||dS )Nrk r )r getr )r r retcoder- r' r' r( r b s
r c O sx d|v r t dd|v r0|d d u r0|ds'|ds'|ds'|dr*d}nd }||d< t|t| d
d |jS ) Nr8 z3stdout argument not allowed, it will be overridden.inputuniversal_newlinestextencodingerrors T)r8 rA check)r4 r r r r8 )rA r r emptyr' r' r( r
u s " r
c @ s2 e Zd Z dddZdd ZeejZdd Z dS ) r Nc C r* r+ )rk r, r8 r/ )r0 rk r, r8 r/ r' r' r( r1 r2 zCompletedProcess.__init__c C sh d | jd | jg}| jd ur|d | j | jd ur(|d | j d t| jd|S )Nz args={!r}zreturncode={!r}z stdout={!r}z stderr={!r}z{}({})z, ) formatrk r, r8 rj r/ typer$ join)r0 rk r' r' r( rT s
zCompletedProcess.__repr__c C s" | j rt| j | j| j| jd S r+ )r, r rk r8 r/ r5 r' r' r( check_returncode s z!CompletedProcess.check_returncoder= )
r$ r% r& r1 rT classmethodtypes GenericAlias__class_getitem__r r' r' r' r( r s
r )r capture_outputrA r c O s& | d ur| dd urtdt|d< |r0| dd us$| dd ur(tdt|d< t|d< t|i |L}z |j| |d\}}W n' tyc } z| trZ| \| _| _ |
d } ~ w | | }
|r||
r|t |
|j
||dW d n1 sw Y t|j
|
||S )Nstdinz/stdin and input arguments may not both be used.r8 r/ z@stdout and stderr arguments may not be used with capture_output.r r. r/ )r r4 r r communicater r
_mswindowsr8 r/ r pollr rk r ) r r rA r r r Zprocessr8 r/ excr r' r' r( r s@ r c C s g }d}t tj| D ]d}g }|r|d d|v p d|v p | }|r(|d |D ]1}|dkr6|| q*|dkrM|dt| d g }|d q*|rV|| g }|| q*|rc|| |ro|| |d q d|S ) NF "\ z\"r )maposfsdecoderj lenr r )seqresultZ needquoter Zbs_bufcr' r' r( list2cmdline s8
r c
C sp z t | ddtd}d}W n ty% } z |j}|j}W Y d }~nd }~ww |dd dkr4|d d }||fS )NT)shellr r/ r rc
)r
r r r. r, )r- dataZexitcodeZexr' r' r( r \ s r c C s t | d S Nr{ )r )r- r' r' r( r { s r c
C s t sttds
dS tjdv rdS zd. Z!e.j/e.j0e.j1fd?d@Z2de.j3e.j4e5j6fdAd0Z&dBdC Z7dDd2 Z'dEd6 Z)dFdG Z8dHd8 Z*dId: Z+dJdK Z,dS )Pr Frc NTr r' )usergroup extra_groupsr r r umaskpipesizec + C s t t | _d | _d| _|d u rd}t|ts td|d u r$d}t|ts-tdt r8|d ur7t
dn |rD|sDt dt
d}|
d urLt
d|d krTt
d
|| _d | _d | _d | _d | _d | _|| _|| _|| _|d ur| d urt| t|krtd | |||\}}} } } } t r|dkrt| d }| dkrt| d } | dkrt| d } |p|p|p| | _ | j r|d u rd | _}d
| _ d| _ | j r|dkrd} d}nd} d }!|d ur-t t!dst
dt|t"rzd d l#}"W n t$y t
dw |"%|j&}!nt|tr|}!n td't(||!d k r-t
d|! d }#|d urt t!ds>t
dt|t"rHt
dg }#|D ];}$t|$t"rrzd d l#}"W n t$yf t
dw |#)|"%|$j& qLt|$tr|#)|$ qLtd't(|$|#D ]}%|%d k rt
d|% qd }&|d urt t!dst
dt|t"rzd d l*}'W n t$y t
dw |'+|j,}&n
t|tr|}&ntd |&d k rt
d |& zp|dkrt-.|d || _| j rt-j/| jd| ||d | _| dkr t-.| d || _| j r t-j/| j||d!| _| dkr8t-.| d || _| j r8t-j/| j||d!| _| 0||||||
| |
|| ||| | | | ||!|#|&|| W d S t1d | j| j| jfD ]}(z|(2 W qc t3yw Y qcw | j sg })|t4kr|))| |t4kr|))| |t4kr|))| t | d"r|))| j5 |)D ]#}*zt rt|*t6r|*7 nt!2|* W q t3y Y qw )#NFrc zbufsize must be an integerzpipesize 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.localeg ?r{ setregidz>The 'group' parameter is not supported on the current platformzHThe group parameter cannot be a string on systems without the grp modulez,Group must be a string or an integer, not {}z!Group ID cannot be negative, got setgroupszEThe 'extra_groups' parameter is not supported on the current platformz#Groups must be a list, not a stringzIItems in extra_groups cannot be strings on systems without the grp modulez9Items in extra_groups must be a string or integer, not {}setreuidz=The 'user' parameter is not supported on the current platformzGThe user parameter cannot be a string on systems without the pwd modulez#User must be a string or an integerz User ID cannot be negative, got wb)
write_throughline_bufferingr r rb)r r _devnull)8rX threadingZLock
_waitpid_lock_input_communication_started
isinstancerQ TypeErrorr r4 warningswarnRuntimeWarningrk r r8 r/ pidr, r r r boolr _get_handlesmsvcrtZopen_osfhandlerR text_mode_sigint_wait_secs_closed_child_pipe_fdsr r strgrp ImportErrorZgetgrnamZgr_gidr r rj pwdgetpwnamZpw_uidioopen
TextIOWrapper_execute_childfiltercloser r r rM rP )+r0 rk bufsize
executabler r8 r/
preexec_fn close_fdsr cwdenvr startupinfo
creationflagsrestore_signalsstart_new_sessionpass_fdsr r r r r r r r p2creadp2cwritec2preadc2pwriteerrreaderrwriter gidr gidsZ extra_groupZ gid_checkuidr fZto_closefdr' r' r( r1 sX
zPopen.__init__c C s@ d| j j d| j d| jd}t|dkr |d d d }|S )NP L z...>)rS r$ r, rk r )r0 Zobj_reprr' r' r( rT s zPopen.__repr__c C rB r+ )r r5 r' r' r( r s zPopen.universal_newlinesc C s t || _d S r+ )r r )r0 r r' r' r( r s c C s | ||}|ddddS )Nz
r
)decodereplace)r0 r r r r' r' r( _translate_newlines s zPopen._translate_newlinesc C s | S r+ r' r5 r' r' r( __enter__
rY zPopen.__enter__c C s | j r| j | jr| j z0| jr| j W |tkr;| jdkr6z | j| jd W n ty5 Y nw d| _d S | d S |tkrf| jdkr]z | j| jd W n ty\ Y nw d| _ Y d S | w )Nr r ) r8 r r/ r KeyboardInterruptr _waitr r )r0 exc_typer; tracebackr' r' r( __exit__
s8
zPopen.__exit__c C s\ | j sd S | jd u r|d| j t| d | j|d | jd u r*td ur,t| d S d S d S )Nz subprocess %s is still running)sourcerZ )_child_createdr, r ResourceWarningr] r\ rj )r0 Z_maxsizeZ_warnr' r' r( rV ) s
z
Popen.__del__c C s" t | dsttjtj| _| jS )Nr )r r r devnullO_RDWRr r5 r' r' r( _get_devnull8 s
zPopen._get_devnullc
C s |r-z| j | W n" ty Y n ty, } z|jtjkr!n W Y d }~nd }~ww z| j W d S ty? Y d S tyY } z|jtjkrMn W Y d }~d S d }~ww r+ )r writeBrokenPipeErrorr errnoZEINVALr )r0 r r r' r' r( _stdin_write= s. zPopen._stdin_writec C sT | j r
|r
td|d u rN| j sN| j| j| jgd dkrNd }d }| jr+| | n| jr9| j }| j n
| jrF| j }| j | ||fS |d urXt
| }nd }z>z | |||\}}W n- t y |d ur{t
| j| |}n| j}d| _z| j|d W ty Y w w W d| _ nd| _ w | j | |d}||fS )Nz.Cannot send input after starting communicationr r r T)r r4 r r8 r/ countr# readr r _time _communicater minr _remaining_timer r )r0 r rA r8 r/ endtimesigint_timeoutstsr' r' r( r V sR
zPopen.communicatec C s
| S r+ )r] r5 r' r' r( r s z
Popen.pollc C s |d u rd S |t S r+ )r& )r0 r* r' r' r( r) s
zPopen._remaining_timec C sR |d u rd S |st |kr't| j||rd|nd |r#d|dd dd S )Nr r )r& r rk r )r0 r* orig_timeoutZ
stdout_seqZ
stderr_seqskip_check_and_raiser' r' r( _check_timeout s zPopen._check_timeoutc C s~ |d ur
t | }z| j|dW S ty> |d ur&t| j| |}n| j}d| _z| j|d W ty= Y w w )Nr r )r& r r r( r r) r )r0 rA r* r+ r' r' r( r s(
z
Popen.waitc C s t | dd }t m}tr,|dkr||j |dkr!||j |dkr+||j n9|dkr?|dkr?||kr?|tj| |dkrR|dkrR||krR|tj| |dkre|dkre||kre|tj| |d urp|tj| W d n1 szw Y d| _d S )Nr rc T) r
contextlib ExitStackr callbackrP r r r ) r0 r r r r r r Z
devnull_fdstackr' r' r( _close_pipe_fds s*
zPopen._close_pipe_fdsc C sr |d u r|d u r|d u rdS d\}}d\}}d\}} |d u r;t t j}|d u r:t d d\}}
t|}t |
n4|tkrQt d d\}}t|t|}}n |tkr]t |
}nt |t rht |}nt |
}| |}|d u rt t j}|d u rt d d\}
}t|}t |
n4|tkrt d d\}}t|t|}}n |tkrt |
}nt |t rt |}nt |
}| |}|d u rt t j} | d u rt d d\}
} t| } t |
n?|tkrt d d\}} t|t| }} n(|tkr |} n |tkrt |
} nt |t r%t |} nt |
} | | } |||||| fS )N)rc rc rc rc rc rc rc rc r )rU Z GetStdHandler Z
CreatePiperM rO r r
r Z
get_osfhandler r rQ fileno_make_inheritabler r r ) r0 r r8 r/ r r r r r r _r' r' r( r sx
zPopen._get_handlesc C s( t t |t ddt j}t|S )Nr r{ )rU ZDuplicateHandleZGetCurrentProcessZDUPLICATE_SAME_ACCESSrM )r0 handlehr' r' r( r7 4 s
zPopen._make_inheritablec C s t dd |D S )Nc S s, h | ]}|d @ d kst |t jkr|qS ) )rU Z GetFileTypeZFILE_TYPE_CHAR).0r9 r' r' r( D s z,Popen._filter_handle_list..)rL )r0 rJ r' r' r( _filter_handle_list= s zPopen._filter_handle_listc ! C sz t |trn't |tr|
rtdt|g}nt |tjr*|
r$tdt|g}nt|}|d ur7t|}|d u r?t }n| }d| ||fv}|r]| j
t j O _
| |_
||_||_|j}t|ojd|v oj|d }|sr|r|r|d u r{i }|_t|dg }|d< |r|t| t|t|g7 }| ||d d < |r|stdt d}|
r| j
t jO _
t j|_|stj d}|stj dd } tj | d
d }tj |st d tj |r|}n|}d
!||}|d urt|}t"#d|||| z t $||d d t| | ||| \} } } } W | %| | |
||| n | %| | |
||| w d| _&t'| | _(| | _)t *| d S )Nz$bytes args is not allowed on Windows0path-like args is not allowed when shell is truerc rJ z?startupinfo.lpAttributeList['handle_list'] overriding close_fdsFZComSpecZ
SystemRootr ZSystem32zcmd.exez:shell not found: neither %ComSpec% nor %SystemRoot% is setz
{} /c "{}"subprocess.PopenT)+r r bytesr r r PathLiker r# rK rD rU r rE rF rG rI r rL r rQ r> r r r r r rH environpathr isabsFileNotFoundErrorr r^ auditZ
CreateProcessr4 r rM _handler rO )!r0 rk r r r r r r r r r r r r r r r Zunused_restore_signalsZ
unused_gidZ unused_gidsZ
unused_uidZ unused_umaskZunused_start_new_sessionZuse_std_handlesZattribute_listZhave_handle_listrJ ZcomspecZ system_rootZhpZhtr tidr' r' r( r J s
zPopen._execute_childc C s. | j d u r|| jd|kr|| j| _ | j S Nr )r, rH )r0 r[ Z_WaitForSingleObjectZ_WAIT_OBJECT_0Z_GetExitCodeProcessr' r' r( r] s
zPopen._internal_pollc C s` |d u r t j}nt|d }| jd u r-t | j|}|t jkr&t| j|t | j| _| jS )Ni )
rU ZINFINITErQ r, WaitForSingleObjectrH Z WAIT_TIMEOUTr rk GetExitCodeProcess)r0 rA Ztimeout_millisr r' r' r( r s
z Popen._waitc C s | | | d S r+ )rj r% r )r0 Zfhbufferr' r' r(
_readerthread s zPopen._readerthreadc C sT | j r!t| ds!g | _tj| j| j | jfd| _d| j_| j | j rBt| dsBg | _
tj| j| j | j
fd| _ d| j _| j | j rJ|
| | j d urc| j| | | j rct| j|| j d ur|| j | | | j r|t| j|d }d }| j r| j}| j | j r| j
}| j |r|d nd }|r|d nd }||fS )N _stdout_buff)targetrk T _stderr_buffr )r8 r rO r ZThreadrN Z
stdout_threadZdaemonstartr/ rQ Z
stderr_threadr r# r r) Zis_aliver rk r )r0 r r* r- r8 r/ r' r' r( r' sJ
zPopen._communicatec C sp | j d urd S |tjkr| d S |tjkr"t| jtj d S |tjkr1t| jtj d S t d
|)NzUnsupported signal: {}) r, r3 SIGTERM terminateZ CTRL_C_EVENTr r r ZCTRL_BREAK_EVENTr4 r r0 Zsigr' r' r( send_signal! s
zPopen.send_signalc C sX | j d urd S z
t| jd W d S ty+ t| j}|tjkr% || _ Y d S w r )r, rU ZTerminateProcessrH PermissionErrorrL Z STILL_ACTIVE)r0 Zrcr' r' r( rT / s
zPopen.terminatec
C s d\}}d\}}d\}} |d u rn3|t kr0t \}}| jdkr/ttdr/t|tj| j n|tkr9| }n t |t
rA|}n| }|d u rJn3|t krht \}}| jdkrgttdrgt|tj| j n|tkrq| }n t |t
ry|}n| }|d u rnD|t krt \}} | jdkrttdrt| tj| j n&|t kr|dkr|} nt
j } n|tkr| } n t |t
r|} n| } |||||| fS )Nr5 r F_SETPIPE_SZrc )r r piper r fcntlrX r
r r rQ r6 r r^
__stdout__)
r0 r r8 r/ r r r r r r r' r' r( r D s`
c C s |d u rt j}i } |r&g } dD ]}
tt|
d }|d ur!| | q| | d< g }||| fD ]}|dkr;|t j|f q-|df|df|
dffD ]\}}|dkrX|t j||f qG|r_|| d< t j|||fi | | _d| _ |
||||| |
d S ) N)SIGPIPEZSIGXFZSIGXFSZZ setsigdefrc r r{ r file_actionsT) r rC r r3 rj POSIX_SPAWN_CLOSEPOSIX_SPAWN_DUP2r r r r4 )r0 rk 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}nt |tjr |
rtd|g}nt|}|
r7ttdr)dnd}|dg| } r7 |d< d u r?|d t d ||| t
rtj r|d u r|s|s|d u r| dksd| d kr|dksl|d kr|dkst|d kr|s|d u r|d u r|d u r|dk r|
| ||| | |
|||
d S }t \}}g }|d
k r|| t|}|d
k s|D ]} t| qzz||d urg } | D ] \} } t| } d | v rtd | | d t| qnd } t tj r f} nt fd
dt|D } t|}!|!| t|| |ttt t |!|| | | |
||||||||||||| _ d| _ W t| nt| w | | | |
||| t! }" t"|d}#|"|#7 }"|#rbt#|"dkrcnqNW t| nt| w |"rzt$| j d\}$}%|$| j kr| %|% ntj&| _'W n
t(y Y nw z|")dd \}&}'}(|(* }(W n ty d}&d}'d+t|"}(Y nw t,t-|&*dt.})t/|)t0r|'rt |'d}*|(dk}+|+rd}(|},n|},|*dkrt1|*}(|)|*|(|,|)|(d S )Nr? Zgetandroidapilevelz/system/bin/shz/bin/shz-cr r@ rc r r; =z!illegal environment variable namec 3 s$ | ]
}t jt | V qd S r+ )r rD r fsencode)r< dirr r' r( s
z'Popen._execute_child..TiP :s SubprocessError 0z#Bad exception data from child: {!r}ascii Znoexecr )2r r rA r rB r rL r r^ rG _USE_POSIX_SPAWNrD dirnamera rY rj dupr r rc r4 r
get_exec_pathsetadd_posixsubprocessZ fork_execsortedr rQ r r r4 bytearrayr% r waitpid_handle_exitstatusr_ r, ChildProcessErrorr r r r builtinsr
issubclassr strerror)-r0 rk r r r r 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_listkrp Zexecutable_listZ fds_to_keepZ errpipe_datapartr r, Zexception_nameZ hex_errnoerr_msgZchild_exception_typeZ errno_numZchild_exec_never_calledZ err_filenamer' re r( r s
c C s( ||r
|| | _ d S ||| _ d S r+ )r, )r0 r, waitstatus_to_exitcodeZ _WIFSTOPPEDZ _WSTOPSIGr' r' r( ru K s zPopen._handle_exitstatusc
C s | j d u rm| jdsd S zXz#| j d ur | j W W | j S || j|\}}|| jkr1| | W n" tyT } z|d urB|| _ n|j|krJd| _ W Y d }~nd }~ww W | j | j S W | j | j S | j w | j S )NFr )r, r acquirereleaser ru r r" )r0 r[ Z_waitpidZ_WNOHANGZ_ECHILDr r, er' r' r( r] W s6
c C sB zt | j|\}}W ||fS ty | j}d}Y ||fS w rJ )r rt r rv )r0 Z
wait_flagsr r, r' r' r( _try_waitz s zPopen._try_waitc C s^ | j d ur | j S |d urot | }d} | jdrRz0| j d ur*W | j | j S | tj\}}|| jkrE| | W | j | j S W | j n| j w |
|}|dkrat | j |t
|d |d}t| q| j d u r| j( | j d ur W d | j S | d\}}|| jkr| | W d n1 sw Y | j d u st| j S )NgMb@?TFr r g?)r, r& r r~ r r r WNOHANGr ru r) r rk r( timesleep)r0 rA r* Zdelayr r, Z remainingr' r' r( r sP
c
C s$ | j r*| js*z| j W n ty Y nw |s*z| j W n ty) Y nw d }d }| jsFi | _| jr=g | j| j< | jrFg | j| j< | jrO| j| j }| jrX| j| j }| | | j ret
| j }t }| j rv|rv| | j t
j | jr| jjs| | jt
j | jr| jjs| | jt
j | r=| |}|d ur|dk r| j||||dd td||} | |||| | D ]u\}
} |
j| j u r|| j| jt } z| jt|
j| 7 _W n ty | |
j |
j Y qw | jt | j kr| |
j |
j q|
j| j| jfv r8t |
jd}
|
s/| |
j |
j | j|
j |
q| sW d n 1 sHw Y | j | |d |d ur`d!|}|d urjd!|}| j"r|d ur~| #|| jj$| jj%}|d ur| #|| 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_fileobj2outputr8 r/ _save_inputr
memoryview_PopenSelectorregister selectorsZ EVENT_WRITErN Z
EVENT_READZget_mapr) r/ RuntimeErrorselectZfileobj
_input_offset _PIPE_BUFr r r
unregisterr r% rj r r r r r r )r0 r r* r- r8 r/ Z
input_viewZselectorrA ZreadykeyZeventschunkr r' r' r( r' s
,
c C sV | j r#| jd u r%d| _|| _|d ur'| jr)| j| j j| j j| _d S d S d S d S d S rJ )r r r r encoder r )r0 r r' r' r( r s
zPopen._save_inputc C sB | | jd ur d S z
t| j| W d S ty Y d S w r+ )r r, r r r ProcessLookupErrorrU r' r' r( rV " s
c C | tj d S r+ )rV r3 rS r5 r' r' r( rT B c C r r+ )rV r3 SIGKILLr5 r' r' r( r G r z
Popen.kill)rc NNNNNTFNNNNr TFr' r= )Fr+ )9r$ r% r& r r1 rT r r r r r? r r@ r r r r^ r_ r r rV r r# r r r) r/ r r4 r r r7 r> r rU rK Z
WAIT_OBJECT_0rL r] r rN r' rV rT r ra r r}
WIFSTOPPEDWSTOPSIGru rt r r" ZECHILDr r r' r' r' r( r s 5
|
D
H
2<' &
#
)f r )Krw r" r r r r3 r^ r r r0 r r& r rZ r __all__r rU r ModuleNotFoundErrorrq r r r r r r r r r r r r r r r r r r r! r" r Exceptionr r r r# rQ rM r r r rW r ZSelectSelectorr\ rX r r r
rl r r r r
objectr r r r r r rk Z
_USE_VFORKr r' r' r' r( s " P
%
;4% FI
2