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 s z'Popen._execute_child..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 , sp
%
(
.,!2I