File: //usr/local/lib/python3.10/test/__pycache__/test_subprocess.cpython-310.opt-1.pyc
o
�iVq � @ s� d dl Z d dl mZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z zd dl Z W n e y� dZ Y nw zd dl!Z!W n e y� dZ!Y nw zd dl"Z"W n e y� dZ"Y nw zd dl#Z#W n dZ#Y ej$r�e �%d ��e
j&d
kZ'e'r�d Z(nd Z(d
Z)e*e+e,fZ-e
j.ddfa/dd� Z0G dd� de j1�Z2G dd� de3�Z4G dd� de j5�Z6G dd� de2�Z7G dd� de2�Z8d d � Z9e �:e'd �G d d � d e2��Z;e �<e'd!�G d"d#� d#e2��Z=G d$d%� d%e j1�Z>e �<e?ed&�d'�G d(d)� d)e7��Z@e �<e'd*�G d+d,� d,e2��ZAG d-d.� d.e2�ZBeCd/k�rke �D� dS dS )0� N)�mock)�support)�check_sanitizer)�
import_helper)� os_helper)�warnings_helper)�FakePathztest is not helpful for PGO�win32z@import msvcrt; msvcrt.setmode(sys.stdout.fileno(), os.O_BINARY);� )Znonexisting_i_hope�-c�passc C sH t �d�} | d u r d S t�| tj�r t�| g�jdkr"| fad S d S d S )N�truer ) �shutil�which�os�access�X_OK�
subprocess�run�
returncode�ZERO_RETURN_CMD)Z
shell_true� r �1/usr/local/lib/python3.10/test/test_subprocess.py� setUpModuleG s
�r c @ � e Zd Zdd� Zdd� ZdS )� BaseTestCasec C s t �� d S �N)r �
reap_children��selfr r r �setUpR s zBaseTestCase.setUpc C sB t stjD ]}|�� qt�� | �tjd� | �� t�� d S )Nz subprocess._active not empty) � mswindowsr �_active�wait�_cleanup� assertFalseZ
doCleanupsr r )r �instr r r �tearDownW s
� zBaseTestCase.tearDownN��__name__�
__module__� __qualname__r r' r r r r r Q s r c @ s e Zd ZdS )�PopenTestExceptionN)r) r* r+ r r r r r, d s r, c @ s e Zd ZdZdd� ZdS )�PopenExecuteChildRaiseszePopen subclass for testing cleanup of subprocess.PIPE filehandles when
_execute_child fails.
c O � t d��)NzForced Exception for Test)r, �r �args�kwargsr r r �_execute_childl � z&PopenExecuteChildRaises._execute_childN)r) r* r+ �__doc__r2 r r r r r- h s r- c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d7d8� Z e � e!d9�d:d;� �Z"e � e!d9�d<d=� �Z#e � e!d9�d>d?� �Z$d@dA� Z%dBdC� Z&dDdE� Z'dFdG� Z(dHdI� Z)dJdK� Z*e � e!dL�dMdN� �Z+e � e!dL�dOdP� �Z,dQdR� Z-e � e.j/e.j0kdS�dTdU� �Z1e � e.j/e.j0kdS�e � e2�3� dV�dWdX� ��Z4dYdZ� Z5d[d\� Z6d]d^� Z7d_d`� Z8dadb� Z9dcdd� Z:dedf� Z;dgdh� Z<didj� Z=dkdl� Z>dmdn� Z?dodp� Z@dqdr� ZAdsdt� ZBdudv� ZCdwdx� ZDe �EeF�o/eGeFdy�dz�d{d|� �ZHe �EeF�o?eGeFdy�dz�d}d~� �ZIdd�� ZJe � e.jKd�kd��e � e2�Ld��d�kd��e � eMd�d��d��d�d�� ���ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�� ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�� Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbd�d�� Zcd�d�� Zdd�d�� Zed�d�� Zfd�d�� Zgd�d�� Zhd�d�� Zid�d Zjd�dĄ Zkd�dƄ Zld�dȄ Zmd�dʄ Znd�d̄ Zod�d΄ Zpd�dЄ Zqd�d҄ Zrd�dԄ Zsd�dք Zte �EeGeud׃dءe �EeGevdكdڡe �EeGevdۃdܡd�dބ ���Zwe �Eevjx�yd�ev�z� �d�d�d� �Z{e � e!d�d�d� �Z|e � e!d�d�d� �Z}d�d� Z~d�S )��ProcessTestCasec C s� t jtt jt jt jd�}z.| �|jtj� | �|jtj� | �|j tj� W |j�
� |j�
� |j �
� |� � d S |j�
� |j�
� |j �
� |� � w )N��stdin�stdout�stderr) r �Popenr �PIPE�assertIsInstancer7 �io�BufferedIOBaser8 r9 �closer# �r �pr r r �test_io_buffered_by_defaultr s �
�
z+ProcessTestCase.test_io_buffered_by_defaultc C s� t jtt jt jt jdd�}z.| �|jtj� | �|jtj� | �|j tj� W |j�
� |j�
� |j �
� |� � d S |j�
� |j�
� |j �
� |� � w )Nr )r7 r8 r9 �bufsize) r r: r r; r< r7 r= � RawIOBaser8 r9 r? r# r@ r r r �test_io_unbuffered_works� s �
�
z(ProcessTestCase.test_io_unbuffered_worksc C s" t �tjddg�}| �|d� d S �Nr �import sys; sys.exit(47)�/ �r �call�sys�
executable� assertEqual�r �rcr r r �
test_call_seq� s
�z ProcessTestCase.test_call_seqc C s" | j tjtjtjddgdd� d S )Nr �while True: pass皙�����?��timeout)� assertRaisesr �TimeoutExpiredrJ rK rL r r r r �test_call_timeout� s
�z!ProcessTestCase.test_call_timeoutc C s t �t�}| �|d� d S �Nr )r �
check_callr rM rN r r r �test_check_call_zero� s
z$ProcessTestCase.test_check_call_zeroc C �R | � tj��}t�tjddg� W d � n1 sw Y | �|jjd� d S rF ) rU r �CalledProcessErrorrY rK rL rM � exceptionr �r �cr r r �test_check_call_nonzero� s
� �z'ProcessTestCase.test_check_call_nonzeroc C s" t �tjddg�}| �d|� d S )Nr �
print('BDFL')� BDFL�r � check_outputrK rL �assertIn�r �outputr r r �test_check_output� s
�z!ProcessTestCase.test_check_outputc C r[ )Nr zimport sys; sys.exit(5)� ) rU r r\ rd rK rL rM r] r r^ r r r �test_check_output_nonzero� s
� �z)ProcessTestCase.test_check_output_nonzeroc C s( t jtjddgt jd�}| �d|� d S )Nr �$import sys; sys.stderr.write('BDFL')�r9 rb )r rd rK rL �STDOUTre rf r r r �test_check_output_stderr� s
�z(ProcessTestCase.test_check_output_stderrc C sN t �� }| �|j� |�d� |�d� tjtj ddg|d�}| �
d|� d S )N� pearr r �6import sys; sys.stdout.write(sys.stdin.read().upper())�r7 � PEAR) �tempfile�
TemporaryFile�
addCleanupr? �write�seekr rd rK rL re )r �tfrg r r r �test_check_output_stdin_arg� s
��z+ProcessTestCase.test_check_output_stdin_argc C s& t jtjddgdd�}| �d|� d S )Nr rp ro ��inputrr rc rf r r r �test_check_output_input_arg� � ��z+ProcessTestCase.test_check_output_input_argc C s& t jtjddgdd�}| �d|� dS )z<input=None has a legacy meaning of input='' on check_output.r �3import sys; print('XX' if sys.stdin.read() else '')Nrz s XX�r rd rK rL � assertNotInrf r r r � test_check_output_input_none� r} z,ProcessTestCase.test_check_output_input_nonec C �( t jtjddgd dd�}| �d|� d S )Nr r~ T)r{ �text�XXr rf r r r �!test_check_output_input_none_text� � ��z1ProcessTestCase.test_check_output_input_none_textc C r� )Nr r~ T)r{ �universal_newlinesr� r rf r r r �/test_check_output_input_none_universal_newlines� r� z?ProcessTestCase.test_check_output_input_none_universal_newlinesc C s* t jtjddgd ddd�}| �d|� d S )Nr z print('foo')�utf-8�ignore)r{ �encoding�errors�foorc rf r r r �,test_check_output_input_none_encoding_errors� s
�z<ProcessTestCase.test_check_output_input_none_encoding_errorsc C sd | � t��}tjtjddgtjd�}| �d� W d � n1 s!w Y | �d|j j
d � d S )Nr �print('will not be run')�r8 z-Expected ValueError when stdout arg supplied.r8 r ) rU �
ValueErrorr rd rK rL r8 �failre r] r0 �r r_ rg r r r � test_check_output_stdout_arg� s
� �z,ProcessTestCase.test_check_output_stdout_argc C s� t �� }| �|j� |�d� |�d� | �t��}tj t
j ddg|dd�}| � d� W d � n1 s5w Y | �
d|jjd � | �
d |jjd � d S )
Nro r r r� � hare�r7 r{ �7Expected ValueError when stdin and input args supplied.r7 r{ )rs rt ru r? rv rw rU r� r rd rK rL r� re r] r0 �r rx r_ rg r r r �&test_check_output_stdin_with_input_arg� s
� �z6ProcessTestCase.test_check_output_stdin_with_input_argc C s` | � tj��}tjtjddgdd�}| �d� W d � n1 s!w Y | �|jj d� d S )Nr �Mimport sys, time
sys.stdout.write('BDFL')
sys.stdout.flush()
time.sleep(3600)� rS zExpected TimeoutExpired.rb )
rU r rV rd rK rL r� rM r] rg r� r r r �test_check_output_timeout s �� � z)ProcessTestCase.test_check_output_timeoutc C s8 t j�� }d|d< tjtjddg|d�}| �|d� d S )N�banana�FRUITr z5import sys, os;sys.exit(os.getenv("FRUIT")=="banana")��env� )r �environ�copyr rJ rK rL rM )r �newenvrO r r r �test_call_kwargs s
��z ProcessTestCase.test_call_kwargsc C s~ t �� �)}| jttjdd� tjjjj}dg|d }| jttjg|�R � W d � n1 s0w Y | � |�
� d� d S )Nr� )Zinvalid_arg_namer r
) r Zcaptured_stderrrU � TypeErrorr r: �__init__�__code__� co_argcountrM �getvalue)r �sZargcountZ
too_many_argsr r r �test_invalid_args s
�z!ProcessTestCase.test_invalid_argsc C �R t jtjddgt jt jd�}| �|jj� | �|jj� |� � | �
|j d � d S )Nr �print("banana")�r8 r9 ) r r: rK rL r; ru r8 r? r9 r# rM r7 r@ r r r �test_stdin_none' � �z ProcessTestCase.test_stdin_nonec C �l d}t jtjd|gt jt jd�}| �|jj� | �|jj� |� � \}}| �
|j d|� | �
|� � d� d S )Nz�import sys; from subprocess import Popen, PIPE;p = Popen([sys.executable, "-c", "print('test_stdout_none')"], stdin=PIPE, stderr=PIPE);p.wait(); assert p.stdout is None;r r� r s test_stdout_none�
r r: rK rL r; ru r8 r? r9 � communicaterM r �rstrip�r �coderA �out�errr r r �test_stdout_none0 s � z ProcessTestCase.test_stdout_nonec C r� )Nr r� �r7 r8 ) r r: rK rL r; ru r8 r? r7 r# rM r9 r@ r r r �test_stderr_noneG r� z ProcessTestCase.test_stderr_nonec K s6 |dg }t j|fi |��}|�� | �d|j� d S �NrG rH )r r: r# rM r )r �pre_argsr1 r0 rA r r r �_assert_pythonP s
z ProcessTestCase._assert_pythonc C s0 t j�t j�tj�d�}| j|dgtjd� d S �N� doesnotexistr �rL )r �path�join�dirnamerK rL r� �r r� r r r �test_executableX s �z ProcessTestCase.test_executablec C s6 t j�t j�tj�d�}| j|dgt �tj�d� d S r� )r r� r� r� rK rL r� �fsencoder� r r r �test_bytes_executablec s �
�z%ProcessTestCase.test_bytes_executablec C s4 t j�t j�tj�d�}| j|dgttj�d� d S r� )r r� r� r� rK rL r� r r� r r r �test_pathlike_executablei s �
�z(ProcessTestCase.test_pathlike_executablec C s0 t jdg}| �|� | jt| j|td d� d S )Nr r r� )rK rL r� rU �NONEXISTING_ERRORS�NONEXISTING_CMD)r r� r r r � test_executable_takes_precedenceo s
�z0ProcessTestCase.test_executable_takes_precedencez"executable argument replaces shellc C s | j g tjdd� d S �NT)rL �shell)r� rK rL r r r r � test_executable_replaces_shelly s z.ProcessTestCase.test_executable_replaces_shellc C s | j g t�tj�dd� d S r� )r� r r� rK rL r r r r �$test_bytes_executable_replaces_shell s
�z4ProcessTestCase.test_bytes_executable_replaces_shellc C s | j g ttj�dd� d S r� )r� r rK rL r r r r �'test_pathlike_executable_replaces_shell� s
�z7ProcessTestCase.test_pathlike_executable_replaces_shellc C s6 t �|�� t�� W d � S 1 sw Y d S r )r Z
change_cwdr �getcwd)r �cwdr r r �_normalize_cwd� s $�z ProcessTestCase._normalize_cwdc C s t j�tj�}t j�|�S r )r r� �realpathrK rL �split)r Z python_pathr r r �_split_python_path� s z"ProcessTestCase._split_python_pathc K sl t j|ddgfdt ji|��}| �|jj� |�� | �d|j� t j
j }| �||�||j� � �
� �� d S )Nr zcimport os, sys; buf = sys.stdout.buffer; buf.write(os.getcwd().encode()); buf.flush(); sys.exit(47)r8 rH )r r: r; ru r8 r? r# rM r r r� �normcase�read�decode)r Z expected_cwdZ
python_argr1 rA r� r r r � _assert_cwd� s ���
�zProcessTestCase._assert_cwdc C s( t �� }| �|�}| j|tj|d� d S �N�r� )rs �
gettempdirr� r� rK rL �r �temp_dirr r r �test_cwd� s
zProcessTestCase.test_cwdc C s. t �� }| �|�}| j|tjt�|�d� d S r� )rs r� r� r� rK rL r r� r� r r r �test_cwd_with_bytes� s
z#ProcessTestCase.test_cwd_with_bytesc C s, t �� }| �|�}| j|tjt|�d� d S r� )rs r� r� r� rK rL r r� r r r �test_cwd_with_pathlike� s
z&ProcessTestCase.test_cwd_with_pathlikez"pending resolution of issue #15533c C s� | � � \}}tj�tj|�}t�� �*}| �tt j
|g� | jtt j
|g|d� | � |�}| j |||d� W d � d S 1 s?w Y d S r� �
r� r r� r� �curdirr Ztemp_cwdrU �FileNotFoundErrorr r: r� r� )r �
python_dir� python_base�
rel_python� wrong_dirr r r �test_cwd_with_relative_arg� s
�
�
"�z*ProcessTestCase.test_cwd_with_relative_argc C s� | � � \}}tj�tj|�}d}t�� �.}| jtt j
|g|d� | jtt j
|g||d� | � |�}| j ||||d� W d � d S 1 sEw Y d S )N�somethingyoudonthaver� �rL r� r� )r r� r� r� Z doesntexistr� r r r �!test_cwd_with_relative_executable� s
�
�
�"�z1ProcessTestCase.test_cwd_with_relative_executablec C s� | � � \}}tj�||�}tj�tj|�}t�� �!}| jtt j
|g|d� | � |�}| j |||d� W d � d S 1 s=w Y d S r� )
r� r r� r� r� r r� rU r� r r: r� r� )r r� r� Z
abs_pythonr� r� r r r �test_cwd_with_absolute_arg� s
�
"�z*ProcessTestCase.test_cwd_with_absolute_argzTest is not venv-compatiblec C s. | � � \}}| �|�}| j|dtj|d� d S )Nr� r� )r� r� r� rK rL )r r� r� r r r �test_executable_with_cwd� s
�z(ProcessTestCase.test_executable_with_cwdz#need an installed Python. See #7774c C s | j t�� dtjd� d S )Nr� r� )r� r r� rK rL r r r r �test_executable_without_cwd� s
�z+ProcessTestCase.test_executable_without_cwdc C sH t jtjddgt jd�}|j�d� |j�� |�� | � |j
d� d S )Nr �0import sys; sys.exit(sys.stdin.read() == "pear")rq ro r� ) r r: rK rL r; r7 rv r? r# rM r r@ r r r �test_stdin_pipe� s
��
z ProcessTestCase.test_stdin_pipec C sf t �� }| �|j� |�� }t�|d� t�|dd� tj t
j ddg|d�}|� � | �
|jd� d S �Nro r r r� rq r� )rs rt ru r? �filenor rv �lseekr r: rK rL r# rM r �r rx �drA r r r �test_stdin_filedes s
��z"ProcessTestCase.test_stdin_filedesc C sX t �� }| �|j� |�d� |�d� tjtj ddg|d�}|�
� | � |j d� d S r� )
rs rt ru r? rv rw r r: rK rL r# rM r �r rx rA r r r �test_stdin_fileobj s
��z"ProcessTestCase.test_stdin_fileobjc C �T t jtjddgt jd�}|� | �|j�� d� W d � d S 1 s#w Y d S )Nr �&import sys; sys.stdout.write("orange")r� � orange�r r: rK rL r; rM r8 r� r@ r r r �test_stdout_pipe! �
��"�z ProcessTestCase.test_stdout_pipec C �` t �� }| �|j� |�� }tjtjddg|d�}|� � t
� |dd� | � t
�
|d�d� d S )Nr r� r� r � r� �rs rt ru r? r� r r: rK rL r# r r� rM r� r� r r r �test_stdout_filedes) �
��z#ProcessTestCase.test_stdout_filedesc C �P t �� }| �|j� tjtjddg|d�}|�� |� d� | �
|� � d� d S )Nr r� r� r r� � rs rt ru r? r r: rK rL r# rw rM r� r� r r r �test_stdout_fileobj5 �
��
z#ProcessTestCase.test_stdout_fileobjc C r� )Nr �*import sys; sys.stderr.write("strawberry")rl �
strawberry)r r: rK rL r; rM r9 r� r@ r r r �test_stderr_pipe@ r z ProcessTestCase.test_stderr_pipec C r )Nr r rl r r r
r r� r r r �test_stderr_filedesH r z#ProcessTestCase.test_stderr_filedesc C r )Nr r rl r r
r r� r r r �test_stderr_fileobjT r z#ProcessTestCase.test_stderr_fileobjc C sR t jtjddgt jt jd�}|�� \}}| �|d� | �|d� | �|jd� d S )Nr z�import sys, subprocess;rc = subprocess.call([sys.executable, "-c", "import sys;" "sys.stderr.write('42')"], stderr=subprocess.STDOUT);sys.exit(rc)r� s 42� r �r r: rK rL r; r� rM r �r rA r8 r9 r r r �,test_stderr_redirect_with_no_stdout_redirect_ s
�� z<ProcessTestCase.test_stderr_redirect_with_no_stdout_redirectc C sX t jtjddgt jt jd�}|� | �|j�� d� W d � d S 1 s%w Y d S )Nr �Rimport sys;sys.stdout.write("apple");sys.stdout.flush();sys.stderr.write("orange")r� � appleorange) r r: rK rL r; rm rM r8 r� r@ r r r �test_stdout_stderr_pipet s
��"�z'ProcessTestCase.test_stdout_stderr_pipec C sR t �� }| �|j� tjtjddg||d�}|�� |� d� | �
|� � d� d S )Nr r r� r r r r� r r r �test_stdout_stderr_file� s
��
z'ProcessTestCase.test_stdout_stderr_filec C r� )Nz�import sys, subprocess; rc = subprocess.call([sys.executable, "-c", "import os, sys; sys.exit(os.write(sys.stdout.fileno(), b'test with stdout=1'))"], stdout=1); assert rc == 18r r� r s test with stdout=1r� r� r r r � test_stdout_filedes_of_stdout� s � z-ProcessTestCase.test_stdout_filedes_of_stdoutc C �2 t jtjddgt jd�}|�� | �|jd � d S )Nr z'for i in range(10240):print("x" * 1024)r� )r r: rK rL �DEVNULLr# rM r8 r@ r r r �test_stdout_devnull� �
��z#ProcessTestCase.test_stdout_devnullc C r )Nr z=import sys
for i in range(10240):sys.stderr.write("x" * 1024)rl )r r: rK rL r r# rM r9 r@ r r r �test_stderr_devnull� s
��z#ProcessTestCase.test_stderr_devnullc C r )Nr z import sys;sys.stdin.read(1)rq )r r: rK rL r r# rM r7 r@ r r r �test_stdin_devnull� r z"ProcessTestCase.test_stdin_devnull� F_GETPIPE_SZz%fcntl.F_GETPIPE_SZ required for test.c C s� t �� \}}zt�|tj�}W t �|� t �|� n t �|� t �|� w |d }|dk r2t�d��tjt j
ddgtj tj tj |d�}z.|j |j
|jfD ]}| �t�|�� tj�|� qL|j �d� |j �� W |�� |�� d S |�� |�� w )N� i z+default pipesize too small to perform test.r �Qimport sys; sys.stdin.read(); sys.stdout.write("out"); sys.stderr.write("error!")�r7 r8 r9 �pipesizero )r �pipe�fcntlr r? �unittest�SkipTestr r: rK rL r; r7 r8 r9 rM r� rv �killr# )r Z test_pipe_rZ test_pipe_wZpipesize_defaultr$ rA �fifor r r �test_pipesizes� s>
� ���� �
z ProcessTestCase.test_pipesizesc C s� t jtjddgt jt jt jdd�}zMt�� \}}z+t�|tj�}|j |j
|j fD ]}| � t�|�
� tj�|� q(W t�|� t�|� n t�|� t�|� w |j �� W |�� |�� d S |�� |�� w )Nr r" ���r# )r r: rK rL r; r r% r& r r7 r8 r9 rM r� r? r) r# )r rA Zfp_rZfp_wZdefault_pipesizer* r r r �test_pipesize_default� s4 �� ��
� �
z%ProcessTestCase.test_pipesize_defaultc C sj t j�� }d|d< tjtjddgtj|d��}|�� \}}| � |d� W d � d S 1 s.w Y d S )N�oranger� r �2import sys,os;sys.stdout.write(os.getenv("FRUIT"))�r8 r� r� )
r r� r� r r: rK rL r; r� rM �r r� rA r8 r9 r r r �test_env� s
�� "�zProcessTestCase.test_envr z#cannot test an empty env on WindowsZPy_ENABLE_SHAREDr� zEThe Python shared library cannot be loaded with an empty environment.T)�addressz)AddressSanitizer adds to the environment.c s� dd� � t jtjddgt ji d��*}|�� \}}t|�� �}| �|t � � fdd�|D �}| �
|g � W d � dS 1 s>w Y dS ) z+Verify that env={} is as empty as possible.c S s* d| v pd| v p| dkp| � d�p| dkS )z:Determine if an environment variable is under our control.Z VERSIONERZ__CFZ
LD_PRELOADZSANDBOX�LC_CTYPE)�
startswith)�nr r r �is_env_var_to_ignore s ���z<ProcessTestCase.test_empty_env.<locals>.is_env_var_to_ignorer z)import os; print(list(os.environ.keys()))r0 c s g | ]}� |�s|�qS r r )�.0�k�r7 r r �
<listcomp> s
�z2ProcessTestCase.test_empty_env.<locals>.<listcomp>N) r r: rK rL r; r� �eval�stripr< �listrM )r rA r8 r9 Zchild_env_namesr r: r �test_empty_env s
�� "�z ProcessTestCase.test_empty_envc C s� t jd }| �t�� t�|ddg� W d � n1 s w Y | �t�� t�t jddg� W d � d S 1 s<w Y d S )N� r r zpass# )rK rL rU r� r r: )r �cmdr r r �test_invalid_cmd" s
� "�z ProcessTestCase.test_invalid_cmdc C sH t j�� }d|d< | �t�� tjt|d� W d � n1 s w Y t j�� }d|d< | �t�� tjt|d� W d � n1 sEw Y t j�� }d|d< | �t�� tjt|d� W d � n1 sjw Y t j�� }d|d< tjtj d d
gtj
|d ��}|� � \}}| � |d � W d � d S 1 s�w Y d S )
NZcabbagezFRUIT VEGETABLEr� zorange VEGETABLE=cabbager� Zlemonz FRUIT=ORANGEz orange=lemonr z3import sys, os;sys.stdout.write(os.getenv("FRUIT"))r0 s orange=lemon)
r r� r� rU r� r r: r rK rL r; r� rM r1 r r r �test_invalid_env, s6
�
�
�
�� "�z ProcessTestCase.test_invalid_envc C s4 t jtjddgt jd�}|�d� | �|jd� d S )Nr z/import sys;sys.exit(sys.stdin.read() == "pear")rq ro r� r r@ r r r �test_communicate_stdinJ s
��
z&ProcessTestCase.test_communicate_stdinc C s@ t jtjddgt jd�}|�� \}}| �|d� | �|d � d S )Nr z)import sys; sys.stdout.write("pineapple")r� � pineapple�r r: rK rL r; r� rM r r r r �test_communicate_stdoutR �
�� z'ProcessTestCase.test_communicate_stdoutc C s@ t jtjddgt jd�}|�� \}}| �|d � | �|d� d S )Nr z)import sys; sys.stderr.write("pineapple")rl rE rF r r r r �test_communicate_stderrZ rH z'ProcessTestCase.test_communicate_stderrc C st t jtjddgt jt jt jd�}| �|jj� | �|jj� | �|j j� |�
d�\}}| � |d� | � |d� d S )Nr zNimport sys,os;sys.stderr.write("pineapple");sys.stdout.write(sys.stdin.read())r6 � bananarE ) r r: rK rL r; ru r8 r? r9 r7 r� rM r r r r �test_communicateb s
�� z ProcessTestCase.test_communicatec C sd t jtjddgdt jt jt jd�}| jt j|jddd� |�� \}}| �|d� | �|� � d� d S ) Nr z~import sys,os,time;sys.stderr.write("pineapple\n");time.sleep(1);sys.stderr.write("pear\n");sys.stdout.write(sys.stdin.read())T)r� r7 r8 r9 r� g333333�?rS s pineapple
pear
)
r r: rK rL r; rU rV r� rM �encoder r r r �test_communicate_timeoutq s
��
� z(ProcessTestCase.test_communicate_timeoutc C sL t jtjddgt jd�}| jt j|jdd� |�� \}}| �t |�d� d S )Nr z�import sys,os,time;sys.stdout.write("a" * (64 * 1024));time.sleep(0.2);sys.stdout.write("a" * (64 * 1024));time.sleep(0.2);sys.stdout.write("a" * (64 * 1024));time.sleep(0.2);sys.stdout.write("a" * (64 * 1024));r� g�������?rS i )
r r: rK rL r; rU rV r� rM �len)r rA r8 �_r r r �%test_communicate_timeout_large_output� s
� �
z5ProcessTestCase.test_communicate_timeout_large_outputc C s� dD ]W}dD ]R}dD ]M}i }|rt j|d< |r t j|d< |r#t j|d< |s&q
t jtfi |��}|�� |jd ur?| �|jj� |jd urK| �|jj� |j d urW| �|j j� q
qqd S )N�FTr7 r8 r9 )
r r; r: r r� r7 �
assertTrue�closedr8 r9 )r Z
stdin_pipeZ stdout_pipeZ stderr_pipe�optionsrA r r r � test_communicate_pipe_fd_leak� s0
����z-ProcessTestCase.test_communicate_pipe_fd_leakc C s: t �tjddg�}|�� \}}| �|d � | �|d � d S )Nr rG )r r: rK rL r� rM r r r r �test_communicate_returns� s
� z(ProcessTestCase.test_communicate_returnsc C s� t �� \}}t �|� t �|� tjtjddtj gtj tj tj d�}| �
|j j� | �
|j j� | �
|j
j� dtj }|�|�\}}| �||� d S )Nr zpimport sys,os;sys.stdout.write(sys.stdin.read(47));sys.stderr.write("x" * %d);sys.stdout.write(sys.stdin.read())r6 � a)r r% r? r r: rK rL r �
PIPE_MAX_SIZEr; ru r8 r9 r7 r� rM )r �x�yrA Zstring_to_writer8 r9 r r r �test_communicate_pipe_buf� s$
���
z)ProcessTestCase.test_communicate_pipe_bufc C s� t jtjddgt jt jt jd�}| �|jj� | �|jj� | �|j j� |j �
d� |� d�\}}| � |d� | � |d� d S )Nr z0import sys,os;sys.stdout.write(sys.stdin.read())r6 rJ s splits bananasplitr )
r r: rK rL r; ru r8 r? r9 r7 rv r� rM r r r r � test_writes_before_communicate� s
�� z.ProcessTestCase.test_writes_before_communicatec
C s� t jddt d g}dD ]g}tj|fi dtjdtj|di��}|�J |j�d� |j�� | � |j
� � d� |j�d � |j� � | �
|j
j � | � |j
� � d
� | � |j
�d �d � | � |j
�� d � W d � n1 snw Y q d S )
Nr �import sys,os;a@ buf = sys.stdout.buffer;buf.write(sys.stdin.readline().encode());buf.flush();buf.write(b"line2\n");buf.flush();buf.write(sys.stdin.read().encode());buf.flush();buf.write(b"line4\n");buf.flush();buf.write(b"line5\r\n");buf.flush();buf.write(b"line6\r");buf.flush();buf.write(b"\nline7");buf.flush();buf.write(b"\nline8");)r� r� r7 r8 Tzline1
zline3
zline2
� z line4
line5
line6
line7
line8)rK rL � SETBINARYr r: r; r7 rv �flushrM r8 �readliner? ru r� )r r0 Z extra_kwargrA r r r � test_universal_newlines_and_text� s: ���
�� � ���z0ProcessTestCase.test_universal_newlines_and_textc C s^ t jtjddt d gt jt jdd�}| �|jj� | �|j j� |�
� \}}| � |d� d S )Nr r] z�buf = sys.stdout.buffer;buf.write(b"line2\n");buf.flush();buf.write(b"line4\n");buf.flush();buf.write(b"line5\r\n");buf.flush();buf.write(b"line6\r");buf.flush();buf.write(b"\nline7");buf.flush();buf.write(b"\nline8");r� )r9 r8 r� z#line2
line4
line5
line6
line7
line8) r r: rK rL r_ r; ru r8 r? r9 r� rM r r r r �#test_universal_newlines_communicate s
��� �z3ProcessTestCase.test_universal_newlines_communicatec C sH t jtjddt t�d� gt jdd�}|�d�\}}| � |j
d� d S )Nr r] a
s = sys.stdin.readline()
assert s == "line1\n", repr(s)
s = sys.stdin.read()
assert s == "line3\n", repr(s)
r� )r7 r� � line1
line3
r ) r r: rK rL r_ �textwrap�dedentr; r� rM r r r r r �)test_universal_newlines_communicate_stdin s
�� z9ProcessTestCase.test_universal_newlines_communicate_stdinc C s0 t jtt jt jdd�}|�� | �|jd� d S )NT)r7 r8 r� r )r r: r r; r� rM r r@ r r r �.test_universal_newlines_communicate_input_none( s �z>ProcessTestCase.test_universal_newlines_communicate_input_nonec C s� t jtjddt t�d� gt jt jt jdd�}| �|j j
� | �|j j
� |� d�\}}| �
|jd� | �
d|� | �|�d �� d S )
Nr r] a�
s = sys.stdin.buffer.readline()
sys.stdout.buffer.write(s)
sys.stdout.buffer.write(b"line2\r")
sys.stderr.buffer.write(b"eline2\n")
s = sys.stdin.buffer.read()
sys.stdout.buffer.write(s)
sys.stdout.buffer.write(b"line4\n")
sys.stdout.buffer.write(b"line5\r\n")
sys.stderr.buffer.write(b"eline6\r")
sys.stderr.buffer.write(b"eline7\r\nz")
T)r7 r9 r8 r� rd r z line1
line2
line3
line4
line5
zeline2
eline6
eline7
)r r: rK rL r_ re rf r; ru r8 r? r9 r� rM r rR r5 r r r r �7test_universal_newlines_communicate_stdin_stdout_stderr4 s
�
� zGProcessTestCase.test_universal_newlines_communicate_stdin_stdout_stderrc C sT dD ]%}d| }t jd|g}tj|tjtj|d�}|jdd�\}}| �|d� qd S )N)zutf-16z utf-32-bez@import sys; sys.stdout.buffer.write('1\r\n2\r3\n4'.encode('%s'))r )r7 r8 r� r
rz z1
2
3
4)rK rL r r: r; r� rM )r r� r� r0 �popenr8 r9 r r r �-test_universal_newlines_communicate_encodingsP s � ��z=ProcessTestCase.test_universal_newlines_communicate_encodingsc C s\ dD ])\}}d}t jd|g}tj|tjtjd|d�}|jdd�\}}| �|d�|�� qd S ) N))r� r
)�replaceu ��)�surrogateescapeu ��)�backslashreplacez\x80\x80z2import sys; sys.stdout.buffer.write(b'[\x80\x80]')r r� )r7 r8 r� r� r
rz z[{}])rK rL r r: r; r� rM �format)r r� �expectedr� r0 rj r8 r9 r r r �test_communicate_errorsf s ��z'ProcessTestCase.test_communicate_errorsc
C sB t sd}nd}g }t�� }z�t|�D ]3}ztj�|tj�}|� t�
|tj tj B �� W q t
yE } z|jtjkr:� W Y d }~ n d }~ww | �d| � td�D ] }t�|�� � qQtd�D ] }tjtjddgtjtjtjd�}|�d �d
}| �|d � q_W |D ]} t�| � q�t�|� d S |D ]} t�| � q�t�|� w ) Ni i z4failed to reach the file descriptor limit (tried %d)�
� r z-import sys;sys.stdout.write(sys.stdin.read())r6 s limer ) r! rs �mkdtemp�ranger r� r� r ZTESTFN�append�open�O_WRONLY�O_CREAT�OSError�errnoZEMFILE�skipTestr? �popr r: rK rL r; r� rM r �rmtree)
r Z max_handles�handles�tmpdir�iZtmpfile�erA �data�hr r r �test_no_leaking{ sL ���
���
� z ProcessTestCase.test_no_leakingc C s� | � t�g d��d� | � t�g d��d� | � t�g d��d� | � t�g d��d� | � t�g d ��d
� | � t�g d ��d � | � t�g d
��d� | � t�ddg�d� d S )N)za b cr� r� z "a b c" d e)�ab"c�\r� z ab\"c \ d)r� z \r� z
ab\"c " \\" d)za\\\bzde fgr� za\\\b "de fg" h)za\"br_ r� z
a\\\"b c d)za\\b cr� r� z "a\\b c" d e)za\\b\ cr� r� z
"a\\b\ c" d e�abr
zab "")rM r � list2cmdliner r r r �test_list2cmdline� s0 ��������z!ProcessTestCase.test_list2cmdlinec C sb t jtjddgt jd�}| �|jj� | �|� � � t
� |j� � d� |�
� | �|� � d� d S )Nr zimport os; os.read(0, 1)rq � Ar )r r: rK rL r; ru r7 r? � assertIsNone�pollr rv r� r# rM r@ r r r � test_poll� s
��zProcessTestCase.test_pollc C s. t �t�}| �|�� d� | �|�� d� d S rX �r r: r rM r# r@ r r r � test_wait� s
zProcessTestCase.test_waitc C sv t �tjddg�}| �t j��}|jdd� W d � n1 s w Y | �dt|j �� | �
|jt j d�d� d S )Nr z import time; time.sleep(0.3)�-C ��6?rS z0.0001r )
r r: rK rL rU rV r# re �strr] rM r �
SHORT_TIMEOUT)r rA r_ r r r �test_wait_timeout� s � �z!ProcessTestCase.test_wait_timeoutc C s< | � t�� t�td� W d � d S 1 sw Y d S )Nr. )rU r� r r: r r r r r �test_invalid_bufsize� s "�z$ProcessTestCase.test_invalid_bufsizec C s> t �td �}| �|�� d� t jtd d�}| �|�� d� d S )Nr )rC r� r@ r r r �test_bufsize_is_none� s z$ProcessTestCase.test_bufsize_is_nonec
C s� t jtjddgt jt jt jd|d��C}|j�|� t� |j�
� � |j � � }t
�� � z|j� � W n ty; Y nw W d � n1 sFw Y d |_W d � n1 sXw Y | �|jd� | �||� d S )Nr zDimport sys;sys.stdout.write(sys.stdin.readline());sys.stdout.flush()r� )r7 r8 r9 rC r� r )r r: rK rL r; r r7 rv r r? r� r8 ra r �SuppressCrashReportrz rM r )r �linerp r� rA Z read_liner r r �_test_bufsize_equal_one� s. �
�� � �z'ProcessTestCase._test_bufsize_equal_onec C s d}| j ||dd� d S )Nzline
T�r� )r� �r r� r r r � test_bufsize_equal_one_text_mode� s z0ProcessTestCase.test_bufsize_equal_one_text_modec C sP dt j�� }| �td�� | j|ddd� W d � d S 1 s!w Y d S )Ns linezline bufferingr Fr� )r �lineseprL ZassertWarnsRegex�RuntimeWarningr� r� r r r �"test_bufsize_equal_one_binary_mode� s "�z2ProcessTestCase.test_bufsize_equal_one_binary_modec C sP t d�D ]!}| �t�� tjttjtjd� W d � n1 s w Y qd S )Nr r� )ru rU r� r r: r� r; )r r� r r r �test_leaking_fds_on_error� s � ���z)ProcessTestCase.test_leaking_fds_on_errorc C s� z dd l }|j W n ttfy | �d� Y nw t�dt�d��}tj d|g}t
j |t
j dd�}|� |�
� d }W d � n1 sEw Y | �|d � | �|jd� d S )
Nr z need msvcrt.CrtSetReportModezL
import msvcrt
import subprocess
cmd = a
for report_type in [msvcrt.CRT_WARN,
msvcrt.CRT_ERROR,
msvcrt.CRT_ASSERT]:
msvcrt.CrtSetReportMode(report_type, msvcrt.CRTDBG_MODE_FILE)
msvcrt.CrtSetReportFile(report_type, msvcrt.CRTDBG_FILE_STDERR)
try:
subprocess.Popen(cmd,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
except OSError:
pass
r T)r9 r� r� r
)�msvcrtZCrtSetReportMode�AttributeError� ImportErrorr| re rf r� rK rL r r: r; r� rM r )r r� r� rA �procr9 r r r �test_nonexisting_with_pipes
s&
�
� � � z+ProcessTestCase.test_nonexisting_with_pipesc s g � � fdd�}t j|d�}|�� zP| �t�� tjttjtjtjd� W d � n1 s/w Y W |� � d }� D ] }zt
� |� W q= t yZ } z|}W Y d }~q=d }~ww |d ura|�d S |� � d }� D ] }zt
� |� W qk t y� } z|}W Y d }~qkd }~ww |d ur�|�w )Nc s* t d�D ]} � �t�� � t�d� qd S )N� g����MbP?)ru �extendr r% �time�sleep)r� ��fdsr r �open_fds6 s �z<ProcessTestCase.test_double_close_on_error.<locals>.open_fds)�targetr6 )
� threading�Thread�startrU �EnvironmentErrorr r: r� r; r� r r? rz )r r� �t�exc�fdr� r r� r �test_double_close_on_error3 sH � ��������z*ProcessTestCase.test_double_close_on_errorc s� t �tjddg�� | �� jd� g �� �fdd�}t�d|�}|�� t r(d}nd}� j
t j d � | j� j|d
d � � �
� | j� j|d d � |�
� | �d
d|fd|fg�� dS )z?Issue21291: Popen.wait() needs to be threadsafe for returncode.r zimport time; time.sleep(12)Nc sN �� d� �� f� � �� � �� �� d� jf� � �� �� d� jf� d S )N�thread-start-poll-result�thread-after-kill-and-wait�thread-after-second-wait)rv r� r) r# r r �r� �resultsr r �kill_proc_timer_threadW s zDProcessTestCase.test_threadsafe_wait.<locals>.kill_proc_timer_thread皙�����?r� i����rS z*unexpected result in wait from main thread��msgz&unexpected result in second main wait.)r� Nr� r� )r r: rK rL rM r r� �Timerr� r! r# r r� r� )r r� r� Zexpected_errorcoder r� r �test_threadsafe_waitP s4
�
�
���z$ProcessTestCase.test_threadsafe_waitc C s6 d� d�}t�tjd|g�}| �|�d�t|�� d S )N�;)zimport subprocess, syszJretcode = subprocess.call([sys.executable, '-c', 'print("Hello World!")'])zassert retcode == 0r s Hello World!)r� r rd rK rL rR r5 �ascii)r r� rg r r r �test_issue8780� s
z ProcessTestCase.test_issue8780c C s� t �� \}}t �� \}}t �� \}}z tjdg|||d� W n' tyE t�|� t�|� t�|� t�|� t�|� t�|� Y nw | �tj �
|�� | �tj �
|�� | �tj �
|�� d S )N�*r6 ) rs �mkstempr r: rz r r? �remover% r� �exists)r ZifhandleZifnameZofhandleZofnameZefhandleZefnamer r r � test_handles_closed_on_exception� s$
�
�z0ProcessTestCase.test_handles_closed_on_exceptionc C sT t jtt jt jt jd�}| �|jj� | �|jj� | �|jj� |� dd � d S )Nr6 � x� )
r r: r r; ru r8 r? r9 r7 r� r@ r r r �test_communicate_epipe� s �z&ProcessTestCase.test_communicate_epipec
C s� t �d�}|jj}dddgdd dfg d�dd df|dd d
|� d �fg}tjj�tj d ��$ |D ]\}}}}tj ||d
�}||_
| � t |�|� q/W d � d S 1 sSw Y d S )Nz
my-tool.py)�lsT�{ z#<Popen: returncode: 123 args: 'ls'>)�daaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaTr zP<Popen: returncode: 0 args: 'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa...>r� Fz&<Popen: returncode: None args: ['ls']>)r� z --my-optsr� zP<Popen: returncode: None args: ['ls', '--my-opts', 'aaaaaaaaaaaaaaaaaaaaaaaa...>� z <Popen: returncode: 7 args: z('my-tool.py')>r2 �r� )
�pathlib�Path� __class__r) r' r �patch�objectr r: r rM �repr) r Zpath_cmdZ pathlib_cls�casesrA r� r� ZsxrA r r r � test_repr� s"
�� �"�zProcessTestCase.test_reprc C s8 t jtt jd�}| �|jj� |�� |�dd � d S )Nrq r� r� ) r r: r r; ru r7 r? r# r� r@ r r r �!test_communicate_epipe_only_stdin� s �z1ProcessTestCase.test_communicate_epipe_only_stdin�SIGUSR1zRequires signal.SIGUSR1r) zRequires os.kill�getppidzRequires os.getppidc C s� dd� }t � t j|�}| �t j t j|� tjddg}dD ]$}|tji}tj|fi |��� }|�� W d � n1 s;w Y q d S )Nc S � d S r r )�signum�framer r r �handler� � z7ProcessTestCase.test_communicate_eintr.<locals>.handlerr z7import os, signal;os.kill(os.getppid(), signal.SIGUSR1)r� ) �signalr� ru rK rL r r; r: r� )r r� � old_handlerr0 �stream�kw�processr r r �test_communicate_eintr� s �
���z&ProcessTestCase.test_communicate_eintr� /proc/%d/fdzLinux specificc C sp dt �� }t �|�}| �t�� tttjtjtjd� W d � n1 s&w Y t �|�}| � ||� dS )z;Test for the fork() failure fd leak reported in issue16327.r� r6 N)
r �getpid�listdirrU r, r- r r r; rM )r Z fd_directoryZfds_before_popenZfds_after_exceptionr r r �!test_failed_child_execute_fd_leak� s
� �
z1ProcessTestCase.test_failed_child_execute_fd_leakz+behavior currently not supported on Windowsc C sL | � t��}t�g d�� W d � n1 sw Y | �|jjd� d S )N)�/opt/nonexistent_binary�withZsomer0 r� )rU r� r rJ rM r] �filenamer^ r r r �%test_file_not_found_includes_filename� s �z5ProcessTestCase.test_file_not_found_includes_filenamec C sP | � t��}tjddgdd� W d � n1 sw Y | �|jjd� d S )N�exit�0z/some/nonexistent/directoryr� )rU r� r r: rM r] r� r^ r r r � test_file_not_found_with_bad_cwd� s �z0ProcessTestCase.test_file_not_found_with_bad_cwdc C s, | � tjt tj� | � tjt tj� d S r )r< r r: �bytes�types� GenericAlias�CompletedProcessr� r r r r �test_class_getitems s z#ProcessTestCase.test_class_getitemsN)r) r* r+ rB rE rP rW rZ r` rh rj rn ry r| r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r' �skipIfr! r� r� r� r� r� r� r� r� r� r� r� r� rK � base_prefix�prefixr� � sysconfigZis_python_buildr� r� r� r� r r r
r r r r r r r r r r �
skipUnlessr& �hasattrr+ r- r2 �platform�get_config_varr r? rB rC rD rG rI rK rM rP rU rV r[ r\ rb rc rg rh ri rk rq r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� �isdirr� r� r� r� r� r r r r r5 p s*
�
�
�
�
�
�� �
' ' ) 4 � � ��
r5 c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Ze�ed%�d&d'� �Ze�e�d(� d)�d*d+� �Zd,S )-�RunFuncTestCasec K s t jd|g}tj|fi |��S )z4Run Python code in a subprocess using subprocess.runr )rK rL r r )r r� r1 �argvr r r �
run_python s zRunFuncTestCase.run_pythonc C sR | � d�}| �|jd� | �tj��
|�� W d � d S 1 s"w Y d S r� )r rM r rU r r\ �check_returncode�r �cpr r r �test_returncode
s
"�z RunFuncTestCase.test_returncodec C sN | � tj��}| jddd� W d � n1 sw Y | �|jjd� d S )NrG T��checkrH )rU r r\ r rM r] r r^ r r r �
test_check s �zRunFuncTestCase.test_checkc C s t jtdd�}| �|jd� d S )NTr r )r r r rM r r r r r �test_check_zero s z RunFuncTestCase.test_check_zeroc C s@ | � tj�� | jddd� W d � d S 1 sw Y d S )NrQ r� rS )rU r rV r r r r r � test_timeout s "�z RunFuncTestCase.test_timeoutc C �" | j dtjd�}| �d|j� d S )Nra r� rb �r r r; re r8 r r r r �test_capture_stdout# s z#RunFuncTestCase.test_capture_stdoutc C r )Nrk rl rb )r r r; re r9 r r r r �test_capture_stderr( s �z#RunFuncTestCase.test_capture_stderrc C sL t �� }| �|j� |�d� |�d� | jd|tjd�}| � d|j
� d S )Nro r rp r� rr ) rs rt ru r? rv rw r r r; re r8 )r rx r r r r ry - s
�z+RunFuncTestCase.test_check_output_stdin_argc C s$ | j ddtjd�}| �d|j� d S )Nrp ro )r{ r8 rr r
r r r r r| 8 s
�z+RunFuncTestCase.test_check_output_input_argc C s� t �� }| �|j� |�d� |�d� | jtdd��}| jd|dd�}W d � n1 s.w Y | � d|j
j d � | � d |j
j d � d S )
Nro r r� r� r� r� r� r7 r{ ) rs rt ru r? rv rw rU r� r re r] r0 r� r r r r� ? s
�� �z6RunFuncTestCase.test_check_output_stdin_with_input_argc C sb | � tj��}| jddtjd�}W d � n1 sw Y | �|jjd� | �|jjd� d S )Nr� r� )rT r8 rb ) rU r rV r r; rM r] rg r8 )r r_ r r r r r� L s � � z)RunFuncTestCase.test_check_output_timeoutc C s2 t j�� }d|d< | jd|d�}| �|jd� d S )Nr� r� zCimport sys, os;sys.exit(33 if os.getenv("FRUIT")=="banana" else 31)r� �! )r r� r� r rM r )r r� r r r r �test_run_kwargsZ s
�z RunFuncTestCase.test_run_kwargsc C s� t rdnd}t�|�}|d u r| �|� d�� t|�}tj|tjd�}| �|j d� | �
t �� tj|tjdd� W d � d S 1 sDw Y d S )Nztree.comr� z required for this testr� r T)r8 r� ) r! r r r| r r r r rM r rU r� )r �progr� �resr r r �test_run_with_pathlike_pathb s
"�z+RunFuncTestCase.test_run_with_pathlike_pathc C s2 t �tj�}|ddg}t�|�}| �|jd� d S )Nr s import sys; sys.exit(57)�9 )r r� rK rL r r rM r �r r� r0 r r r r �&test_run_with_bytes_path_and_argumentsp s
z6RunFuncTestCase.test_run_with_bytes_path_and_argumentsc C s0 t tj�}|ddg}t�|�}| �|jd� d S )Nr zimport sys; sys.exit(57)r )r rK rL r r rM r r r r r �)test_run_with_pathlike_path_and_argumentsw s
z9RunFuncTestCase.test_run_with_pathlike_path_and_argumentsc C s. | j ddd�}| �d|j� | �d|j� d S )Nz>import sys;sys.stdout.write('BDFL'); sys.stderr.write('FLUFL')T)�capture_outputrb s FLUFL)r re r8 r9 r r r r �test_capture_output~ s
�z#RunFuncTestCase.test_capture_outputc C �~ t �� }| �|j� | jtdd��}| jdd|d�}W d � n1 s$w Y | �d|jj d � | �d|jj d � d S ) NzAExpected ValueError when stdout and capture_output args supplied.r� r� T)r r8 r8 r r �
rs rt ru r? rU r� r re r] r0 r� r r r �#test_stdout_with_capture_output_arg� � �� �z3RunFuncTestCase.test_stdout_with_capture_output_argc C r ) NzAExpected ValueError when stderr and capture_output args supplied.r� r� T)r r9 r9 r r r r� r r r �#test_stderr_with_capture_output_arg� r z3RunFuncTestCase.test_stderr_with_capture_output_argz)requires posix like 'sleep' shell commandc
C s� t �� }z tjddddd� W n tjy* } zt �� }t�� }W Y d}~n
d}~ww | �d� | j|| dd|� d �d
� dS ) zJOutput capturing after a timeout mustn't hang forever on open filehandles.zsleep 3TrR )r� rT r NzTimeoutExpired not raised.g �?z/TimeoutExpired was delayed! Bad traceback:
```
z```r� ) r� � monotonicr r rV � traceback�
format_excr� Z
assertLess)r Z before_secsr� Z
after_secsZstacksr r r �.test_run_with_shell_timeout_and_capture_output� s
���
�
�z>RunFuncTestCase.test_run_with_shell_timeout_and_capture_outputZ
HAVE_VFORKz!vfork() not enabled by configure.c C s� | � tj� tj�tdd�� | j| �d�jddd� W d � n1 s%w Y G dd� d�}tj�td|� ��# | j| �d�jdd d� t`| j| �d�jdd
d� W d � d S 1 s`w Y d S ) N�
_USE_VFORKFr r zFalse _USE_VFORK failedr� c @ � e Zd Zdd� ZdS )z4RunFuncTestCase.test__use_vfork.<locals>.RaisingBoolc S r. )Nz"force PyObject_IsTrue to return -1)� RuntimeErrorr r r r �__bool__� r3 z=RunFuncTestCase.test__use_vfork.<locals>.RaisingBool.__bool__N)r) r* r+ r' r r r r � RaisingBool� � r( z"odd bool()-error _USE_VFORK failedz%lack of a _USE_VFORK attribute failed) rR r r$ r r� r� rM r r )r r( r r r �test__use_vfork� s � ���"�z RunFuncTestCase.test__use_vforkN) r) r* r+ r r r r
r r r ry r| r� r� r r r r r r r r' r� r! r# r� r� r* r r r r r s2
�r c C s@ dD ]} t rz
t �| � W | S ty Y qw qt�d��)N)ZstaffZnogroup�grp�nobodyZ nfsnobodyz?No identified group name to use for this test on this platform.)r+ �getgrnam�KeyErrorr' r( )�
name_groupr r r �_get_test_grp_name� s ���
r0 zPOSIX specific testsc s e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� ZG d d � d ej �Z
e � d
�dd� �Z
e � d
�dd� �Ze�ej�d� d�dd� �Zdd� Ze�eed�d�dd� �Ze�eed�d �d d � �Ze�eed �d �d!d"� �Ze�eed �d#�d$d%� �Ze�eed&�d'�d(d)� �Z e�eed&�d*�d+d,� �Z e�e p�eed-� d.�d/d0� �Z d1d2� Z d3d4� Z!d5d6� Z"d7d8� Z#d9d:� Z$d;d<� Z%G d=d>� d>ej �Z&e�ej�d?� d@�dAdB� �Z'dCdD� Z(e�e)j*dEkdF�dGdH� �Z+dIdJ� Z,dKdL� Z-dMdN� Z.dOdP� Z/dQdR� Z0dSdT� Z1dUdV� Z2e�e)j*�3dW�dX�dYdZ� �Z4d[d\� Z5d]d^� Z6d_d`� Z7dadb� Z8dcdd� Z9dedf� Z:dgdh� Z;didj� Z<dkdl� Z=dmdn� Z>dodp� Z?dqdr� Z@dsdt� ZAdudv� ZBdwdx� ZCdydz� ZDd{d|� ZEd}d~� ZFdd�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPe�e)j*�3d���o�e�Qd��jRe�Qd��jRkd��d�d�� �ZSeT�Ud�d��d�d�� �ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�� Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`eTjad�d�� �ZbeTjad�d�� �Zcd�d�� Zdd�d�� Zed�d�� Zfd�d�� Zge�ehd�u�o�eehd��d��d�d�� �Zid�dÄ Zjd�dń Zkd�dDŽ Zl� ZmS )��POSIXProcessTestCasec s t � �� d| _d S )Nz/_this/pa.th/does/not/exist)�superr �_nonexistent_dirr �r� r r r � s
zPOSIXProcessTestCase.setUpc
C sP zt �| j� W n ty } z |}W Y d }~|S d }~ww | �d| j � |S )Nz,chdir to nonexistent directory %s succeeded.)r �chdirr3 rz r� )r r� �desired_exceptionr r r �_get_chdir_exception� s ���z)POSIXProcessTestCase._get_chdir_exceptionc
C � | � � }ztjtjddg| jd�}W n+ ty= } z | �|j|j� | �|j |j � | �|j
|j
� W Y d}~dS d}~ww | � d| � dS )z;Test error in the child raised in the parent for a bad cwd.r r
r� N�Expected OSError: %s� r7 r r: rK rL r3 rz rM r{ �strerrorr� r� �r r6 rA r� r r r �test_exception_cwd� �
� ��z'POSIXProcessTestCase.test_exception_cwdc
C r8 )zBTest error in the child raised in the parent for a bad executable.r r
r� Nr9 r: r< r r r � test_exception_bad_executable� r> z2POSIXProcessTestCase.test_exception_bad_executablec
C s� | � � }z t�| jddg�}W n+ ty: } z | �|j|j� | �|j|j� | �|j|j� W Y d}~dS d}~ww | � d| � dS )z?Test error in the child raised in the parent for a bad args[0].r r
Nr9 )
r7 r r: r3 rz rM r{ r; r� r� r< r r r �test_exception_bad_args_0 s ��z.POSIXProcessTestCase.test_exception_bad_args_0c @ r% )z&POSIXProcessTestCase.PopenNoDestructorc C r� r r r r r r �__del__ r� z.POSIXProcessTestCase.PopenNoDestructor.__del__N)r) r* r+ rA r r r r �PopenNoDestructor r) rB z%subprocess._posixsubprocess.fork_execc C s� dd� }||_ tjdtd��, | �t�� | �dg� W d � n1 s%w Y W d � dS W d � dS 1 s=w Y dS )z>Test error passing done through errpipe_write in the good casec W s0 | d }d� tj��� }t�|d| d � dS )N�
z{:x}s OSError:� :r )ro r{ ZEISDIRrL r rv )r0 �
errpipe_writeZerr_coder r r � proper_error# s zHPOSIXProcessTestCase.test_exception_errpipe_normal.<locals>.proper_error�subprocess.os.waitpid�� side_effect�non_existent_commandN)rI r r� �ChildProcessErrorrU �IsADirectoryErrorrB )r � fork_execrF r r r � test_exception_errpipe_normal s � ��"�z2POSIXProcessTestCase.test_exception_errpipe_normalc s� d� � fdd�}||_ tjdtd��$ | �tj��}| �dg� W d � n1 s*w Y W d � n1 s9w Y | �t � �t
|j �� dS )zZTest error passing done through errpipe_write where its not
in the expected formats � ޭc s | d }t �|� � dS )NrC r )r rv )r0 rE �Z
error_datar r � bad_error6 s zGPOSIXProcessTestCase.test_exception_errpipe_bad_data.<locals>.bad_errorrG rH rJ N) rI r r� rK rU r �SubprocessErrorrB re r� r� r] )r rM rP r� r rO r � test_exception_errpipe_bad_data1 s � �� �z4POSIXProcessTestCase.test_exception_errpipe_bad_data�/proc/self/statuszneed /proc/self/statusc C s� t jddgdd�}|�� D ] }|�d�r|} nq
| �d� t jddgdd�}|�� D ] }|�d�r6|} nq+| j||dd � d S )
N�catrS F)�restore_signalss SigIgnz&SigIgn not found in /proc/self/status.Tz=restore_signals=True should've unblocked SIGPIPE and friends.r� )r rd �
splitlinesr5 r| �assertNotEqual)r Zdefault_proc_statusr� Zdefault_sig_ign_maskZrestored_proc_statusZrestored_sig_ign_maskr r r �test_restore_signalsG s, �
�
�
�
�z)POSIXProcessTestCase.test_restore_signalsc
C sr z
t jtjddgdd�}W n ty' } z|jtjkr � W Y d }~d S d }~ww t�d�}t |�}| �
||� d S )Nr z import os; print(os.getsid(0))T)�start_new_sessionr ) r rd rK rL rz r{ �EPERMr �getsid�intrW )r rg r� Z
parent_sidZ child_sidr r r �test_start_new_session_ s
� ���
z+POSIXProcessTestCase.test_start_new_session�setreuidzno setreuid on platformc
C s t �� }|dkr
dnd|g}tjdkrdnd}td ur3z t�|� |�|� W n ty2 d }Y nw |D ]i}dD ]d}| j||d��S zt j
tj dd g||d�}W n$ t yZ Y n4 t
yu } z|jtjtjfvrk� W Y d }~n d }~ww t|t�r�t�|�j}n|}t|�} | �| |� W d � n1 s�w Y q9q5| �t�� t jtd
d � W d � n1 s�w Y | �t�� t jtt jt j d d
� W d � n1 s�w Y td u �r|d u�r| �t�� t jt|d � W d � d S 1 s�w Y d S d S d S )N� � �darwinr, �unknownrQ )�user� close_fdsr z import os; print(os.getuid())r, �rc � )r� r� rc ) r �geteuidrK r� �pwd�getpwnamrv r. �subTestr rd rL �PermissionErrorrz r{ ZEACCESrZ �
isinstancer� �pw_uidr\ rM rU r� rY r �
OverflowErrorr� r� )
r �uidZ
test_usersZname_uidrc rd rg r� Zuser_uidZ
child_userr r r � test_usero sf
��
� ���
� ��� �
� � "��z POSIXProcessTestCase.test_userz setreuid() available on platformc C �> | � t�� tjtdd� W d � d S 1 sw Y d S )N� re �rU r� r rY r r r r r �test_user_error� � "�z$POSIXProcessTestCase.test_user_error�setregidzno setregid() on platformc C s� t �� }|dkr
dndg}t� }td ur|�|� ||g D ]N}dD ]I}| j||d��8 ztjtj ddg||d�}W n t
yC Y nw t |t �rPt�
|�j}n|}t|�}| �||� W d � n1 sfw Y q"q | �t�� tjtdd� W d � n1 s�w Y | �t�� tjtt jt jd d
� W d � n1 s�w Y td u r�| �t�� tjt|d� W d � d S 1 s�w Y d S d S ) Nr_ r` rQ )�grouprd r z import os; print(os.getgid())r, �rw rf )r� r� rw )r �getegidr0 r+ rv rj r rd rK rL rk rl r� r- �gr_gidr\ rM rU r� rY r rn r� r� ) r �gid�
group_listr/ rw rd rg Z group_gidZ child_groupr r r �
test_group� sR
�
� �
� ��� �
� � "��z POSIXProcessTestCase.test_groupz setregid() available on platformc C rq )Nrr rx rs r r r r �test_group_error� ru z%POSIXProcessTestCase.test_group_error� setgroupszno setgroups() on platformc
C s� t �� }|dkr
dndg}t� }d}td ur|�|� z
tjtjddg|d�}W n t yC } z|j
t
j kr7� d}W Y d }~n3d }~ww t � � }t
�|�}td urYdd � |D �} n|} |rh| �t|�t|�� n
| �t| �t|�� | �t�� tjtd
gd� W d � n1 s�w Y | �t�� tjtt jt jd gd � W d � n1 s�w Y td u r�| �t�� tjt|gd� W d � d S 1 s�w Y d S d S )
Nr_ r` Fr z;import os, sys, json; json.dump(os.getgroups(), sys.stdout)�� extra_groupsTc S s& g | ]}t |t�rt�|�jn|�qS r )rl r� r+ r- rz )r8 �gr r r r; � s �z:POSIXProcessTestCase.test_extra_groups.<locals>.<listcomp>r, rf )r� r� r� )r ry r0 r+ rv r rd rK rL rz r{ rZ � getgroups�json�loadsrM �setrU r� rY r r� r� )
r r{ r| r/ Z
perm_errorrg �exZ
parent_groupsZ child_groupsZ desired_gidsr r r �test_extra_groups� sZ
�
� ��
� � � � �"��z&POSIXProcessTestCase.test_extra_groupsz!setgroups() available on platformc C s> | � t�� tjtg d� W d � d S 1 sw Y d S )Nr� rs r r r r �test_extra_groups_error ru z,POSIXProcessTestCase.test_extra_groups_error�umaskz POSIX umask() is not available.c C s� d }zCt �� }tj�|d�}tjtjdd|�d�gdd� t� |�j
d@ }d}| j ||t |�� d t |�� �d
� W |d urDt
�|� d S d S |d urPt
�|� w w ) NZbeansr zopen(z, 'w').close()�+ )r� i� i� z != r� )rs rt r r� r� r rY rK rL �stat�st_moderM �octr r~ )r r� �namer� Z
expected_moder r r �
test_umask
s$ �� � �z POSIXProcessTestCase.test_umaskc C sX t �� � t�tjddg�}|�� W d � n1 s w Y | �|j t j
� d S )Nr zimport os; os.abort()) r r� r r: rK rL r# rM r r� �SIGABRTr@ r r r �test_run_abort# s
�
�z#POSIXProcessTestCase.test_run_abortc C sN t �ttj� d�}t|�}| �d|�� � | �d|� | �ttj�|� d S )N�fake cmdr� ZSIG)r r\ r\ r� r� r� re �lower�r r� Z error_stringr r r �"test_CalledProcessError_str_signal+ s
z7POSIXProcessTestCase.test_CalledProcessError_str_signalc C �$ t �dd�}t|�}| �d|� d S )Ni�Ki�r� zunknown signal 9876543.�r r\ r� re r� r r r �*test_CalledProcessError_str_unknown_signal6 � z?POSIXProcessTestCase.test_CalledProcessError_str_unknown_signalc C r� )Nr! r� znon-zero exit status 2.r� r� r r r �$test_CalledProcessError_str_non_zero; r� z9POSIXProcessTestCase.test_CalledProcessError_str_non_zeroc C sZ t jtjddgt jdd� d�}|� | �|j�� d� W d � d S 1 s&w Y d S )Nr r/ c S s t �dd�S )Nr� �apple)r �putenvr r r r �<lambda>G � z3POSIXProcessTestCase.test_preexec.<locals>.<lambda>)r8 �
preexec_fn� appler r@ r r r � test_preexec@ s
��"�z!POSIXProcessTestCase.test_preexecc
C s� dd� }z
t jtjddg|d�}W n6 t jy, } z| �t jd� W Y d }~d S d }~w tyG } z| �d|j d � W Y d }~d S d }~ww | �
d � d S )
Nc S r. )Nz'What if two swallows carried a coconut?�r� r r r r �raise_itL r3 z=POSIXProcessTestCase.test_preexec_exception.<locals>.raise_itr r
�r� z)Expected a ValueError from the preexec_fnZcoconutr zEException raised by preexec_fn did not make it to the parent process.) r r: rK rL rQ rR �_posixsubprocessr� re r0 r� )r r� rA r� r r r �test_preexec_exceptionK s
��� ��z+POSIXProcessTestCase.test_preexec_exceptionc @ � e Zd ZdZdd� Zdd� ZdS )z+POSIXProcessTestCase._TestExecuteChildPopenz3Used to test behavior at the end of _execute_child.c O s$ || _ tjj| g|�R i |�� d S r )� _testcaser r: r� )r Ztestcaser0 r1 r r r r� ] s z4POSIXProcessTestCase._TestExecuteChildPopen.__init__c O s zJt jj| g|�R i |�� W dd� td�D �}z'|D ]}| jj|| j�� | j�� | j �� fdd� qW |D ]}t
� |� q6d S |D ]}t
� |� qBw dd� td�D �}z&|D ]}| jj|| j�� | j�� | j �� fdd� qWW |D ]}t
� |� qrw |D ]}t
� |� q}w )Nc S s g | ] }t �d t j��qS )� /dev/zero)r rw �O_RDONLY�r8 rO r r r r; h s �zNPOSIXProcessTestCase._TestExecuteChildPopen._execute_child.<locals>.<listcomp>� z!At least one fd was closed early.r� ) r r: r2 ru r� r� r7 r� r8 r9 r r? )r r0 r1 Z devzero_fdsr� r r r r2 a sH ���� � ������
� �z:POSIXProcessTestCase._TestExecuteChildPopen._execute_childN)r) r* r+ r4 r� r2 r r r r �_TestExecuteChildPopen[ s r� r� z/dev/zero required.c C sV dd� }| � tj�� | j| ttjtjtj|d� W d � dS 1 s$w Y dS )z6Issue16140: Don't double close pipes on preexec error.c S s
t �d��)Nz-force the _execute_child() errpipe_data path.)r rQ r r r r r� x s �zWPOSIXProcessTestCase.test_preexec_errpipe_does_not_double_close_pipes.<locals>.raise_it)r7 r8 r9 r� N)rU r rQ r� r r; )r r� r r r �0test_preexec_errpipe_does_not_double_close_pipest s �"�zEPOSIXProcessTestCase.test_preexec_errpipe_does_not_double_close_pipesc C s� t �� }zKt �� | �t �� � tjtjddgdd� d� | �t �� d� t �� | � t �� � tjtjddgdd� d� | � t �� d� W |sNt �� d S d S |sWt �� w w ) Nr r
c S r� r r r r r r r� � � zEPOSIXProcessTestCase.test_preexec_gc_module_failure.<locals>.<lambda>r� z#Popen enabled gc when it shouldn't.c S r� r r r r r r r� � r� zPopen left gc disabled.)
�gc� isenabled�disabler% r rJ rK rL �enablerR )r Zenabledr r r � test_preexec_gc_module_failure� s* �
�� �
�z3POSIXProcessTestCase.test_preexec_gc_module_failurera z!setrlimit() seems to fail on OS Xc
C s� z ddl m}m}m} W n ty# } z | �|� W Y d }~nd }~ww ||�}|\}}||d|f� | �|||� ztjt j
ddgdd� d� W n
t yS Y d S w | �d� d S ) Nr )� getrlimit� setrlimit� RLIMIT_NPROCr r
c S r� r r r r r r r� � r� z@POSIXProcessTestCase.test_preexec_fork_failure.<locals>.<lambda>r� z.RLIMIT_NPROC had no effect; probably superuser) Zresourcer� r� r� r� r| ru r rJ rK rL �BlockingIOError)r r� r� r� r� ZlimitsrO Zhardr r r �test_preexec_fork_failure� s$ ��
� �z.POSIXProcessTestCase.test_preexec_fork_failurec C s� t �� \}}t|ddd��}|�dtj � |�dtj � W d � n1 s(w Y t� |d� t
� |�}|� � t�
|� | �|jd� d S �N�wrm )r� z#!%s
z(exec '%s' -c 'import sys; sys.exit(47)'
i� rH )rs r� rw rv r �
unix_shellrK rL r �chmodr r: r# r� rM r )r r� �fname�fobjrA r r r �test_args_string� s � �
z%POSIXProcessTestCase.test_args_stringc C s< | j ttjtjddgdd� | j ttjtjddgdd� d S )Nr rG rH �� startupinfo��
creationflags�rU r� r rJ rK rL r r r r r� � s
��
�
�z&POSIXProcessTestCase.test_invalid_argsc C sj t j�� }d|d< tjdgdtj|d�}|� | �|j�� � d�d� W d � d S 1 s.w Y d S �Nr� r� z echo $FRUITr� �r� r8 r� s
r� �
r r� r� r r: r; rM r8 r� r= �r r� rA r r r �test_shell_sequence� s
�"�z(POSIXProcessTestCase.test_shell_sequencec C sh t j�� }d|d< tjddtj|d�}|� | �|j�� � d�d� W d � d S 1 s-w Y d S r� r� r� r r r �test_shell_string� s
�"�z&POSIXProcessTestCase.test_shell_stringc C s� t �� \}}t|ddd��}|�dtj � |�dtj � W d � n1 s(w Y t� |d� t
� |�}t� |� | �
|d� d S r� )rs r� rw rv r r� rK rL r r� r rJ r� rM )r r� r� r� rO r r r �test_call_string� s � �
z%POSIXProcessTestCase.test_call_stringc C s� g }dD ]}dD ]}t j�||�}t j�|�r |�|� qq|s%| �d� d}t j�|�r8t j�|�s8|�|� |D ],}tjd|dtj d�}|� | �
|j � � �
� t|d�� W d � n1 saw Y q:d S ) N)z/binz /usr/bin/z/usr/local/bin)ZbashZkshz"bash or ksh required for this testz/bin/shzecho $0T)rL r� r8 r� )r r� r� �isfilerv r| �islinkr r: r; rM r8 r� r= r� )r Zshellsr� r� �shrA r r r �test_specific_shell� s,
��
� ���z(POSIXProcessTestCase.test_specific_shellc
G st t � t jt j�}ztjtjddgdtjtjtjd�}W t � t j|� nt � t j|� w |j� d� t
||�|� |S )Nr z�if 1:
import sys, time
sys.stdout.write('x\n')
sys.stdout.flush()
time.sleep(30)
T�rd r7 r8 r9 r� ) r� �SIGINT�default_int_handlerr r: rK rL r; r8 r� �getattr)r �methodr0 r� rA r r r �
_kill_process� s � z"POSIXProcessTestCase._kill_process)ZnetbsdZopenbsdz"Due to known OS bug (issue #16762)c G sR t jtjddgdt jt jt jd�}|j�d� t�d� t ||�|� |�
� d S )Nr z�if 1:
import sys, time
sys.stdout.write('x\n')
sys.stdout.flush()
Tr� r� ) r r: rK rL r; r8 r� r� r� r� r� )r r� r0 rA r r r �_kill_dead_process s �
z'POSIXProcessTestCase._kill_dead_processc C s: | � dtj�}|�� \}}| �d|� | �|�� d� d S )N� send_signals KeyboardInterruptr )r� r� r� r� re rW r# �r rA rO r9 r r r �test_send_signal+ s z%POSIXProcessTestCase.test_send_signalc C �: | � d�}|�� \}}| �|d� | �|�� tj � d S )Nr) r )r� r� rM r# r� �SIGKILLr� r r r � test_kill1 �
z POSIXProcessTestCase.test_killc C r� )N� terminater )r� r� rM r# r� �SIGTERMr� r r r �test_terminate7 r� z#POSIXProcessTestCase.test_terminatec C � | � dtj� d S �Nr� )r� r� r� r r r r �test_send_signal_dead= s z*POSIXProcessTestCase.test_send_signal_deadc C � | � d� d S �Nr) �r� r r r r �test_kill_deadA � z#POSIXProcessTestCase.test_kill_deadc C r� �Nr� r� r r r r �test_terminate_deadE r� z(POSIXProcessTestCase.test_terminate_deadc C s6 g }|D ]}t �|�}t �|�}|�|||f� q|S r )r �get_inheritable�duprv )r Zsave_fdsr� r� � inheritable�savedr r r � _save_fdsI s
z POSIXProcessTestCase._save_fdsc C s. |D ]\}}}t j|||d� t �|� qd S )N)r� )r �dup2r? )r r� r� r� r� r r r � _restore_fdsQ s �z!POSIXProcessTestCase._restore_fdsc C s� d}| � |�}|D ]
\}}}|dkr|} nq z1|D ]}t�|� qtjtjddg|tjtjd��� \}}| � |d� | � |d� W | �
|� d S | �
|� w )Nr r r r6 r� r� ) r� r r? r r: rK rL r; r� rM r� ) r r� r7 � saved_fdsr� r� r� r� r� r r r �check_close_std_fdsV s,
�
��� z(POSIXProcessTestCase.check_close_std_fdsc C � | � dg� d S rX �r� r r r r �test_close_fd_0o � z$POSIXProcessTestCase.test_close_fd_0c C r� �Nr� r� r r r r �test_close_fd_1r r� z$POSIXProcessTestCase.test_close_fd_1c C r� )Nr! r� r r r r �test_close_fd_2u r� z$POSIXProcessTestCase.test_close_fd_2c C � | � ddg� d S )Nr r� r� r r r r �test_close_fds_0_1x � z'POSIXProcessTestCase.test_close_fds_0_1c C r� )Nr r! r� r r r r �test_close_fds_0_2{ r� z'POSIXProcessTestCase.test_close_fds_0_2c C r� )Nr� r! r� r r r r �test_close_fds_1_2~ r� z'POSIXProcessTestCase.test_close_fds_1_2c C s | � g d�� d S )N)r r� r! r� r r r r �test_close_fds_0_1_2� s z)POSIXProcessTestCase.test_close_fds_0_1_2c
C s� t �d�}t �d�}z.t �d� t �d� t�tjddg��� W t �|d� t �|d� t �|� t �|� dS t �|d� t �|d� t �|� t �|� w )z=Issue #15798: Popen should work when stdio fds are available.r r� r z*print('AssertionError:0:CLOEXEC failure.')N) r r� r? r r: rK rL r# r� )r Z new_stdinZ
new_stdoutr r r �test_small_errpipe_write_fd� s$
�
�
z0POSIXProcessTestCase.test_small_errpipe_write_fdc
C sV dd� t d�D �}z�dd� |D �}|D ] \}}t�|� qt�|d d� t�|d dd� | �t d��}z-t|�D ]
\}}t�||� q:tj t
j dd g|d |d
|d d �}|� � W | �
|� n| �
|� w |D ] }t�|dd� qkt�|d
d �}t�|d d ��� } | �|d
� | �| d� W |D ]}t�|� q�d S |D ]}t�|� q�w )Nc S � g | ]}t �� �qS r �rs r� �r8 r� r r r r; � � z?POSIXProcessTestCase.test_remapping_std_fds.<locals>.<listcomp>r� c S � g | ]\}}|�qS r r �r8 r� r� r r r r; � r r� � STDINr r �Zimport sys; got = sys.stdin.read();sys.stdout.write("got %s"%got); sys.stderr.write("err")r! r6 r � got STDIN� err)ru r �unlinkrv r� r� � enumerater� r r: rK rL r# r� r� r= rM r? )
r �temps�temp_fdsr� r� r� �temp_fdrA r� r� r r r �test_remapping_std_fds� s>
��
� �z+POSIXProcessTestCase.test_remapping_std_fdsc
C s: dd� t d�D �}dd� |D �}z�|D ] \}}t�|� q| �t d��}zNt|�D ]
\}} t�| |� q)t�|d� t�|dd� tj t
j ddg|||d �}
|
� � |D ] }t�|dd� qTt�
|d
�} t�
|d
��� } W | �|� n| �|� w | �| d � | �| d � W |D ]}t�|� q�d S |D ]}t�|� q�w )
Nc S r r r r r r r r; � r z7POSIXProcessTestCase.check_swap_fds.<locals>.<listcomp>r� c S r r r r r r r r; � r r
r r r r6 r r r
)ru r r r� r r� rv r� r r: rK rL r# r� r= r� rM r? )
r Zstdin_noZ stdout_noZ stderr_nor r r� r� r� r rA r� r� r r r �check_swap_fds� s>
�� � �z#POSIXProcessTestCase.check_swap_fdsc C sX | � ddd� | � ddd� | � ddd� | � ddd� | � ddd� | � ddd� d S )Nr r� r! )r r r r r �
test_swap_fds� s z"POSIXProcessTestCase.test_swap_fdsc C s� | � td��}z�|D ] }t�� �}t�|�� |� W d � n1 s#w Y q
ttd��t|� �� }t� |� g d�}i }t
||�D ]
\}} |||| < qEt � d�}
ttd��t|� �� } t
jtjd|
t| �gfi |��} | �| d� t
||�D ]9\}} t�|dtj� t�|d�}
ttt|
�d���}t � d|� d |� d
|� d |� d | � d
� �}| �| g||� q|W | �|� d S | �|� w )Nr� r6 z�
import os, sys
skipped_fd = int(sys.argv[1])
for fd in range(3):
if fd != skipped_fd:
os.write(fd, str(fd).encode('ascii'))
r r r r� z"
When testing z to z4 redirection,
parent descriptor z5 got redirected
to descriptor(s) z instead of descriptor z.
)r� ru rs rt r r� r� r� r} r? �zipre rf r rJ rK rL r� rM r� �SEEK_SETr� r> �mapr\ r� r� )r �from_fds�to_fdsr� Zfrom_fd�fZ fd_to_closeZ arg_namesr1 Zto_fdr� Z
skipped_fdrO �
read_bytesZread_fdsr� r r r �#_check_swap_std_fds_with_one_closed
sJ
��
� ����
�� z8POSIXProcessTestCase._check_swap_std_fds_with_one_closedc C s< t �td�d�D ]}t �td�d�D ]}| �||� qqd S )Nr� r! )� itertools� combinationsru � permutationsr )r r r r r r �!test_swap_std_fds_with_one_closed,
s
��z6POSIXProcessTestCase.test_swap_std_fds_with_one_closedc
C s� dd� }z t jt|d� W nB ty. } z| �t j� | �t|�d� W Y d }~d S d }~w t jyO } z| � t j� | �t|�d� W Y d }~d S d }~ww | �
d� d S )Nc S r. )N�
surrogate:�r� r r r r �prepare2
r3 zCPOSIXProcessTestCase.test_surrogates_error_message.<locals>.preparer� r" z!Exception occurred in preexec_fn.z1Expected ValueError or subprocess.SubprocessError) r rJ r r� r� r� rM r� rQ �assertIsNotNoner� )r r# r� r r r � test_surrogates_error_message1
s
� � ��z2POSIXProcessTestCase.test_surrogates_error_messagec C s� dD ]j\}}|� dd�}dt|� }tj�� }|||< d|d< |}tjtjd|g|d�}|� d �}| �
|� d�t |�� |� dd�}d
t|� }tj�� }|||< tjtjd|g|d�}|� d �}| �
|� d�t |�� qd S ) N))�testu abc�)u test�Z42r� rm z&import os; print(ascii(os.getenv(%s)))�C�LC_ALLr r� s
z'import os; print(ascii(os.getenvb(%s))))
rL r� r r� r� r rd rK rL r� rM r� r� )r �key�valueZ
encoded_value�scriptr� Z
decoded_valuer8 r r r �test_undecodable_envD
s0
�
�
�z)POSIXProcessTestCase.test_undecodable_envc C s� t �td �}ttdd � �}t j�td �\}}t �|�}t�|g| �}| �|d� d|d� |��
d�f }tj|dd�}| �|d� t j � � }||d< tj|g| |d �}| �|d� t j
� � }t �|�|d
< tj|g| |d �}| �|d� d S ) Nr r� s '%s' %s� r� Tr� �PATHr� s PATH)r r� r r> r� r� r rJ rM r� rL r� r� �environb) r Z abs_programr0 r� Zprogram�exitcoderA r� Zenvbr r r �test_bytes_programa
s"
z'POSIXProcessTestCase.test_bytes_programc C s� t jddd�}t jddd�}tjtj|gtjtjtjdd�}| �|jd� tjtj|gtjdd�}|�� \}}t t
t |� d ���}t |j
�� |j�� |j�� g�}| �||@ d
|||@ f � d S ) Nzinput_reader.py�subprocessdata�Zsubdir� fd_status.pyF)r7 r8 r9 rd r �r8 rd � ,z5Expected no fds from %r to be open in child, found %r)r �findfiler r: rK rL r; ru r� r� r r\ r� r7 r� r8 r9 r% ) r Zsleeper� fd_status�p1�p2rg �errorZ
result_fdsZ unwanted_fdsr r r �test_pipe_cloexec|
s( � � �
��z&POSIXProcessTestCase.test_pipe_cloexecc
s t jddd�}t jddd�}d}|d d }tjtj|gtjtjdd �� tjtj||g� jtjdd ��| �� j � | ��j � � fd
d �}�fd d
�}| �|� | �|� � j
� |� � j
� � t
�
�jgg g d�\}}} | �|d� | ��j�� |� � j� � �j� � d S )Nzqcat.pyr2 r3 zqgrep.pys zxcvbn� �
F)r7 r8 rd c �$ z� � � W d S ty Y d S w r �r� �ProcessLookupErrorr )r9 r r �kill_p1�
�
�zBPOSIXProcessTestCase.test_pipe_cloexec_real_tools.<locals>.kill_p1c r? r r@ r )r: r r �kill_p2�
rC zBPOSIXProcessTestCase.test_pipe_cloexec_real_tools.<locals>.kill_p2rr zThe child hung)r r7 r r: rK rL r; r8 ru r# r7 rv r? �selectrR rM r� )
r ZqcatZqgrepZsubdatar� rB rD Z readfilesZignored1Zignored2r )r9 r: r � test_pipe_cloexec_real_tools�
s2 ��
z1POSIXProcessTestCase.test_pipe_cloexec_real_toolsc
s� t jddd�}t�� }| �tj|d � | �tj|d � t|�� td�D ]}t�tj tj
�}| �tj|� � � |� q%� D ]}t� |d� q>t
jtj|gt
jdd �}|�� \}}ttt|�d
���}| �|� @ � d � t
jtj|gt
jdd �}|�� \}}ttt|�d
���}| �|� @ d � | �d|d
� t� fdd�td�D ��} t
jtj|gt
jd| d�}|�� \}}ttt|�d
���}| �|| � @ d� | �d|d
� d S )Nr4 r2 r3 r r� � TFr5 r6 zSome fds were closedzSome fds were left openzSubprocess failedc 3 s � | ]}� � � V qd S r )r} r� �r� r r � <genexpr>�
s � z6POSIXProcessTestCase.test_close_fds.<locals>.<genexpr>r� �r8 rd �pass_fdsz'Some fds not in pass_fds were left open)r r7 r r% ru r? r� ru rw �devnullr� �add�set_inheritabler r: rK rL r; r� r r\ r� rM r% re )
r r8 r� rO r� rA rg �ignored�
remaining_fds� fds_to_keepr rH r �test_close_fds�
sN � � �
� � �z#POSIXProcessTestCase.test_close_fdsZfreebsdz/devz/dev/fdz/Requires fdescfs mounted on /dev/fd on FreeBSD.c C s� t jddd�}tjtjdt�d| �gtjd�}|� � \}}|�
� }| j t |�dd| d � t
tt|d
�� �d ���}t
tt|d �� �d ���}| j||@ d
d � dS )z;Confirm that issue21618 is fixed (may fail under valgrind).r4 r2 r3 r aK
import os, resource, subprocess, sys, textwrap
open_fds = set()
# Add a bunch more fds to pass down.
for _ in range(40):
fd = os.open(os.devnull, os.O_RDONLY)
open_fds.add(fd)
# Leave a two pairs of low ones available for use by the
# internal child error pipe and the stdout pipe.
# We also leave 10 more open as some Python buildbots run into
# "too many open files" errors during the test if we do not.
for fd in sorted(open_fds)[:14]:
os.close(fd)
open_fds.remove(fd)
for fd in open_fds:
#self.addCleanup(os.close, fd)
os.set_inheritable(fd, True)
max_fd_open = max(open_fds)
# Communicate the open_fds to the parent unittest.TestCase process.
print(','.join(map(str, sorted(open_fds))))
sys.stdout.flush()
rlim_cur, rlim_max = resource.getrlimit(resource.RLIMIT_NOFILE)
try:
# 29 is lower than the highest fds we are leaving open.
resource.setrlimit(resource.RLIMIT_NOFILE, (29, rlim_max))
# Launch a new Python interpreter with our low fd rlim_cur that
# inherits open fds above that limit. It then uses subprocess
# with close_fds=True to get a report of open fds in the child.
# An explicit list of fds to check is passed to fd_status.py as
# letting fd_status rely on its default logic would miss the
# fds above rlim_cur as it normally only checks up to that limit.
subprocess.Popen(
[sys.executable, '-c',
textwrap.dedent("""
import subprocess, sys
subprocess.Popen([sys.executable, %r] +
[str(x) for x in range({max_fd})],
close_fds=True).wait()
""".format(max_fd=max_fd_open+1))],
close_fds=False).wait()
finally:
resource.setrlimit(resource.RLIMIT_NOFILE, (rlim_cur, rlim_max))
r� r! z(expected exactly two lines of output:
%rr� r r6 r� zSome fds were left open.N)r r7 r r: rK rL re rf r; r� rV rM rN r� r r\ r= r� r% )r r8 rA rg Z
unused_stderrZ output_linesZ
opened_fdsrP r r r �%test_close_fds_when_max_fd_is_lowered�
s$
/��0� 2 �
�z:POSIXProcessTestCase.test_close_fds_when_max_fd_is_loweredrr ri c C s> t jddd�}t� }td�D ]-}t�� }| �tj|d � | �tj|d � t�|d d� t�|d d� |� |� q|D ]^}t
j t j
|gt
jd|fd�}|�� \}}ttt|�d ���} ||h }
| �|| d
� | �| |
@ d � | �t��} | �t
jtd |fd
�� W d � n1 s�w Y | �dt| j�� q>d S )Nr4 r2 r3 ri r r� TrJ r6 zfd to be passed not passedzfd to be closed passedF)rd rK zoverriding close_fds)r r7 r� ru r r% ru r? rN �updater r: rK rL r; r� r r\ r� re r% Z assertWarnsr� rJ r r� �warning) r r8 r� rY r� r� rA rg rO rP Z to_be_closed�contextr r r �
test_pass_fds? s: �
�
� ��z"POSIXProcessTestCase.test_pass_fdsc
C s� t jddd�}t�� \}}| �tj|� | �tj|� t�|d� t�|d� ||f}tj|g}|t t
t |��7 }t j
|t jd|d�}|�� \}}tt
t|�d���} | �| t|�d| � | �t�|�d� | �t�|�d� d S ) Nr4 r2 r3 TFrJ r6 z output=%a)r r7 r r% ru r? rN rK rL r> r r� r r: r; r� r� r\ r� rM r� )
r r+ r� Znon_inheritablerK r0 rA rg rO r� r r r �test_pass_fds_inheritablea s$
� z.POSIXProcessTestCase.test_pass_fds_inheritablec C s t jddd�}g }td�D ]}t�tjtj�}| �tj|� |� |� q
t�
� \}}| �tj|� | �tj|� |� d|� t j
tj|g|d |d |d d|d�� t�|d �}W d
� n1 scw Y d d � |�d
�D �}| �|h d�t|�B d|��� d
S )z7Regression test for https://bugs.python.org/issue32270.r4 r2 r3 r! r� r T)r7 r8 r9 rd rK r Nc S s h | ]}t |��qS r )r\ )r8 �numr r r � <setcomp>� r z@POSIXProcessTestCase.test_pass_fds_redirected.<locals>.<setcomp>r6 > r r� r! zoutput=)r r7 ru r rw rL �O_RDWRru r? rv r% �insertr r: rK rL r� r� rM � frozenset) r r8 rK rO r� Zstdout_rZstdout_wrg r� r r r �test_pass_fds_redirected s* � �$z-POSIXProcessTestCase.test_pass_fds_redirectedc C �L t �tjd��}tjt||d�}|�� W d � d S 1 s w Y d S )N�r+)r8 r7 �r= rw r rL r r: r r# �r ZinoutrA r r r �%test_stdout_stdin_are_single_inout_fd� � �
"�z:POSIXProcessTestCase.test_stdout_stdin_are_single_inout_fdc C r_ )Nr` r� ra rb r r r �&test_stdout_stderr_are_single_inout_fd� rd z;POSIXProcessTestCase.test_stdout_stderr_are_single_inout_fdc C r_ )Nr` )r9 r7 ra rb r r r �%test_stderr_stdin_are_single_inout_fd� rd z:POSIXProcessTestCase.test_stderr_stdin_are_single_inout_fdc C sR t jddd�}tjtj|gtjtjd�}|�� \}}| �d|j d|�
d� � d S )Nzsigchild_ignore.pyr2 r3 r� r z6sigchild_ignore.py exited non-zero with this error:
%sr� ) r r7 r r: rK rL r; r� rM r r� )r Zsigchild_ignorerA r8 r9 r r r � test_wait_when_sigchild_ignored� s � �
�z4POSIXProcessTestCase.test_wait_when_sigchild_ignoredc C s� t �d�}tjtjddgtjdd�}|j}| �|j � z | �
|� d�d� | � ||�
|gg g d�d � W |�� d S |�� w ) NrE r z$import sys;sys.stdout.write("apple")r )r8 rC r= s applg )r �
import_moduler r: rK rL r; r8 ru r? rM r� re rE r# )r rE rA r r r r �test_select_unbuffered� s
�� z+POSIXProcessTestCase.test_select_unbufferedc C s� t jtjddgt jt jd�}| �|jj� | �|jj� t |�}|j
}t � dt
f��
d }W d � n1 s7w Y trF| �t j� d S | �|dd� t jD �� d S )Nr z import sys, time;time.sleep(0.2)r� r
c S � g | ]}t |��qS r ��id�r8 �or r r r; � r zEPOSIXProcessTestCase.test_zombie_fast_process_del.<locals>.<listcomp>)r r: rK rL r; ru r8 r? r9 rl �pidr �check_warnings�ResourceWarningr! r� r" re )r rA �identro r r r � test_zombie_fast_process_del� s
�� � z1POSIXProcessTestCase.test_zombie_fast_process_delc C sb t jtjddgt jt jd�}| �|jj� | �|jj� t |�}|j
}t � dt
f�� d }t�� W d � n1 s;w Y t�|tj� trP| �t j� n | �|dd� t jD �� t�d� | �t��" t jt t jt jd��}W d � n1 s|w Y W d � n1 s�w Y | �ttj |d� tr�| �t j� d S | � |d d� t jD �� d S )
Nr zimport time;time.sleep(3)r� r
c S rj r rk rm r r r r; � r zJPOSIXProcessTestCase.test_leak_fast_process_del_killed.<locals>.<listcomp>r� r c S rj r rk rm r r r r; r ) r r: rK rL r; ru r8 r? r9 rl ro r rp rq r �
gc_collectr r) r� r� r! r� r" re r� r� rU rz r� �waitpidr� )r rA rr ro r� r r r �!test_leak_fast_process_del_killed� sB
��
�
� �� � z6POSIXProcessTestCase.test_leak_fast_process_del_killedc sx t jddd�}t�d�� | �tj� � tjtj |gtj
d� fdd�d�}|� � \}}t t
t|�d ���}| �� |� d S )
Nr4 r2 r3 r� Tc s t �d� �S r� )r r� r �r� r r r� r� zCPOSIXProcessTestCase.test_close_fds_after_preexec.<locals>.<lambda>)r8 rd r� r6 )r r7 r r� ru r? r r: rK rL r; r� r� r r\ r� r� )r r8 rA rg rO rP r rw r � test_close_fds_after_preexec
s
� z1POSIXProcessTestCase.test_close_fds_after_preexecc C s dd l }t�� }zpdd� }t�� ddgd dgfdgdd dgfdgdgddgfdgdgd dffD ]=\}}}}| �t��!}|�||dd ||d
d
d
d
d d d
ddddg dd
|� W d � n1 s_w Y | �dt|j �� q0W |swt�
� d S d S |s�t�
� w w )Nr c S r� r r r r r r r� % r� z5POSIXProcessTestCase.test_fork_exec.<locals>.<lambda>r� s exe� envs argTr r, r� r! r� r= Fz
takes exactly) r� r� r� r� rU r� rM r� r� r] r� ) r r� �
gc_enabled�funcr0 Zexe_listr� �env_listr� r r r �test_fork_exec s8 � � �� �
�z#POSIXProcessTestCase.test_fork_execc C s� dd l }G dd� d�}t�� }z_t�� ddddd|d �|d
�ffD ]A}| jtd �|�d ��$}|�d
gd
gd|d dgddddd d
ddddd d d dd � W d � n1 sUw Y | �dt |j
�� q"W |smt� � d S d S |svt� � w w )Nr c @ r� )zJPOSIXProcessTestCase.test_fork_exec_sorted_fd_sanity_check.<locals>.BadIntTc S s
|| _ d S r )r* )r r* r r r r� I s
zSPOSIXProcessTestCase.test_fork_exec_sorted_fd_sanity_check.<locals>.BadInt.__init__c S s | j r d| _ | jS t�)NF)�firstr* r� r r r r �__int__K s zRPOSIXProcessTestCase.test_fork_exec_sorted_fd_sanity_check.<locals>.BadInt.__int__N)r) r* r+ r~ r� r r r r r �BadIntG s r� )r, r! r� r= ri )r� r= )� � �* l )ri r= )r^ r� r� r� r� r! zfds_to_keep={}r� s falseTry r, r� r= rQ ) r� r� r� r� rU r� ro rM re r� r] r� )r r� r� rz rQ r_ r r r �%test_fork_exec_sorted_fd_sanity_checkC sD
��
� � � �
�z:POSIXProcessTestCase.test_fork_exec_sorted_fd_sanity_checkc C s� t �t�}|�5 tj�|d��}t|j_|� � |j�
� W d � n1 s'w Y W d � d S W d � d S 1 s?w Y d S )Nr7 ) r r: r r r� r� �BrokenPipeErrorr? rI r� Zassert_called_with�r r� �mock_proc_stdinr r r �,test_communicate_BrokenPipeError_stdin_closem s
P�zAPOSIXProcessTestCase.test_communicate_BrokenPipeError_stdin_closec C s� t �t�}|�< tj�|d�� }t|j_|� d� |j�
d� |j �
� W d � n1 s.w Y W d � d S W d � d S 1 sFw Y d S )Nr7 � stuff) r r: r r r� r� r� rv rI r� �assert_called_once_withr? r� r r r �,test_communicate_BrokenPipeError_stdin_writev s
P�zAPOSIXProcessTestCase.test_communicate_BrokenPipeError_stdin_writec
C s� t jtjdgt jt jd�}|�R tj�|d��2}tt j
d�� }t |j _
|�� |j_|�d� |j �� W d � n1 s=w Y W d � n1 sLw Y W d � d S W d � d S 1 sdw Y d S )N�-hr� r7 �wbr� )r r: rK rL r; r r� r� rw r rL r� r` rI r� � return_valuer� r� )r r� r� Zdev_nullr r r �,test_communicate_BrokenPipeError_stdin_flush� s �
�
��P zAPOSIXProcessTestCase.test_communicate_BrokenPipeError_stdin_flushc C s� t jtjdgt jt jd�}|�7 tj�|d��}t|j _
|j dd� |j � � W d � n1 s1w Y W d � d S W d � d S 1 sIw Y d S )Nr� r� r7 i� rS )
r r: rK rL r; r r� r� r� r? rI r� r� r� r r r �9test_communicate_BrokenPipeError_stdin_close_with_timeout� s � P�zNPOSIXProcessTestCase.test_communicate_BrokenPipeError_stdin_close_with_timeoutN�
W_STOPCODEzneed _testcapi.W_STOPCODEc C st t }t�|�}tj|jdd� t�d�}tj d|j|fd�� |�
� }W d � n1 s-w Y | � |d� dS )zATest wait() behavior when waitpid returns WIFSTOPPED; issue29335.r �r0 r� rG )r� N���) r r r: r � wait_processro � _testcapir� r r� r# rM )r r0 r� �statusr r r r � test_stopped� s
�z!POSIXProcessTestCase.test_stoppedc C st t �t�}tj|jdd� | �|j� t� d��}|�
t j � W d � n1 s)w Y |�
� | �|j� d S )Nr r� zos.kill)r r: r r r� ro r� r r r� r� r� r� Zassert_not_calledr$ )r r� Z mock_killr r r �test_send_signal_race� s
�z*POSIXProcessTestCase.test_send_signal_racec C st t �tjddg�}|js|�� |jr tjj|ddd� d�� d |_|� t
j � W d � d S 1 s3w Y d S )Nr zexit(1)r� c S r� r r r r r r r� � r� z=POSIXProcessTestCase.test_send_signal_race2.<locals>.<lambda>)�new) r r: rK rL r r� r r� r� r� r� r� r@ r r r �test_send_signal_race2� s �"�z+POSIXProcessTestCase.test_send_signal_race2c C sD t jtjddgt jd�} z |jdd� W d S t jy Y nw q
)Nr z+import os, time; os.close(1), time.sleep(2)r� TrR rS )r r: rK rL r; r� rV �r r� r r r �1test_communicate_repeated_call_after_stdout_close� s
�� ��zFPOSIXProcessTestCase.test_communicate_repeated_call_after_stdout_close)nr) r* r+ r r7 r= r? r@ r r: rB r r� rN rR r' r� r r� r� rX r] r� r� rp rt r} r~ r� r� r! r� r� r� r� r� r� r� r� r� r� rK r� r� r� r� r� r� r� r� r� r5 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, r1 r< rF rR r� �st_devrS r Zrequires_mac_verrW rX r^ rc re rf rg ri rs rv rx � cpython_onlyr} r� r� r� r� r� r� r� r� r� r� �
__classcell__r r r4 r r1 � s�
�
3
)
0
�
�
�
-0, )0�
P
! +
'
)
�
r1 zWindows specific testsc @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zej d d � �Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-S ).�Win32ProcessTestCasec C s. d}d}t �� }||_||_t jt|d� d S )Nr� r� r� )r � STARTUPINFO�dwFlags� wShowWindowrJ r )r �STARTF_USESHOWWINDOW� SW_MAXIMIZEr� r r r �test_startupinfo� s
�z%Win32ProcessTestCase.test_startupinfoc C s( d}d}t j||d�}t jt|d� d S )Nr� r� )r� r� r� )r r� rJ r )r ZSTARTF_USERSHOWWINDOWr� r� r r r �test_startupinfo_keywords� s �
�z.Win32ProcessTestCase.test_startupinfo_keywordsc
C s� t �� }t j|_t j|_td�D ]l}t}tt j
d��/}t j ||t j |d�}|� |�
� W d � n1 s6w Y | �|jd� W d � n1 sLw Y | �|jt j� | �|j� | �|j� | �|j� | �|jt j� | �|jdg i� qd S )Nr! r� )r8 r9 r� r � handle_list)r r� r� r� ZSW_HIDEr� ru r rw r rL r: rm r� rM r r� Z hStdInputZ
hStdOutputZ hStdError�lpAttributeList)r r� rO rA Znullr� r r r �test_startupinfo_copy� s2 �
� � � �z*Win32ProcessTestCase.test_startupinfo_copyc C s( d}t j�d� tjt jd |d� d S )N� z' a DOS box should flash briefly ...
z# -c "import time; time.sleep(0.25)"r� )rK r9 rv r rJ rL )r ZCREATE_NEW_CONSOLEr r r �test_creationflags
s �
�z'Win32ProcessTestCase.test_creationflagsc C s$ | j ttjtjddgdd� d� d S )Nr rG c S s dS r� r r r r r r� %
r� z8Win32ProcessTestCase.test_invalid_args.<locals>.<lambda>r� r� r r r r r�
s
�
�z&Win32ProcessTestCase.test_invalid_argsc C sP G dd� dt �}| �t�� tjt|� d� W d � d S 1 s!w Y d S )Nc @ s e Zd ZdZdS )z4Win32ProcessTestCase.test_issue31471.<locals>.BadEnvN)r) r* r+ �keysr r r r �BadEnv+
s r� r� )�dictrU r� r r: r )r r� r r r �test_issue31471'
s "�z$Win32ProcessTestCase.test_issue31471c C s& t jtjddgdd�}| �|d� d S )Nr rG T)rd rH rI rN r r r rR 0
s
��z#Win32ProcessTestCase.test_close_fdsc
C s� dd l }t�� }| �tj|d � | �tj|d � g }|D ]}t�|d� |�|�|�� q tj t
j dd� |d �gtj
dd�}|�� \}}| �|jd� t|�� � tj t
j dd� |d �gtj
tj
dd�}|�� \}}| �|jd� | �d |� g }t�� } d
|i| _tj t
j dd� |d �gtj
tj
| dd �}|�� \}}| �|jd� | �d |� t�d tf��8 t�� } d
|d d � i| _tj t
j dd� |d �gtj
tj
| dd �}|�� \}}| �|jd� W d � d S 1 s�w Y d S )
Nr r� Tr z2import msvcrt; print(msvcrt.open_osfhandle({}, 0))Fr5 )r8 r9 rd s OSErrorr� )r8 r9 r� rd z.*overriding close_fds)r� r r% ru r? rN rv Z
get_osfhandler r: rK rL ro r; r� rM r r\ r= re r� r� r rp r� )
r r� r� r r� rA r8 r9 r� r� r r r �test_close_fds_with_stdio7
sd
��
�
�
�� �
�� "�z.Win32ProcessTestCase.test_close_fds_with_stdioc C s t �� }i |_t jt|d� d S )Nr� �r r� r� rJ r �r r� r r r �test_empty_attribute_listi
s
�z.Win32ProcessTestCase.test_empty_attribute_listc C s$ t �� }dg i|_t jt|d� d S )Nr� r� r� r� r r r �test_empty_handle_listo
s
�z+Win32ProcessTestCase.test_empty_handle_listc C sd t j�� }d|d< tjdgdtj|d�}|� | �d|j�� � W d � d S 1 s+w Y d S �N�physalisr� r� r� r� s physalis� r r� r� r r: r; re r8 r� r� r r r r� u
s
�"�z(Win32ProcessTestCase.test_shell_sequencec C sb t j�� }d|d< tjddtj|d�}|� | �d|j�� � W d � d S 1 s*w Y d S r� r� r� r r r r�
s
�"�z&Win32ProcessTestCase.test_shell_stringc C sn dD ]2}t j�� }d|d< tjddtj||d�}|� | �d|j�� |� W d � n1 s/w Y qd S )N)�ansiZoemr� r� r� r� )r� r8 r� r� r� )r �encr� rA r r r �test_shell_encodings�
s
� ���z)Win32ProcessTestCase.test_shell_encodingsc C s t �tjd �}| �|d� d S )Nz -c "import sys; sys.exit(47)"rH rI rN r r r r� �
s �z%Win32ProcessTestCase.test_call_stringc G s� t jtjddgt jt jt jd�}|�% |j�d� t||�|� |�� \}}| � |d� |�
� }W d � n1 s:w Y | � |d� d S )Nr z�if 1:
import sys, time
sys.stdout.write('x\n')
sys.stdout.flush()
time.sleep(30)
r6 r� r r ) r r: rK rL r; r8 r� r� r� rM r# rW )r r� r0 rA rO r9 r r r r r� �
s �
�z"Win32ProcessTestCase._kill_processc G s� t jtjddgt jt jt jd�}|�* |j�d� t�d� t ||�|� |�
� \}}| � |d� |� � }W d � n1 s?w Y | � |d� d S )Nr z�if 1:
import sys, time
sys.stdout.write('x\n')
sys.stdout.flush()
sys.exit(42)
r6 r� r r� )
r r: rK rL r; r8 r� r� r� r� r� rM r# )r r� r0 rA rO r9 rO r r r r� �
s �
� z'Win32ProcessTestCase._kill_dead_processc C r� r� )r� r� r� r r r r r� �
r� z%Win32ProcessTestCase.test_send_signalc C r� r� �r� r r r r r� �
� z Win32ProcessTestCase.test_killc C r� r� r� r r r r r� �
r� z#Win32ProcessTestCase.test_terminatec C r� r� )r� r� r� r r r r r� �
r� z*Win32ProcessTestCase.test_send_signal_deadc C r� r� r� r r r r r� �
r� z#Win32ProcessTestCase.test_kill_deadc C r� r� r� r r r r r� �
r� z(Win32ProcessTestCase.test_terminate_deadN)r) r* r+ r� r� r� r� r� r r� r� rR r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� � s0
2
r� c @ s^ e Zd ZG dd� dej�Zej�ejd�dd� �Z dd� Z
dd � Z d
d � Z d d
� Z
dd� ZdS )� MiscTestsc s$ e Zd ZdZg Z� fdd�Z� ZS )zMiscTests.RecordingPopenz<A Popen that saves a reference to each instance for testing.c s" t � j|i |�� | j�| � d S r )r2 r� �instances_createdrv r/ r4 r r r� �
s z!MiscTests.RecordingPopen.__init__)r) r* r+ r4 r� r� r� r r r4 r �RecordingPopen�
s r� � _communicatec
K s� t |_z�tj�tjd���}t |_tj�td| j��, | �t �� |t j
ddgfdtj i|�� W d � n1 s9w Y W d � n1 sHw Y |j dd� D ]}| �
|tjdd�d |j � �� qTg }|j D ]}|tjd
d�krz|�|� qk| j|jd |j d � | jt|�d|j d � W d � n!1 s�w Y W | jj�� }|�� |�� | �g | jj� dS W | jj�� }|�� |�� | �g | jj� dS | jj�� }|�� |�� | �g | jj� w )
a� Fake a SIGINT happening during Popen._communicate() and ._wait().
This avoids the need to actually try and get test environments to send
and receive signals reliably across platforms. The net effect of a ^C
happening during a blocking subprocess execution which we want to clean
up from is a KeyboardInterrupt coming out of communicate() or wait().
�_waitr: r zLimport time
time.sleep(9)
import sys
sys.stderr.write('\n!runaway child!\n')r8 Nr� rS z.no open-ended wait() after the first allowed: g �?r! r� )�KeyboardInterruptrI r r� r� r r: r� rU rK rL r Zcall_args_listrW rJ rv ZassertLessEqualZ
call_countrM rN r� r} r) r# )r ZpopenerZmock__communicater1 Z
mock__waitrJ Z sigint_callsr� r r r � _test_keyboardinterrupt_no_kill�
sd
� ��� �� � ��
�
� � � � �z)MiscTests._test_keyboardinterrupt_no_killc C � | j tjdd� d S �NgT㥛� @rS )r� r rJ r r r r �#test_call_keyboardinterrupt_no_kill � z-MiscTests.test_call_keyboardinterrupt_no_killc C r� r� )r� r r r r r r �"test_run_keyboardinterrupt_no_kill r� z,MiscTests.test_run_keyboardinterrupt_no_killc C s dd� }| � |� d S )Nc _ s* t j| i |���}t�1 sw Y d S r )r r: r� )r0 r1 Zunused_processr r r �popen_via_context_manager s �z[MiscTests.test_context_manager_keyboardinterrupt_no_kill.<locals>.popen_via_context_manager)r� )r r� r r r �.test_context_manager_keyboardinterrupt_no_kill s z8MiscTests.test_context_manager_keyboardinterrupt_no_killc C s� | � t�d�d� | � t�d�d� d }z,t�� }tj�|d�}t�t r&dnd| �\}}| �
|d� W |d ur?t� |� d S d S |d urKt� |� w w )Nz
echo xyzzy�xyzzy)r r� r� ztype zcat r ) rM r � getoutput�getstatusoutputrs rt r r� r� r! rW �rmdir)r �dirr� r� rg r r r �test_getoutput s" �� � �zMiscTests.test_getoutputc C sn h d�}t tj�}t � }ddl}tj�� D ]\}}|�d�r qt||jf�r'q|� |� q| �
||| � dS )z*Ensure that __all__ is populated properly.> r� r& r+ rh �Handler NrO ) r� r �__all__r� �__dict__�itemsr5 rl �
ModuleTyperM rM )r Zintentionally_excludedZexportedZpossible_exportsr� r� r* r r r � test__all__. s
zMiscTests.test__all__N)r) r* r+ r r: r� r r� r� r� r� r� r� r� r� r r r r r� �
s
+ r� � PollSelectorz!Test needs selectors.PollSelectorc @ r )�ProcessTestCaseNoPollc C s t j| _tjt _t�| � d S r )r �_PopenSelector�
orig_selector� selectors�SelectSelectorr5 r r r r r r @ s zProcessTestCaseNoPoll.setUpc C s | j t_t�| � d S r )r� r r� r5 r' r r r r r' E s z ProcessTestCaseNoPoll.tearDownNr( r r r r r� = s r� zWindows-specific testsc sP e Zd Z� fdd�Z� fdd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z � Z
S )�CommandsWithSpacesc s> t � �� t�dd�\}}|�� | _t�|d� t�|� d S )Nz.pyzte stsV import sys;sys.stdout.write('%d %s' % (len(sys.argv), [a.lower () for a in sys.argv]))) r2 r rs r� r� r� r rv r? )r r r� r4 r r r M s
zCommandsWithSpaces.setUpc s t �| j� t� �� d S r )r r� r� r2 r' r r4 r r r' V s zCommandsWithSpaces.tearDownc O sb t j|d< t j|i |��}|� | �|j�� �d�d| j � W d � d S 1 s*w Y d S )Nr8 �mbcsz2 [%r, 'ab cd'])r r; r: rM r8 r� r� r� )r r0 r1 rA r r r � with_spacesZ s
�"�z CommandsWithSpaces.with_spacesc C s | j dtj| jdf dd� d S )N�"%s" "%s" "%s"�ab cdr� r� �r� rK rL r� r r r r � test_shell_string_with_spacesc s
�
�z0CommandsWithSpaces.test_shell_string_with_spacesc C s | j tj| jdgdd� d S )Nr� r� r� r� r r r r � test_shell_sequence_with_spacesh s z2CommandsWithSpaces.test_shell_sequence_with_spacesc C s | � dtj| jdf � d S )Nr� r� r� r r r r � test_noshell_string_with_spacesl s �z2CommandsWithSpaces.test_noshell_string_with_spacesc C s | � tj| jdg� d S )Nr� r� r r r r �!test_noshell_sequence_with_spacesq s z4CommandsWithSpaces.test_noshell_sequence_with_spaces) r) r* r+ r r' r� r� r� r� r� r� r r r4 r r� J s r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �ContextManagerTestsc C s� t jtjddgt jt jd��}| �|j�� d� | �|j�� d� W d � n1 s+w Y | � |jj
� | � |jj
� d S )Nr zAimport sys;sys.stdout.write('stdout');sys.stderr.write('stderr');r� s stdouts stderr) r r: rK rL r; rM r8 r� r9 rR rS r� r r r � test_pipex s
�� � z ContextManagerTests.test_pipec C sD t �tjddg��}W d � n1 sw Y | �|jd� d S )Nr zimport sys; sys.exit(100)�d )r r: rK rL rM r r� r r r r � s
� �z#ContextManagerTests.test_returncodec C sV t jtjddgt jd��}|�d� | �|jd� W d � d S 1 s$w Y d S )Nr z2import sys;sys.exit(sys.stdin.read() == 'context')rq s contextr� r r� r r r rD � s
��
"�z*ContextManagerTests.test_communicate_stdinc C st | � t��+ tjttjtjd��}W d � n1 sw Y W d � d S W d � d S 1 s3w Y d S )Nr� )rU r� r r: r� r; r� r r r r� � s � ��"�z%ContextManagerTests.test_invalid_argsc C sr t jtt jtjd d�}|�� }|j�dtj � | � |j
� | � t |j
ddd� | �|j
d� | �|jj� dS )z9Broken pipe error should not prevent wait() (Issue 21619)r! )r7 rC r� Nr )r r: r r; r rX � __enter__r7 rv r� r rU rz �__exit__rM rR rS r� r r r �test_broken_pipe_cleanup� s � z,ContextManagerTests.test_broken_pipe_cleanupN)r) r* r+ r� r rD r� r� r r r r r� v s
r� �__main__)Er' r r& r Z test.supportr r r r r rK r� r= r r r{ rs r� r! r� r� r� rE r r� r� re r� r� Ztest.support.os_helperr r� r� rh r+ r& ZPGOr( r� r! r_ r� r� �NotADirectoryErrorrk r� rL r r ZTestCaser � Exceptionr, r: r- r5 r r0 r� r1 r� r� r� r� r� r� r� r) �mainr r r r �<module> s� � � �
F
~ d�
+
6 �