)_child_createdr
r ResourceWarningr@ r? rM )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 rt excr r r _stdin_write s" zPopen._stdin_writec C s | j r|rtd|dkr| j r| j| j| jgjddkrd}d}| jrV| j| n6| jrr| jj }| jj n| jr| jj }| jj | j nJ|dk rt
| }nd}z| j |||\}}W dd| _ X | j | j |d}||fS )a4 Interact with process: Send data to stdin. Read data from
stdout and stderr, until end-of-file is reached. Wait for
process to terminate.
The optional "input" argument should be data to be sent to the
child process (if self.universal_newlines is True, this should
be a string; if it is False, "input" should be bytes), or
None, if no data should be sent to the child.
communicate() returns a tuple (stdout, stderr). These will be
bytes or, if self.universal_newlines was True, a string.
z.Cannot send input after starting communicationNrG T)r )
r r r} r r
countr readr rm _time _communicate_remaining_time)r rt r r r
endtimestsr r r r~ 7 s.
zPopen.communicatec C s | j S )zSCheck if child process has terminated. Set and return returncode
attribute.)r@ )r r r r r h s z
Popen.pollc C s |dkr dS |t S dS )z5Convenience for _communicate when computing timeouts.N)r )r r r r r r n s zPopen._remaining_timec C s& |dkr dS t |kr"t| j|dS )z2Convenience for checking if a timeout has expired.N)r r rN )r r orig_timeoutr r r _check_timeoutv s
zPopen._check_timeoutc C s |dkr |dkr |dkr d
S d
\}}d\}}d\}} |dkrtt jt j}|dkrrt jdd\}}
t|}t j|
nj|tkrt jdd\}}t|t| }}n>|tkrtj | j
}n&t |t rtj |}ntj |j
}| j|}|dkr,t jt j}|dkrt jdd\}
}t|}t j|
nn|tkrZt jdd\}}t|t| }}n@|tkrttj | j
}n&t |t rtj |}ntj |j
}| j|}|dkrt jt j} | dkrft jdd\}
} t| } t j|
n~|tkrt jdd\}} t|t| }} nP|tkr&|} n@|tkr@tj | j
} n&t |t rXtj |} ntj |j
} | j| } |||||| fS )z|Construct and return tuple with IO objects:
p2cread, p2cwrite, c2pread, c2pwrite, errread, errwrite
NrF 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
CreatePiper4 r6 r" r* r Z
get_osfhandler r r8 fileno_make_inheritabler/ r0 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 )z2Return a duplicate of handle, which is inheritabler rF )r< ZDuplicateHandleZGetCurrentProcessZDUPLICATE_SAME_ACCESSr4 )r Zhandlehr r r r s
zPopen._make_inheritablec C sJ | st dt|ts t|}|dkr.t }d | ||fkr^| jtjO _| |_||_ ||_
|
r| jtj O _tj |_
tjjdd}dj||}z>tj||ddt| | ||dk rtj|nd| \}}}}W d| d
kr| j |d kr|j |d kr|j t| dr tj| j d| _X d| _t|| _ || _ tj | dS )
z$Execute program (MS Windows version)z"pass_fds not supported on Windows.NrF ZCOMSPECzcmd.exez
{} /c "{}"r Tr r r r ) AssertionErrorr strr r r r< r2 r r r r3 r1 r r environrr ry Z
CreateProcessr8 fspathr7 r r r r r r4 _handler r6 )r rN 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 sH
zPopen._execute_childc C s, | j dkr&|| jd|kr&|| j| _ | j S )zCheck if child process has terminated. Returns returncode
attribute.
This method is called by __del__, so it can only refer to objects
in its local scope.
Nr )r
r )r r> Z_WaitForSingleObjectZ_WAIT_OBJECT_0Z_GetExitCodeProcessr r r r@ s
zPopen._internal_pollc C s |dk r"t jdtdd | j|}|dkr2tj}n t|d }| jdkrztj| j |}|tj
krlt | j |tj
| j | _| jS )zOWait for child process to terminate. Returns returncode
attribute.Nz0'endtime' argument is deprecated; use 'timeout'.rG )
stackleveli )r r DeprecationWarningr r< ZINFINITEr8 r
WaitForSingleObjectr Z WAIT_TIMEOUTr rN GetExitCodeProcess)r r r Ztimeout_millisr r r r rm $ s
z
Popen.waitc C s |j |j |j d S )N)rM 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)targetrN T _stderr_buffr )r r r r ZThreadr Z
stdout_threadZdaemonstartr
r Z
stderr_threadr} r r{ r Zis_aliver rN r )r rt r r r r
r r r r ? sF
zPopen._communicatec C sl | j dk rdS |tjkr"| j nF|tjkr>tj| jtj n*|tjkrZtj| jtj nt dj
|dS )z Send a signal to the process.NzUnsupported signal: {}) r
r SIGTERM terminateZ CTRL_C_EVENTr rn r ZCTRL_BREAK_EVENTr ry )r sigr r r send_signals s
zPopen.send_signalc C sX | j dk rdS ytj| jd W n2 tk
rR tj| j}|tjkrH || _ Y nX dS )zTerminates the process.NrF )r
r< ZTerminateProcessr PermissionErrorr Z STILL_ACTIVE)r Zrcr r r r s
zPopen.terminatec
C s. d\}}d\}}d \}} |dkr"n@|t kr8tj \}}n*|tkrJ| j }nt|trZ|}n|j }|dkrln@|t krtj \}}n*|tkr| j }nt|tr|}n|j }|dkrnh|t krtj \}} nR|tk r|d kr|} n
t j
j } n.|tkr| j } nt|tr|} n|j } |||||| fS )
z|Construct and return tuple with IO objects:
p2cread, p2cwrite, c2pread, c2pwrite, errread, errwrite
rF Nr r )r r r r )r r r r )r r r ) r" r piper* r r r8 r r# rA
__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< dkrJ|d }tj \}}g }x |dk r~|j| tj|}q`W x|D ]}tj| qW zz|dk rg }xL|j D ]:\}}tj
|}d|krt d|j|d tj
| qW nd}tj
tj j
r f}n t fdd tj|D }t|} | j| tj|||tttt| ||| | |
||||||||| _d
| _W dtj| X t| d d} | dkr| dkr| | krtj| |dkr|
dkr|| krtj| |d kr|d kr|| krtj| | dk r.tj| d
| _t } x2tj |d
} | | 7 } | sft | d
kr s z'Popen._execute_child..Tr rF iP :rG s SubprocessError 0z#Bad exception data from child: {!r}ascii Znoexecrv z: r r r r r r )/r r byteslistr r rM dupr rb r r r dirnametuple
get_exec_pathsetadd_posixsubprocessZ fork_execsortedmapr8 r r rc r bytearrayr r waitpid_handle_exitstatusrA rB r
ChildProcessErrorsplitr ry builtinsr
issubclassr strerrorr ENOENTrepr))r rN 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_listkrS 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@|| | _ ntddS )z:All callers to this function MUST hold self._waitpid_lock.zUnknown child exit status!N)r
r )r r Z _WIFSIGNALEDZ _WTERMSIGZ
_WIFEXITEDZ _WEXITSTATUSZ _WIFSTOPPEDZ _WSTOPSIGr r r r X s zPopen._handle_exitstatusc C s | j dkr| jjdsdS zy8| j dk r.| j S || j|\}}|| jkrR| j| W nB tk
r } z&|dk rv|| _ n|j|krd| _ W Y dd}~X nX W d| jj X | j S )zCheck if child process has terminated. Returns returncode
attribute.
This method is called by __del__, so it cannot reference anything
outside of the local scope (nor can any methods it calls).
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 )z:All callers to this function MUST hold self._waitpid_lock.r )r r r r
)r Z
wait_flagsr r r r r _try_wait s
zPopen._try_waitc C sp | j dk r| j S |dk r(tjdtdd |dk s8|dk r^|dkrLt | }n|dkr^| j|}|dk rd}x| jjdrzL| j dk rP | jt j
\}}|| j ks|dkst || j kr| j
| P W d| jj X | j|}|dkrt| j|t|d |d}tj| qnW nXxV| j dkrh| j8 | j dk r6P | jd\}}|| j krZ| j
| W dQ R X qW | j S ) zOWait for child process to terminate. Returns returncode
attribute.Nz0'endtime' argument is deprecated; use 'timeout'.rG )r gMb@?Fr g?)r
r r r r r r r r r WNOHANGr r r r r rN mintimeZsleep)r r r Zdelayr r Z remainingr r r rm sL
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 rw )&r} r flushr r Z_fileobj2outputr r
_save_inputr
memoryview_PopenSelectorregister selectorsZ EVENT_WRITEZ
EVENT_READZget_mapr r rN selectr Zfileobj
_input_offset _PIPE_BUFr r r Z
unregisterr r rM rm r{ r r ru r )r rt 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 ru encode)r rt r r r r / s zPopen._save_inputc C s | j dkrtj| j| dS )z Send a signal to the process.N)r
r rn r )r r r r r r < s
c C s | j tj dS )z/Terminate the process with SIGTERM
N)r r r )r r r r r B s c C s | j tj dS )z*Kill the process with SIGKILL
N)r r SIGKILL)r r r r rn G s z
Popen.killr )NN)NN)NN)2r r r r r r r r r r rA rB r r r= r r r~ r r r r r r r r< r Z
WAIT_OBJECT_0r r@ rm r r r r rn r WIFSIGNALEDWTERMSIG WIFEXITED WEXITSTATUS
WIFSTOPPEDWSTOPSIGr r r r ZECHILDr r r r r r r! 2 sd +
1H @
46
"
4a
r )>r rA platformr r r r r r r r r r Exceptionr r r r r r< r r r# r" ImportErrorZdummy_threadingrc r% r r r ZSelectSelector__all__r, r- r. r/ r0 r1 r2 r3 rh r8 r4 r? rE r" r# r* rO rl r$ r% r( objectr+ r) r r& r' r r! r r r r * sr
%
(
.,!2I