)�_child_createdr
r� �ResourceWarningr@ r? rM )r Z_maxsizeZ_warnr r r r=
s
z
Popen.__del__c C s" t | d�s tjtjtj�| _| jS )Nr� )r� r� r� �devnull�O_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|jtjkr�n� W Y d d }~X nX d S )N)r} �write�BrokenPipeErrorr� �errnoZEINVALr� )r rt �excr r r � _stdin_write s" zPopen._stdin_writec C s� | j r|rtd��|dkr�| j r�| j| j| jgjd�dkr�d}d}| jrV| j|� n6| jrr| jj� }| jj� n| jr�| jj� }| jj� | j � nJ|dk r�t
� | }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
�endtime�stsr 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|tkr�t jdd�\}}t|�t|� }}n>|tkr�tj | j
� �}n&t |t �� r�tj |�}ntj |j
� �}| j|�}|dk�r,t jt j�}|dk�r�t jdd�\}
}t|�}t j|
� nn|tk�rZt jdd�\}}t|�t|� }}n@|tk�rttj | j
� �}n&t |t ��r�tj |�}ntj |j
� �}| j|�}|dk�r�t jt j�} | dk�rft jdd�\}
} t| �} t j|
� n~|tk�rt jdd�\}} t|�t| � }} nP|tk�r&|} n@|tk�r@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 Zhandle�hr r r r� � s
zPopen._make_inheritablec C s< t |t�st|�}|dkr t� }d| ||fkrP| jtjO _| |_||_||_ |
r�| jtj
O _tj |_ t
jjdd�}dj||�}z>tj||ddt| �| ||dk r�t
j|�nd|� \}}}}W d| d kr�| j� |d
kr�|j� |d k� r�|j� t| d��rt
j| j� d| _X d| _t|�| _|| _ tj |� dS ) z$Execute program (MS Windows version)NrF ZCOMSPECzcmd.exez
{} /c "{}"r� Tr� r� r� r� ) r� �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� � sF
zPopen._execute_childc C s, | j dkr&|| jd�|kr&|| j�| _ | j S )z�Check 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 Zfh�bufferr r r �
_readerthread: s zPopen._readerthreadc C s` | j rDt| d� rDg | _tj| j| j | jfd�| _d| j_| jj� | j r�t| d� r�g | _
tj| j| j | j
fd�| _ d| j _| j j� | j r�| j
|� | j d k r�| jj| j|�� | jj� r�t| j|��| j d k r�| j j| j|�� | j j� r�t| 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_threadZdaemon�startr
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|t�rZ|}n|j� }|dkrln@|t kr�tj� \}}n*|tkr�| j� }nt|t�r�|}n|j� }|dkr�nh|t kr�tj� \}} nR|tk� r�|d kr�|} n
t j
j� } n.|tk�r| j� } nt|t��r|} 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 |ttf�r|g}nt|�}|
r:ddg| }� r:� |d< � dkrJ|d � � }tj� \}}g }x |dk r~|j|� tj|�}q`W x|D ]}tj|� q�W �z�z�|dk r�g }xL|j � D ]:\}}tj
|�}d|kr�t d��|j|d tj
|� � q�W nd}tj
� �� tj j
� ��r� f}n t� fdd �tj|�D ��}t|�} | j|� tj|||tttt| ���||| | |
||||||||�| _d
| _W dtj|� X t| d d�} | dk�r�| dk�r�| | k�r�tj| � |dk�r�|
dk�r�|| k�r�tj|� |d k�r|d k�r|| k�rtj|� | dk �r.tj| � d
| _t� } x2tj |d
�} | | 7 } | �sft | �d
k�r 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� �bytes�listr� r� rM �dupr� rb r� r r� �dirname�tuple�
get_exec_path�set�add�_posixsubprocessZ fork_exec�sorted�mapr8 r� r� rc r� � bytearrayr� r� �waitpid�_handle_exitstatusrA rB r
�ChildProcessError�splitr� ry �builtinsr �
issubclassr� �strerrorr� �ENOENT�repr))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_list�krS Zexecutable_listZ fds_to_keepZ
devnull_fdZ errpipe_data�partr� 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@||� | _ ntd��dS )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�| jjd�sdS z�y8| j dk r.| j S || j|�\}}|| jkrR| j|� W nB tk
r� } z&|dk rv|| _ n|j|kr�d| _ W Y dd}~X nX W d| jj� X | j S )z�Check 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 sV | j dk r| j S |dk r(tjdtdd� |dk s8|dk r^|dkrLt� | }n|dkr^| j|�}|dk r�d}x�| jjd�r�z6| j dk r�P | jt j
�\}}|| j kr�| j |� P W d| jj
� X | j|�}|dkr�t| j|��t|d |d�}tj|� qlW nVxT| j dk�rN| j�8 | j dk �r P | jd�\}}|| j k�rB| j |� W dQ R X q�W | j S ) zOWait for child process to terminate. Returns returncode
attribute.Nz0'endtime' argument is deprecated; use 'timeout'.rG )r� g����Mb@?Fr g�������?)r
r� r� r� r� r� r� r r r� �WNOHANGr� r r r rN �min�timeZsleep)r r r� Zdelayr� r� Z remainingr r r rm � 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 }| js�i | _| jr�g | j| j< | jr�g | j| j< | jr�| j| j }| jr�| j| j }| j|� | j r�t
| j �}t � ���}| j r�|r�|j | j t
j� | j�r |j | jt
j� | j�r$|j | jt
j� �xJ|j� �rp| j|�}|d k �r\|dk �r\t| j|��|j|�} | j||� x�| D ]�\}
} |
j| j k�r|| j| jt � } y | jtj|
j| �7 _W n, tk
�r� |j |
j� |
jj� Y n*X | jt | j �k�rf|j |
j� |
jj� nP|
j| j| jfk�rxtj |
jd�}
|
�sT|j |
j� |
jj� | j|
j j |
� �qxW �q(W W d Q R X | j | j|�d� |d k �r�dj!|�}|d k �r�dj!|�}| 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�_PopenSelector�register� 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 Zready�keyZevents�chunkr� 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� � WIFSIGNALED�WTERMSIG� WIFEXITED� WEXITSTATUS�
WIFSTOPPED�WSTOPSIGr 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