a
R�flF � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dlm
Z d dl Z z d dl
Z
W n ey� dZ
Y n0 z d dlZW n ey� dZY n0 g d�Zzd dlZd dlZdZW n. ey� dZd dlZd dlZd dlZY n`0 d dlmZmZmZmZm 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(m)Z) e�*g d�� G dd � d e+�Z,G d
d � d e,�Z-G d d
� d
e,�Z.e�r�G dd� d�Z/G dd� de0�Z1n&e2edd�Z3e4ed��r�ej5Z6nej7Z6e�r�dZ8dd� Z9n g Z8dd� Z9dZ:dZ;dZ<dd � Z=d d � Z>dd �d d!�Z?d"d#� Z@dd �d$d%�ZAG d&d'� d'eB�ZCddddd(�d)d*�ZDd+d,� ZEd-d.� ZFd/d0� ZGd1d2� ZHeH� ZIG d3d4� d4eB�ZJdS )5� N)� monotonic)�Popen�PIPE�STDOUT�call�
check_call�getstatusoutput� getoutput� check_output�run�CalledProcessError�DEVNULL�SubprocessError�TimeoutExpired�CompletedProcessTF)�CREATE_NEW_CONSOLE�CREATE_NEW_PROCESS_GROUP�STD_INPUT_HANDLE�STD_OUTPUT_HANDLE�STD_ERROR_HANDLE�SW_HIDE�STARTF_USESTDHANDLES�STARTF_USESHOWWINDOW�ABOVE_NORMAL_PRIORITY_CLASS�BELOW_NORMAL_PRIORITY_CLASS�HIGH_PRIORITY_CLASS�IDLE_PRIORITY_CLASS�NORMAL_PRIORITY_CLASS�REALTIME_PRIORITY_CLASS�CREATE_NO_WINDOW�DETACHED_PROCESS�CREATE_DEFAULT_ERROR_MODE�CREATE_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' �//opt/alt/python39/lib64/python3.9/subprocess.pyr i � r c @ s8 e Zd Zd dd�Zdd� Zedd� �Zejdd� �ZdS )
r Nc C s || _ || _|| _|| _d S �N)�
returncode�cmd�output�stderr)�selfr+ r, r- r. r' r' r( �__init__s s zCalledProcessError.__init__c C sf | j rR| j dk rRzd| jt�| j �f W S tyN d| j| j f Y S 0 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�
ValueError�r/ r' r' r( �__str__y s �
��zCalledProcessError.__str__c C s | j S r* �r- r3 r' r' r( �stdout� s zCalledProcessError.stdoutc C s
|| _ d S r* r5 �r/ �valuer' r' r( r6 � s )NN�r$ r% r& r0 r4 �propertyr6 �setterr' r' r' r( r l s
r c @ s8 e Zd Zd dd�Zdd� Zedd� �Zejdd� �ZdS )
r Nc C s || _ || _|| _|| _d S r* )r, �timeoutr- r. )r/ r, r< r- r. r' r' r( r0 � s zTimeoutExpired.__init__c C s d| j | jf S )Nz'Command '%s' timed out after %s seconds)r, r< r3 r' r' r( r4 � s
�zTimeoutExpired.__str__c C s | j S r* r5 r3 r' r' r( r6 � s zTimeoutExpired.stdoutc C s
|| _ d S r* r5 r7 r' r' r( r6 � s )NNr9 r' r' r' r( r � s
r c @ s, e Zd Zddddddd�dd�Zdd� ZdS )r# r N��dwFlags� hStdInput�
hStdOutput� hStdError� wShowWindow�lpAttributeListc C s0 || _ || _|| _|| _|| _|p(dg i| _d S )N� handle_listr= )r/ r> r? r@ rA rB rC r' r' r( r0 � s zSTARTUPINFO.__init__c C s@ | j �� }d|v r"t|d �|d< t| j| j| j| j| j|d�S )NrD r= ) rC �copy�listr# r> r? r@ rA rB )r/ Z attr_listr' r' r( rE � s
�zSTARTUPINFO.copy)r$ r% r& r0 rE r' r' r' r( r# � s � r# c @ s2 e Zd ZdZejfdd�Zdd� 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 td��d S )NTzalready closed)rH �intr2 r3 r' r' r( �Detach� s z
Handle.Detachc C s d| j jt| �f S )Nz%s(%d))� __class__r$ rK r3 r' r' r( �__repr__� s zHandle.__repr__N)
r$ r% r& rH �_winapirI rJ rL rN �__del__r' r' r' r( rG � s
rG ZPIPE_BUFi � PollSelectorc C s d S r* r' r' r' r' r( �_cleanup� s rR c C sZ t d u r d S t d d � D ]<} | jtjd�}|d urzt �| � W q tyR Y q0 qd S )N��
_deadstate)�_active�_internal_poll�sys�maxsize�remover2 )�inst�resr' r' r( rR � s ���������c C s* g } t jj}|dkr&| �dd| � | S )Nr �-�O)rW �flags�optimize�append)�argsr8 r' r' r( �"_optim_args_from_interpreter_flags s
re c C sV ddddddd�} t � }| �� D ].\}}ttj|�}|dkr |�d || � q tjjrd|�d
� n$tjjrv|�d � tjjr�|�d � tj d d � }tjj
}ttd
i �}d|v }|dkr�|� d� n|r�|� d� |r�|� d� |D ]}|�d| � q�|�r
|� d� dD ]B}||v �r|| } | du �r4|}
n d|| f }
|� d|
f� �q|S )N�d�B�S�v�b�q)�debug�dont_write_bytecode�no_site�verbose�
bytes_warning�quietr r_ z-Iz-Ez-s� _xoptions�dev� zerror::BytesWarningzdefault::BytesWarning�defaultz-W)�-Xrs )Z faulthandler� tracemallocZ
importtimeZ showrefcount�utf8Z oldparserTz%s=%srv )
re �items�getattrrW ra rc �isolated�ignore_environment� no_user_site� warnoptionsrp rY �extend) Z flag_opt_maprd �flag�optri Zwarnoptsrp Zxoptions�dev_moder8 �argr' r' r( � _args_from_interpreter_flags sP �
r� �r< c O sf t |i |���D}z |j| d�W W d � S |�� � Y n0 W d � n1 sX0 Y d S )Nr� )r �wait�kill)r< � popenargs�kwargs�pr' r' r( r U s r c O s: t | i |��}|r6|�d�}|d u r,| d }t||��dS )Nrd r )r �getr )r� r� �retcoder, r' r' r( r f s
r c O sb d|v rt d��d|v rJ|d d u rJ|�d�s8|�d�r>d}nd}||d< t|t| dd �|��jS )
Nr6 z3stdout argument not allowed, it will be overridden.�input�universal_newlines�text� r) T)r6 r< �check)r2 r� r r r6 )r< r� r� �emptyr' r' r( r
y s #�r
c @ s0 e Zd Zddd�Zdd� Zeej�Zdd� Z dS ) r Nc C s || _ || _|| _|| _d S r* )rd r+ r6 r. )r/ rd r+ r6 r. r' r' r( r0 � s zCompletedProcess.__init__c C sh d� | j�d� | j�g}| jd ur4|�d� | j�� | jd urP|�d� | j�� d� t| �jd�|��S )Nz args={!r}zreturncode={!r}z stdout={!r}z stderr={!r}z{}({})z, ) �formatrd r+ r6 rc r. �typer$ �join)r/ rd r' r' r( rN � s
�
zCompletedProcess.__repr__c C s | j r t| j | j| j| j��d S r* )r+ r rd r6 r. r3 r' r' r( �check_returncode� s �z!CompletedProcess.check_returncode)NN)
r$ r% r& r0 rN � classmethod�types� GenericAlias�__class_getitem__r� r' r' r' r( r � s
r )r� �capture_outputr< r� c O s< | d ur&|� d�d ur td��t|d< |r^|� d�d usF|� d�d urNtd��t|d< t|d< t|i |����}z|j| |d�\}}W n` ty� } z4|�� tr�|�� \| _| _ n|�
� � W Y d } ~ n d } ~ 0 |�� � Y n0 |� � }
|�r |
�r t |
|j
||d��W d � n1 �s"0 Y t|j
|
||�S )N�stdinz/stdin and input arguments may not both be used.r6 r. z@stdout and stderr arguments may not be used with capture_output.r� �r- r. )r� r2 r r � communicater r� �
_mswindowsr6 r. r� �pollr rd r ) r� r� r< r� r� r� Zprocessr6 r. �excr� r' r' r( r � s6 �&r c C s� g }d}t tj| �D ]�}g }|r*|�d� d|v p>d|v p>| }|rN|�d� |D ]b}|dkrj|�|� qR|dkr�|�dt|� d � g }|�d� qR|r�|�|� g }|�|� qR|r�|�|� |r|�|� |�d� qd�|�S ) NF� � �"�\� z\"r� )�map�os�fsdecoderc �lenr r� )�seq�resultZ needquoter� Zbs_buf�cr' r' r( � list2cmdline s4
r� c
C sn zt | ddtd�}d}W n0 tyH } z|j}|j}W Y d }~n
d }~0 0 |dd � dkrf|d d� }||fS )NT)�shellr� r. r r\ �
)r
r r r- r+ )r, �dataZexitcodeZexr' r' r( r ^ s r c C s t | �d S �Nrt )r )r, r' r' r( r } s
r c
C s� t sttd�sdS tjdkr dS zjt�d�} | jdd�}t|�dkrHt�|d }t t
t |d �d
���}tjd kr�|d kr�|d
kr�W dS W n t tt
fy� Y n0 dS )N� posix_spawnF�darwinT�CS_GNU_LIBC_VERSIONrt )�maxsplitr� r �.ZlinuxZglibc)r� � )r� �hasattrr� rW �platform�confstr�splitr� r2 �tupler� rK �AttributeError�OSError)Zver�partsZlibc�versionr' r' r( �_use_posix_spawn� s
r� c @ s� e Zd ZdZdLdddddddd�dd �Zd
d � Zeej�Z e
d d
� �Z e j dd
� �Z dd� Z
dd� Zdd� Zejejfdd�Zdd� Zdd� ZdMdd �Zd d � Zd d � ZdNd!d"�ZdOd#d$�Zd%d&� Z e �r0d'd(� Z d)d*� Z d+d,� Z d-d.� Z!de"j#e"j$e"j%fd/d0�Z&d1d2� Z'd3d4� Z(d5d6� Z)d7d8� Z*d9d:� Z+e+Z,n~d;d(� Z d<d=� Z-d>d.� Z!e.j/e.j0e.j1fd?d@�Z2de.j3e.j4e5j6fdAd0�Z&dBdC� Z7dDd2� Z'dEd6� Z)dFdG� Z8dHd8� Z*dId:� Z+dJdK� Z,dS )Pr Fr\ NTr r' )�user�group� extra_groups�encoding�errorsr� �umaskc ( C sF t � t�� | _d | _d| _|d u r(d}t|t�s:td��t rP|d ur�t
d��n8|rh|sht � dt
� d}|
d urxt
d��|dkr�t
d ��|| _d | _d | _d | _d | _d | _|| _|| _|d ur�| d ur�t| �t|�kr�td
��| �|||�\}}}} } } t �rN|dk�rt�|�� d�}|dk�r4t�|�� d�}| dk�rNt�| �� d�} |�pb|�pb|�pb| | _ d | _ d| _ | j �r�|d k�r�d} d}nd} d } |d u�r t t d
��s�t
d��nPt|t!��r�t"d u �r�t
d��t"�#|�j$} n$t|t��r�|} ntd�%t&|����| dk �r t
d| � ���d }!|d u�r�t t d��sBt
d��nt|t!��rVt
d��g }!|D ]b}"t|"t!��r�t"d u �r�t
d��|!�'t"�#|"�j$� n*t|"t��r�|!�'|"� ntd�%t&|"�����q^|!D ] }#|#dk �r�t
d|#� ����q�d }$|d u�rht t d��s
t
d��nFt|t!��r6t(d u �r(t
d��t(�)|�j*}$nt|t��rH|}$ntd��|$dk �rht
d|$� ���z�|dk�r�t+�,|d |�| _| j �r�t+j-| jd| ||d �| _|dk�r�t+�,|d |�| _| j �r�t+j-| j||d �| _| dk�rt+�,| d |�| _| j �rt+j-| j||d �| _| �.||||||
| |
|| |||| | | || |!|$||� W n� t/d | j| j| jf�D ](}%z |%�0� W n t1�y� Y n0 �qd| j �s:g }&|t2k�r�|&�'|� |t2k�r�|&�'| � |t2k�r�|&�'| � t | d ��r�|&�'| j3� |&D ]F}'z*t �rt|'t4��r|'�5� n
t �0|'� W n t1�y4 Y n0 �q� Y n0 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 �?rt �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_through�line_bufferingr� r� �rb)r� r� �_devnull)6rR � threadingZLock�
_waitpid_lock�_input�_communication_started�
isinstancerK � TypeErrorr� r2 �warnings�warn�RuntimeWarningrd r� r6 r. �pidr+ r� r� �boolr � _get_handles�msvcrtZopen_osfhandlerL � text_mode�_sigint_wait_secs�_closed_child_pipe_fdsr� r� �str�grpZgetgrnamZgr_gidr� r� rc �pwd�getpwnamZpw_uid�io�open�
TextIOWrapper�_execute_child�filter�closer� r r� rG rJ )(r/ rd �bufsize�
executabler� r6 r. �
preexec_fn� close_fdsr� �cwd�envr� � startupinfo�
creationflags�restore_signals�start_new_session�pass_fdsr� r� r� r� r� r� r� �p2cread�p2cwrite�c2pread�c2pwrite�errread�errwriter� �gid�gidsZ extra_groupZ gid_check�uid�fZto_close�fdr' r' r( r0 � s.
� �
�
�
�
�
� �
zPopen.__init__c C s@ d| j j� d| j� d| j�d�}t|�dkr<|d d� d }|S )N�<z: returncode: z args: �>�P �L z...>)rM r$ r+ rd r� )r/ Zobj_reprr' r' r( rN � s ��� zPopen.__repr__c C s | j S r* )r� r3 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 |� ||�}|�dd��dd�S )Nz
r� �
)�decode�replace)r/ r� r� r� r' r' r( �_translate_newlines� s zPopen._translate_newlinesc C s | S r* r' r3 r' r' r( � __enter__� s zPopen.__enter__c C s� | j r| j �� | jr | j�� z^| jr2| j�� W |tkrv| jdkrlz| j| jd� W n tyj Y n0 d| _d S | �� nT|tkr�| jdkr�z| j| jd� W n ty� Y n0 d| _ Y d S | �� 0 d S )Nr r� ) r6 r� r. r� �KeyboardInterruptr� �_waitr r� )r/ �exc_typer8 � tracebackr' r' r( �__exit__� s2
�
zPopen.__exit__c C sT | j s
d S | jd u r(|d| j t| d� | j|d� | jd u rPtd urPt�| � d S )Nz subprocess %s is still running)�sourcerS )�_child_createdr+ r� �ResourceWarningrV rU rc )r/ Z_maxsizeZ_warnr' r' r( rP s
� z
Popen.__del__c C s" t | d�s t�tjtj�| _| jS )Nr� )r� r� r� �devnull�O_RDWRr� r3 r' r' r( � _get_devnull$ s
zPopen._get_devnullc
C s� |rZz| j �|� W nD ty& Y n4 tyX } z |jtjkrBn� W Y d }~n
d }~0 0 z| j �� W nD tyz Y n4 ty� } z |jtjkr�n� W Y d }~n
d }~0 0 d S r* )r� �write�BrokenPipeErrorr� �errnoZEINVALr� )r/ r� r� r' r' r( � _stdin_write) s" zPopen._stdin_writec C sV | j r|rtd��|d u r�| j s�| j| j| jg�d �dkr�d }d }| jrT| �|� n6| jrp| j�� }| j�� n| jr�| j�� }| j�� | � � n�|d ur�t
� | }nd }z�z| � |||�\}}W nd t �y( |d ur�t
| j| �|��}n| j}d| _z| j|d� W n t�y Y n0 � Y n0 W d| _ nd| _ 0 | j | �|�d�}||fS )Nz.Cannot send input after starting communicationr� r r� T)r� r2 r� r6 r. �countr �readr� r� �_time� _communicater
�minr� �_remaining_timer r )r/ r� r< r6 r. �endtime�sigint_timeout�stsr' r' r( r� B sH
�
�
zPopen.communicatec C s | � � S r* )rV r3 r' r' r( r� � s z
Popen.pollc C s |d u r d S |t � S d S r* )r )r/ r r' r' r( r � s zPopen._remaining_timec C sL |d u r d S |st � |krHt| j||r0d�|�nd |r@d�|�nd d��d S )Nr) r� )r r rd r� )r/ r � orig_timeoutZ
stdout_seqZ
stderr_seq�skip_check_and_raiser' r' r( �_check_timeout� s �zPopen._check_timeoutc C s� |d urt � | }z| j|d�W S ty� |d urJt| j| �|��}n| j}d| _z| j|d� W n tyx Y n0 � Y n0 d S )Nr� r )r r r
r r� r r )r/ r< r r r' r' r( r� � 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 ur�|�tj|� W d � n1 s�0 Y d| _d S )Nr� r\ T) rz �
contextlib� ExitStackr� �callbackrJ r� r� r� ) r/ r� r� r� r� r� r� Z
devnull_fd�stackr' r' r( �_close_pipe_fds� s$
,zPopen._close_pipe_fdsc C s~ |d u r |d u r |d u r dS d\}}d\}}d\}} |d u rtt �t j�}|d u r�t �d d�\}}
t|�}t �|
� nh|tkr�t �d d�\}}t|�t|� }}n<|tkr�t� | �
� �}n$t |t �r�t� |�}nt� |�
� �}| �|�}|d u �r*t �t j�}|d u �r�t �d d�\}
}t|�}t �|
� nn|tk�rXt �d d�\}}t|�t|� }}n@|tk�rrt� | �
� �}n&t |t ��r�t� |�}nt� |�
� �}| �|�}|d u �r�t �t j�} | d u �rdt �d d�\}
} t| �} t �|
� n~|tk�rt �d d�\}} t|�t| � }} nP|tk�r$|} n@|tk�r>t� | �
� �} n&t |t ��rVt� |�} nt� |�
� �} | �| �} |||||| fS )N)r\ r\ r\ r\ r\ r\ �r\ r\ r )rO Z GetStdHandler Z
CreatePiperG rI r r
r� Z
get_osfhandler r� rK �fileno�_make_inheritabler r r ) r/ r� r6 r. r� r� r� r� r� r� �_r' r' r( r� � sp
�zPopen._get_handlesc C s& t �t �� |t �� ddt j�}t|�S )Nr rt )rO ZDuplicateHandleZGetCurrentProcessZDUPLICATE_SAME_ACCESSrG )r/ �handle�hr' r' r( r, s
�zPopen._make_inheritablec C s t dd� |D ��S )Nc S s, h | ]$}|d @ d ks$t �|�t jkr|�qS )� )rO Z GetFileTypeZFILE_TYPE_CHAR)�.0r. r' r' r( � <setcomp>0 s
��z,Popen._filter_handle_list.<locals>.<setcomp>)rF )r/ rD r' r' r( �_filter_handle_list) s zPopen._filter_handle_listc ! C s� t |t�r nNt |t�r.|
r"td��t|g�}n,t |tj�rR|
rFtd��t|g�}nt|�}|d urlt�|�}|d u r|t� }n|� � }d| ||fv}|r�| j
t j O _
| |_
||_||_|j}t|o�d|v o�|d �}|s�|�r^|�r^|d u r�i }|_t|�dg �� }|d< |�r0|t| �t|�t|�g7 }| �|�|d d �< |�r^|�sZt�dt� d}|
�r�| j
t jO _
t j|_|�s�tj �d�}|�s�tj �dd �} tj � | d
d �}tj � |��s�t d ��tj � |��r�|}n|}d
�!||�}|d u�r t�|�}t"�#d||||� z@t �$||d d t| �| |||� \} } } } W | �%| | |
|||� n| �%| | |
|||� 0 d| _&t'| �| _(| | _)t �*| � d S )Nz$bytes args is not allowed on Windows�0path-like args is not allowed when shell is truer\ rD 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# rE r> rO r r? r@ rA rC r� rF r� rK r3 r� r� r� r r rB �environ�pathr� �isabs�FileNotFoundErrorr� rW �auditZ
CreateProcessr) r rG �_handler� rI )!r/ rd 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_listrD ZcomspecZ system_rootZhpZhtr� �tidr' r' r( r� 6 s�
��
�
�
���
zPopen._execute_childc C s, | j d u r&|| jd�|kr&|| j�| _ | j S �Nr )r+ r= )r/ rT Z_WaitForSingleObjectZ_WAIT_OBJECT_0Z_GetExitCodeProcessr' r' r( rV � s
zPopen._internal_pollc C s^ |d u rt j}n t|d �}| jd u rXt �| j|�}|t jkrJt| j|��t � | j�| _| jS )Ni� )
rO ZINFINITErK r+ �WaitForSingleObjectr= Z WAIT_TIMEOUTr rd �GetExitCodeProcess)r/ r< Ztimeout_millisr� r' r' r( r � s
�
z Popen._waitc C s |� |�� � |�� d S r* )rc r r� )r/ Zfh�bufferr' r' r( �
_readerthread� s zPopen._readerthreadc C s\ | j rBt| d�sBg | _tj| j| j | jfd�| _d| j_| j�� | j r�t| d�s�g | _
tj| j| j | j
fd�| _ d| j _| j �� | j r�| �
|� | j d ur�| j�| �|�� | j�� r�t| j|��| j d ur�| j �| �|�� | j �� r�t| j|��d }d }| j �r| j}| j �� | j �r0| j
}| j �� |�r>|d nd }|�rP|d nd }||fS )N� _stdout_buff)�targetrd T� _stderr_buffr )r6 r� rD r� ZThreadrC Z
stdout_threadZdaemon�startr. rF Z
stderr_threadr� r r� r Zis_aliver rd r� )r/ r� r r" r6 r. r' r' r( r � sJ
��
��
zPopen._communicatec C sl | j d urd S |tjkr"| �� nF|tjkr>t�| jtj� n*|tjkrZt�| jtj� nt d�
|���d S )NzUnsupported signal: {}) r+ r1 �SIGTERM� terminateZ CTRL_C_EVENTr� r� r� ZCTRL_BREAK_EVENTr2 r� �r/ Zsigr' r' r( � send_signal
s
zPopen.send_signalc C sV | j d urd S zt�| jd� W n0 tyP t�| j�}|tjkrF� || _ Y n0 d S r� )r+ rO ZTerminateProcessr= �PermissionErrorrA Z STILL_ACTIVE)r/ Zrcr' r' r( rI s
zPopen.terminatec
C s, d\}}d\}}d\}} |d u r"n@|t kr8t�� \}}n*|tkrJ| �� }nt|t�rZ|}n|�� }|d u rln@|t kr�t�� \}}n*|tkr�| �� }nt|t�r�|}n|�� }|d u r�nf|t kr�t�� \}} nP|tkr�|dkr�|} n
t j
�� } n.|tk�r| �� } nt|t��r|} n|�� } |||||| fS )Nr* r\ ) r r� �piper
r r� rK r+ r rW �
__stdout__)
r/ r� r6 r. r� r� r� r� r� r� r' r' r( r� 0 sL
�c C s� |d u rt j}i } |rJg } dD ]"}
tt|
d �}|d ur | �|� q | | d< g }||| fD ] }|dkrX|�t j|f� qX|df|df|
dffD ]"\}}|dkr�|�t j||f� q�|r�|| d< t j|||fi | ��| _d| _ | �
||||| |
� d S ) N)�SIGPIPEZSIGXFZ�SIGXFSZZ setsigdefr\ r rt r� � file_actionsT) r� r8 rz r1 rc �POSIX_SPAWN_CLOSE�POSIX_SPAWN_DUP2r� r� r r) )r/ rd r� r� r� r� r� r� r� r� r� r� ZsigsetZsignameZsignumrQ r Zfd2r' r' r( � _posix_spawnf s8 � �zPopen._posix_spawnc - s t |ttf�r|g}n(t |tj�r6|
r.td��|g}nt|�}|
rlttd�rPdnd}|dg| }� rl� |d< � d u r||d � t� d� |||� t
�rFtj � � ��rF|d u �rF|�sF|�sF|d u �rF| dks�| d k�rF|dks�|d k�rF|dks�|d k�rF|�sF|d u �rF|d u �rF|d u �rF|dk �rF| �
|� ||| | |
|||�
d S � }t�� \}}g }|d
k �r||�|� t�|�}�qZ|D ]} t�| � �q��zh�z |d u�r�g } |�� D ]>\} } t�| �} d | v �r�td ��| �| d t�| � � �q�nd } t�� �� tj � � ��r� f} n t� fd
d�t�|�D ��} t|�}!|!�|� t�|| |ttt t |!���|| | | |
||||||||||||�| _ d| _ W t�|� n t�|� 0 | � | | |
|||� t!� }"t�"|d�}#|"|#7 }"|#�r�t#|"�dk�r��q�q�W t�|� n t�|� 0 |"�rz6t�$| j d�\}$}%|$| j k�r<| �%|%� ntj&| _'W n t(�yZ Y n0 z |"�)dd �\}&}'}(|(�*� }(W n* t�y� d}&d}'d�+t|"��}(Y n0 t,t-|&�*d�t.�})t/|)t0��r|'�rt |'d�}*|(dk}+|+�r�d}(|},n|},|*dk�rt�1|*�}(|)|*|(|,��|)|(��d S )Nr4 Zgetandroidapilevelz/system/bin/shz/bin/shz-cr r5 r\ r� r0 � =z!illegal environment variable namec 3 s" | ]}t j�t �|�� �V qd S r* )r� r9 r� �fsencode)r1 �dir�r� r' r( � <genexpr>� s �z'Popen._execute_child.<locals>.<genexpr>TiP� � :s SubprocessError� 0z#Bad exception data from child: {!r}�ascii� Znoexecr� )2r� r� r6 r� r7 r� rF r� rW r< �_USE_POSIX_SPAWNr9 �dirnamerT rM rc �dupr� ry rV r2 r� �
get_exec_path�set�add�_posixsubprocessZ fork_exec�sortedr� rK r� r r) � bytearrayr r� �waitpid�_handle_exitstatusrX r+ �ChildProcessErrorr� r r� rz �builtinsr �
issubclassr� �strerror)-r/ rd 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_list�kri Zexecutable_listZ fds_to_keepZ errpipe_data�partr� r! Zexception_nameZ hex_errno�err_msgZchild_exception_typeZ errno_numZchild_exec_never_calledZ err_filenamer' rX r( r� � s ��
����������� �
� � �
� �
�
�
�
� �
�
c C s$ ||�r||� | _ n
||�| _ d S r* )r+ )r/ r! �waitstatus_to_exitcodeZ _WIFSTOPPEDZ _WSTOPSIGr' r' r( rh 1 s zPopen._handle_exitstatusc
C s� | j d u r�| j�d�sd S z�zF| j d ur<| j W W | j�� S || j|�\}}|| jkr`| �|� W nD ty� } z,|d ur�|| _ n|j|kr�d| _ W Y d }~n
d }~0 0 W | j�� n | j�� 0 | j S )NFr )r+ r� �acquire�releaser� rh r� r )r/ rT Z_waitpidZ_WNOHANGZ_ECHILDr� r! �er' r' r( rV = s$
�
c C s< zt �| j|�\}}W n ty2 | j}d}Y n0 ||fS r? )r� rg r� ri )r/ Z
wait_flagsr� r! r' r' r( � _try_wait` s
zPopen._try_waitc C sP | j d ur| j S |d ur�t� | }d}| j�d�r�zX| j d urLW | j�� q�| �tj�\}}|| jkr~| � |� W | j�� q�W | j�� n | j�� 0 | �
|�}|dkr�t | j |��t
|d |d�}t�|� q&nv| j d u �rJ| j�P | j d u�rW d � �qJ| �d�\}}|| jk�r(| � |� W d � q�1 �s>0 Y q�| j S )Ng����Mb@?Fr r� g�������?)r+ r r� rq rr rt r� �WNOHANGr� rh r r rd r �time�sleep)r/ r< r Zdelayr� r! Z remainingr' r' r( r m s>
�
�
,c
C s2 | j rT| jsTz| j �� W n ty, Y n0 |sTz| j �� W n tyR Y n0 d }d }| js�i | _| jrzg | j| j< | jr�g | j| j< | jr�| j| j }| jr�| j| j }| �|� | j r�t
| j �}t � ���}| j r�|r�|� | j t
j� | j�r| jj�s|� | jt
j� | j�r2| jj�s2|� | jt
j� |�� �r�| �|�}|d u�rv|dk �rv| j||||dd� td��|�|�} | �||||� | D ]�\}
} |
j| j u �r0|| j| jt � } z | jt�|
j| �7 _W n* t�y |� |
j� |
j�� Y n*0 | jt | j �k�r�|� |
j� |
j�� nP|
j| j| jfv �r�t� |
jd�}
|
�sn|� |
j� |
j�� | j|
j � |
� �q��q2W d � n1 �s�0 Y | j | �|�d� |d u�r�d�!|�}|d u�r�d�!|�}| j"�r*|d u�r
| �#|| jj$| jj%�}|d u�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_fileobj2outputr6 r. � _save_inputr� �
memoryview�_PopenSelector�register� selectorsZ EVENT_WRITErH Z
EVENT_READZget_mapr r$ � RuntimeError�selectZfileobj�
_input_offset� _PIPE_BUFr� r r Z
unregisterr� r rc r� r� r� r r� r� )r/ r� r r" r6 r. Z
input_viewZselectorr< Zready�keyZevents�chunkr� r' r' r( r � s�
��
�
:
�
�c C sF | j rB| jd u rBd| _|| _|d urB| jrB| j�| j j| j j�| _d S r? )r� r� r� r� �encoder� r� )r/ r� r' r' r( ry � s �zPopen._save_inputc C s@ | � � | jd urd S zt�| j|� W n ty: Y n0 d S r* )r� r+ r� r� r� �ProcessLookupErrorrJ r' r' r( rK s
c C s | � tj� d S r* )rK r1 rH r3 r' r' r( rI ( s c C s | � tj� d S r* )rK r1 �SIGKILLr3 r' r' r( r� - s z
Popen.kill)r\ NNNNNTFNNNNr TFr' )NN)F)N)9r$ r% r& r r0 rN r� r� r� r� r: r� r; r r r rW rX r� r� rP r r r� r� r r$ r� r) r� r� r, r3 r� rO r@ Z
WAIT_OBJECT_0rA rV r rC r rK rI r� rT r� rp �
WIFSTOPPED�WSTOPSIGrh rg ru r ZECHILDrt ry r' r' r' r( r � s� 6 �� j
D �
H
�
26' &�
�
#
)f r )Krj r r� r� rv r1 rW r� r� r% r r r� r� � ImportErrorr� �__all__r� rO r� �ModuleNotFoundErrorrd 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# rK rG rz r� r� rQ r{ ZSelectSelectorrU rR r r r
re r� r r r
�objectr r r� r r r� r^ r r' r' r' r( �<module>, s~
P
%
;3%� EI
/