| Server IP : 138.197.176.125 / Your IP : 216.73.217.54 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/test/__pycache__/ |
Upload File : |
U
��W[-} � @ s$ d Z ddlmZmZmZ ddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl m
Z
ddlmZ ddlmZmZ ddlmZ ddlmZmZ dd lmZmZmZm Z m Z dd
l m Z dd l m!Z!m"Z" dd l#m$Z$m%Z% dd
l&m'Z' ddl(m)Z)m*Z* eej+��,� Z-ee
j.��/� �/� Z0dZ1e�2� �rPdZ3dZ4dZ1e5ej6�Z7ej8�9ej:�e7d< nHddl3Z3ddl m4Z4 e�;� dk�rvdZ1e � Z7ej8�9ej:��<e�=� �e7d< dd� Z>G dd� de'�Z?G dd� de�Z@G dd� de@�ZAeB� �CeA�D� � G d d � d e@�ZEeB� �CeE�D� � G d d � d e
�ZFG d d!� d!e
�ZGdS )"z�
Tests for implementations of L{IReactorProcess}.
@var properEnv: A copy of L{os.environ} which has L{bytes} keys/values on POSIX
platforms and native L{str} keys/values on Windows.
� )�division�absolute_import�print_functionN)�TestCase)�ReactorBuilder)�msg�err)�platform)�FilePath�_asFilesystemBytes)�
networkString�range�items� bytesEnviron�unicode)�utils)�IReactorProcess�IProcessTransport)�Deferred�succeed)�ProcessProtocol)� ProcessDone�ProcessTerminatedz Cannot change UID/GID on Windows�
PYTHONPATH)�processz$Cannot change UID/GID except as roots
PYTHONPATHc C s t dkrd| _| S )z�
Only run this test on POSIX platforms.
@param testMethod: A test function, being decorated.
@return: the C{testMethod} argument.
Nz%Test only applies to POSIX platforms.)�resource�skip)Z
testMethod� r �D/usr/lib/python3/dist-packages/twisted/internet/test/test_process.py� onlyOnPOSIX; s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � _ShutdownCallbackProcessProtocolz�
An L{IProcessProtocol} which fires a Deferred when the process it is
associated with ends.
@ivar received: A C{dict} mapping file descriptors to lists of bytes
received from the child process on those file descriptors.
c C s || _ i | _d S �N)� whenFinished�received)�selfr" r r r �__init__Q s z)_ShutdownCallbackProcessProtocol.__init__c C s | j �|g ��|� d S r! )r# �
setdefault�append)r$ �fd�bytesr r r �childDataReceivedV s z2_ShutdownCallbackProcessProtocol.childDataReceivedc C s | j �d � d S r! )r" �callback�r$ �reasonr r r � processEndedZ s z-_ShutdownCallbackProcessProtocol.processEndedN)�__name__�
__module__� __qualname__�__doc__r% r* r. r r r r r I s r c @ s� e Zd ZdZegZdd� Zdd� Zdd� Zdd � Z d
d � Z
d d
� Z dd� Z e
edd�dkr`de _dd� Zdd� Zedd� �Zedd� �Zdd � Zd d � Zd d � Zedk r�ee_d!d"� Zedk r�ee_d#d$� ZdS )%�ProcessTestsBuilderBasez�
Base class for L{IReactorProcess} tests which defines some tests which
can be applied to PTY or non-PTY uses of C{spawnProcess}.
Subclasses are expected to set the C{usePTY} attribute to C{True} or
C{False}.
c s` t � }t|�}| �� � � j|ttddg| jd�}| �t�|�� |� � fdd�� | �
� � dS )z�
L{IReactorProcess.spawnProcess} connects the protocol passed to it
to a transport which provides L{IProcessTransport}.
� -c� ��usePTYc s � � � S r! ��stop�Zignored��reactorr r �<lambda>� r5 zHProcessTestsBuilderBase.test_processTransportInterface.<locals>.<lambda>N) r r � buildReactor� spawnProcess�pyExer7 �
assertTruer Z
providedBy� addCallback�
runReactor)r$ �ended�protocol� transportr r; r � test_processTransportInterfacej s � z6ProcessTestsBuilderBase.test_processTransportInterfacec s~ | � � �t� }t|��dttj� � d�� ����fdd�}��|� |��fdd�� | ��� | � � d�
�j d �� d S )
a�
Helper for testing L{IProcessTransport} write functionality. This
method spawns a child process and gives C{write} a chance to write some
bytes to it. It then verifies that the bytes were actually written to
it (by relying on the child process to echo them back).
@param write: A two-argument callable. This is invoked with a process
transport and some bytes to write to it.
s hello, worlds2 import sys
sys.stdout.write(sys.stdin.readline())
c sH �� �ttd�g�} z�| � � W n td d� | �d� Y nX d S )Nr4 z!Unhandled exception while writingZKILL)r? r@ r �
signalProcess�rF �� bytesToSend�programrE r< �writer r �startup� s �
z3ProcessTestsBuilderBase._writeTest.<locals>.startupc s � � � S r! r8 r: r; r r r= � r5 z4ProcessTestsBuilderBase._writeTest.<locals>.<lambda>r5 � N) r> r r r �os�linesep�callWhenRunningrB rC � assertEqual�joinr# )r$ rM rD rN r rJ r �
_writeTest� s
�
z"ProcessTestsBuilderBase._writeTestc C s dd� }| � |� dS )z~
L{IProcessTransport.write} writes the specified C{bytes} to the standard
input of the child process.
c S s | � |� d S r! �rM �rF rK r r r rM � s z1ProcessTestsBuilderBase.test_write.<locals>.writeN�rU �r$ rM r r r �
test_write� s z"ProcessTestsBuilderBase.test_writec C s dd� }| � |� dS )z�
L{IProcessTransport.writeSequence} writes the specified C{list} of
C{bytes} to the standard input of the child process.
c S s | � |g� d S r! )Z
writeSequencerW r r r rM � s z9ProcessTestsBuilderBase.test_writeSequence.<locals>.writeNrX rY r r r �test_writeSequence� s z*ProcessTestsBuilderBase.test_writeSequencec C s dd� }| � |� dS )z�
L{IProcessTransport.writeToChild} writes the specified C{bytes} to the
specified file descriptor of the child process.
c S s | � d|� d S )Nr )� writeToChildrW r r r rM � s z8ProcessTestsBuilderBase.test_writeToChild.<locals>.writeNrX rY r r r �test_writeToChild� s z)ProcessTestsBuilderBase.test_writeToChildc s � fdd�}� � |� dS )z�
L{IProcessTransport.writeToChild} raises L{KeyError} if passed a file
descriptor which is was not set up by L{IReactorProcess.spawnProcess}.
c s( z� �t| jd|� W 5 | � |� X d S )N�
)rM � assertRaises�KeyErrorr\ rW �r$ r r rM � s zIProcessTestsBuilderBase.test_writeToChildBadFileDescriptor.<locals>.writeNrX rY r ra r �"test_writeToChildBadFileDescriptor� s z:ProcessTestsBuilderBase.test_writeToChildBadFileDescriptorc s� | � � � | jrd}ni }t�� ��fdd�}t�tj|� t� }� jt|�t t ddg| j|d� ��
d� �� � s|| � d� g }|�
|j� |r�dS |�
� fd d
�� | �� � | �|� dS ) z�
If, before the reactor is started with L{IReactorCore.run}, a
process is started with L{IReactorProcess.spawnProcess} and
terminates, the process is reaped once the reactor is started.
Nc s � � � d S r! )�set)�args)�signaledr r �handler� s zGProcessTestsBuilderBase.test_spawnProcessEarlyIsReaped.<locals>.handlerr4 r5 )r7 �childFDs�x z,Timed out waiting for child process to exit.c s � � � S r! r8 r: r; r r r= r5 zHProcessTestsBuilderBase.test_spawnProcessEarlyIsReaped.<locals>.<lambda>)r> r7 � threadingZEvent�signal�SIGCHLDr r? r r@ �waitZisSet�failrB r' rC rA )r$ rg rf rD �resultr )r< re r � test_spawnProcessEarlyIsReaped� s2 �
z6ProcessTestsBuilderBase.test_spawnProcessEarlyIsReapedrk Nz;Platform lacks SIGCHLD, early-spawnProcess test can't work.c s� d�t td� ��t� � d}G � �fdd�dt�}��� ��j�j|� ttd|g�jd� ��fdd �}� � |� � �
t � � � �fd
d �� �� �� d S )
z�
The C{reason} argument passed to L{IProcessProtocol.processExited} is a
L{ProcessTerminated} instance if the child process exits with a signal.
ZTERMZSIGsE import sys
sys.stdout.write('x')
sys.stdout.flush()
sys.stdin.read()
c s4 e Zd Z�fdd�Zdd� Z� fdd�Zdd� Zd S )
zDProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiterc s t d||f � | j�� � d S �NzchildDataReceived(%d, %r))r rF rH �r$ r( �data)�sigNamer r r* % s zVProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.childDataReceivedc S s t d|f � d S �N�childConnectionLost(%d)�r )r$ r( r r r �childConnectionLost) s zXProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.childConnectionLostc s t d|f � � �|g� d S �NzprocessExited(%r)�r r+ r, ��exitedr r �
processExited, s zRProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.processExitedc S s t d|f � d S �NzprocessEnded(%r)rv r, r r r r. 5 s zQProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.processEndedN�r/ r0 r1 r* rw r| r. r )r{ rs r r �Exiter$ s r r4 r6 c sX | \}|� t� |j}t�� r:� �|j� � �|jd� n� �|j�� � �|j� d S )NrO ) �trapr �valuer � isWindowsZ assertIsNonerj rS �exitCode)rd �failurer )r$ �sigNumr r �cbExited= s
zFProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.cbExitedc s � � � S r! r8 �Zignr; r r r= R r5 zFProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.<lambda>N)
�getattrrj r r r> rR r? r@ r7 rB �
addErrbackr rC )r$ �sourcer r� r )r{ r< r$ rs r� r � test_processExitedWithSignal s& � �
z4ProcessTestsBuilderBase.test_processExitedWithSignalc sL | � � � g �� �fdd�}� �|� | �� � | ��dtj�d� g� dS )a�
If a child process exits while a system call is in progress, the system
call should not be interfered with. In particular, it should not fail
with EINTR.
Older versions of Twisted installed a SIGCHLD handler on POSIX without
using the feature exposed by the SA_RESTART flag to sigaction(2). The
most noticeable problem this caused was for blocking reads and writes to
sometimes fail with EINTR.
c sj zZt�t�� �} t�| ddg� tj| ddgtjd�}|j� �� |j�
� � W 5 Q R X W 5 � � � X d S )N�-cz import time; time.sleep(0.1)z)import time; time.sleep(0.5);print('Foo'))�stdout) r9 r@ �decode�sys�getfilesystemencoding�
subprocess�Popen�PIPEr� r' �read)�exe�f2�r< rn r r �fe s �� zJProcessTestsBuilderBase.test_systemCallUninterruptedByChildExit.<locals>.fs Foo�asciiN)r> rR rC rS rP rQ �encode)r$ r� r r� r �'test_systemCallUninterruptedByChildExitW s
z?ProcessTestsBuilderBase.test_systemCallUninterruptedByChildExitc s� t d�tj��}t�� \}}| �tj|� | �tj|� d}t� tj
�d | }t� ||� | �tj|� t �
� � G � �fdd�dt�}| �� ��j�j|� ttdd|g| jd� | ��� tt� �� ��}dd d
g}| �|�t||g ��t|�� d S ) z�
Processes spawned with spawnProcess() close all extraneous file
descriptors in the parent. They do have a stdin, stdout, and stderr
open.
z�
import sys
sys.path.insert(0, '{0}')
from twisted.internet import process
sys.stdout.write(repr(process._listOpenFDs()))
sys.stdout.flush()� r c s e Zd Z� jZ�fdd�ZdS )zKProcessTestsBuilderBase.test_openFileDescriptors.<locals>.GatheringProtocolc s � � � d S r! r8 r, r; r r r. � s zXProcessTestsBuilderBase.test_openFileDescriptors.<locals>.GatheringProtocol.processEndedN)r/ r0 r1 rM Z outReceivedr. r ��outputr< r r �GatheringProtocol� s r� s -Wignorer4 r6 rO � N)r �format� twistedRoot�pathrP �pipeZ
addCleanup�closer Z getrlimitZ
RLIMIT_NOFILE�dup2�io�BytesIOr r> rR r? r@ r7 rC rc �eval�getvaluerS � intersection) r$ r� �r�wZ fudgeFactorZ
unlikelyFDr� ZreportedChildFDsZstdFDsr r� r �test_openFileDescriptors{ s: � �
�
�z0ProcessTestsBuilderBase.test_openFileDescriptorsc st dd� }| � td|� | � tddd� � | �� �t�� � �j� �fdd��}| j�d d
� | �d � d �� �
� � d
S )z�
When L{os.execvpe} raises an exception, it will format that exception
on stderr as UTF-8, regardless of system encoding information.
c _ s0 d}t |t�s|�d�}td|d�}t|� d S )Nu <☃>�utf-8z1/0Zsingle)�
isinstance�strr� �compiler� )rd �kw�filenameZcodeobjr r r �execvpe� s
z=ProcessTestsBuilderBase.test_errorDuringExec.<locals>.execvper� r� c S s dS )Nr� r r r r r r= � r5 z>ProcessTestsBuilderBase.test_errorDuringExec.<locals>.<lambda>c s2 G � �fdd�dt t�} ��| � ttddg� d S )Nc s e Zd Z� jZ�fdd�ZdS )z[ProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcherc s � � � d S r! r8 r, r; r r r. � s zhProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcher.processEndedN)r/ r0 r1 rM Z errReceivedr. r r� r r �TracebackCatcher� s r� r4 r5 )r �objectr? r@ )r� r� r r � whenRunning� s
�zAProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning� �Ztimeoutu ☃r� N) ZpatchrP r� r> r� r� rR rC ZassertInr� r� )r$ r� r� r r� r �test_errorDuringExec� s z,ProcessTestsBuilderBase.test_errorDuringExecc s` �� � � G � �fdd�dt�}|� }� j� j|ttddg�jd� �j� dd� ��|j� dS ) zi
If a spawned process exits, C{processExited} will be called in a
timely manner.
c s e Zd ZdZ� �fdd�ZdS )zIProcessTestsBuilderBase.test_timelyProcessExited.<locals>.ExitingProtocolFc s" d| _ � �� ��|jjd� d S )NTr )r{ r9 rS r� r� )Z protoSelfr- �r< r$ r r r| � s zWProcessTestsBuilderBase.test_timelyProcessExited.<locals>.ExitingProtocol.processExitedN)r/ r0 r1 r{ r| r r� r r �ExitingProtocol� s r� r4 s raise SystemExit(0)r6 r� r� N) r> r rR r? r@ r7 rC rA r{ )r$ r� rE r r� r �test_timelyProcessExited� s �z0ProcessTestsBuilderBase.test_timelyProcessExitedc s~ dd|f g}g � G � �fdd�dt �}| �� �|� }�j�j|ttdd�|�gf|di� | ��� | �d� d jj � d S )
aT
Launch a child process, using either the C{uid} or C{gid} argument to
L{IReactorProcess.spawnProcess} to change either its UID or GID to a
different value. If the child process reports this hasn't happened,
raise an exception to fail the test.
@param which: Either C{b"uid"} or C{b"gid"}.
z import osz!raise SystemExit(os.get%s() != 1)c s e Zd Z� �fdd�ZdS )z@ProcessTestsBuilderBase._changeIDTest.<locals>.CaptureExitStatusc s � � |� ��� d S r! )r' r9 r, �Z containerr< r r r. s
zMProcessTestsBuilderBase._changeIDTest.<locals>.CaptureExitStatus.processEndedN)r/ r0 r1 r. r r� r r �CaptureExitStatus s r� r� �
rO r N)
r r> rR r? r@ rT rC rS r� r� )r$ ZwhichrL r� rE r r� r �
_changeIDTest s"
� ��
z%ProcessTestsBuilderBase._changeIDTestc C s | � d� dS )z�
If a value is passed for L{IReactorProcess.spawnProcess}'s C{uid}, the
child process is run with that UID.
ZuidN�r� ra r r r �test_changeUID! s z&ProcessTestsBuilderBase.test_changeUIDc C s | � d� dS )z�
If a value is passed for L{IReactorProcess.spawnProcess}'s C{gid}, the
child process is run with that GID.
�gidNr� ra r r r �test_changeGID+ s z&ProcessTestsBuilderBase.test_changeGIDc s� | � � �G dd� dt�� G � �fdd�dt�}|� }�j|ttddg| jd�}| ��� tdk r�ttj �D ](\}}||k r|qjt�
||� | � d � qj| � d
t
| �� ��� dS ) zY
If L{IProcessProtocol.processExited} raises an exception, it is logged.
c @ s e Zd ZdS )zGProcessTestsBuilderBase.test_processExitedRaises.<locals>.TestExceptionN)r/ r0 r1 r r r r �
TestException= s r� c s e Zd Z� �fdd�ZdS )zBProcessTestsBuilderBase.test_processExitedRaises.<locals>.Protocolc s �� � � d��d S )NzprocessedExited raisedr8 r, �r� r< r r r| A s zPProcessTestsBuilderBase.test_processExitedRaises.<locals>.Protocol.processExitedN)r/ r0 r1 r| r r� r r �Protocol@ s r� r4 r5 r6 NzEAfter processExited raised, transport was left in reapProcessHandlersrO )r> � Exceptionr r? r@ r7 rC r r ZreapProcessHandlersZ unregisterReapProcessHandlerrm rS �lenZflushLoggedErrors)r$ r� rE rF �pidrf r r� r �test_processExitedRaises5 s$ �
z0ProcessTestsBuilderBase.test_processExitedRaises)r/ r0 r1 r2 r ZrequiredInterfacesrG rU rZ r[ r] rb ro r� rj r r� r� r r� r� r� r� r� � _uidgidSkipr� r� r r r r r3 _ s6 %
6�F$
I
" r3 c @ sZ e Zd ZdZdZdZe�� r"dZndZdd� Z dd � Z
d
d � Z d d
� Z dd� Z
dd� ZdS )�ProcessTestsBuilderzp
Builder defining tests relating to L{IReactorProcess} for child processes
which do not have a PTY.
Fs$ twisted.internet.test.process_helpers windowsr5 c s� t � � t � t � t � d��G � �fdd�dt�}d}| �� ��j�j|� ttd|gt| jd� �fdd�}� �|� �fd d
�}� �|� d d � }� �|� � � t
� �fd
d�}� �|� | � �� dS )z�
L{IProcessProtocol.childConnectionLost} is called each time a file
descriptor associated with a child process is closed.
)r rO r� c s$ e Zd Z� fdd�Z�fdd�ZdS )z<ProcessTestsBuilder.test_childConnectionLost.<locals>.Closerc s � � |� d S r! �r+ )r$ rF )� connectedr r �makeConnectiont s zKProcessTestsBuilder.test_childConnectionLost.<locals>.Closer.makeConnectionc s � | � d � d S r! r� �r$ ZchildFD��lostr r rw w s zPProcessTestsBuilder.test_childConnectionLost.<locals>.Closer.childConnectionLostN)r/ r0 r1 r� rw r )r� r� r r �Closers s r� s, twisted.internet.test.process_loseconnection� -m��envr7 c s � � d� �d �� fdd��S )Ns 2
r� c s � S r! r r� rI r r r= � r5 zSProcessTestsBuilder.test_childConnectionLost.<locals>.cbConnected.<locals>.<lambda>�rM rB rI r� rI r � cbConnected� s
zAProcessTestsBuilder.test_childConnectionLost.<locals>.cbConnectedc s � � d� �d �� fdd��S )Ns 1
rO c s � S r! r r� rI r r r= � r5 zRProcessTestsBuilder.test_childConnectionLost.<locals>.lostSecond.<locals>.<lambda>r� rI r� rI r �
lostSecond� s
z@ProcessTestsBuilder.test_childConnectionLost.<locals>.lostSecondc S s | � d� d S )N�
rV rI r r r � lostFirst� s z?ProcessTestsBuilder.test_childConnectionLost.<locals>.lostFirstc s � � � d S r! r8 r: r; r r �cbEnded� s z=ProcessTestsBuilder.test_childConnectionLost.<locals>.cbEndedN) r r r> rR r? r@ � properEnvr7 rB r� r rC )r$ r� �targetr� r� r� r� r )r� r� r< r �test_childConnectionLostk s. �
z,ProcessTestsBuilder.test_childConnectionLostc s� t � � g �G � �fdd�dt�}��� ��j�j|� ttd�jd�jgt�j d� ��fdd�}� �
|� � � t � � �
�fdd �� ��
�� d
S ) z�
L{IProcessProtocol.processEnded} is called after the child process
exits and L{IProcessProtocol.childConnectionLost} is called for each of
its file descriptors.
c s4 e Zd Zdd� Z�fdd�Zdd� Z� fdd�Zd S )
z4ProcessTestsBuilder.test_processEnded.<locals>.Enderc S s t d||f � | j�� d S rp )r rF �loseConnectionrq r r r r* � s zFProcessTestsBuilder.test_processEnded.<locals>.Ender.childDataReceivedc s t d|f � � �|� d S rt )r r' r� r� r r rw � s zHProcessTestsBuilder.test_processEnded.<locals>.Ender.childConnectionLostc S s t d|f � d S rx rv r, r r r r| � s zBProcessTestsBuilder.test_processEnded.<locals>.Ender.processExitedc s t d|f � � �|g� d S r} ry r, )rD r r r. � s zAProcessTestsBuilder.test_processEnded.<locals>.Ender.processEndedNr~ r )rD r� r r �Ender� s r� r� � childr� c s. | \}|� t� ��t� �tdddg�� d S �Nr rO r� )r� r rS rc �rd r� �r� r$ r r r� � s
z6ProcessTestsBuilder.test_processEnded.<locals>.cbEndedc s � � � S r! r8 r� r; r r r= � r5 z7ProcessTestsBuilder.test_processEnded.<locals>.<lambda>N�r r r> rR r? r@ �keepStdioOpenProgram�keepStdioOpenArgr� r7 rB r� r rC )r$ r� r� r )rD r� r< r$ r �test_processEnded� s&
� �
z%ProcessTestsBuilder.test_processEndedc
s� t � �t � � g �G � ��fdd�dt�}��� ��j�j|� ttdd�jd�jgt�j d� � ��fdd�}��
|� ��fd d
�}��
|� �� t � ��
�fd d �� ��
�� d
S )z�
L{IProcessProtocol.processExited} is called when the child process
exits, even if file descriptors associated with the child are still
open.
c s. e Zd Zdd� Z� �fdd�Z�fdd�ZdS )z6ProcessTestsBuilder.test_processExited.<locals>.Waiterc S s t d||f � d S rp rv rq r r r r* � s zHProcessTestsBuilder.test_processExited.<locals>.Waiter.childDataReceivedc s2 t d|f � ��|� t��dkr.� �d � d S )Nru � )r r' r� r+ r� )�allLostr� r r rw � s
zJProcessTestsBuilder.test_processExited.<locals>.Waiter.childConnectionLostc s( t d|f � � �|g� | j�� d S rx )r r+ rF r� r, rz r r r| � s zDProcessTestsBuilder.test_processExited.<locals>.Waiter.processExitedN)r/ r0 r1 r* rw r| r )r� r{ r� r r �Waiter� s r� s -ur� r� r� c s. | \}|� t� td�f � ���g � � S )NzcbExited; lost = %s)r� r r rS r� )r� r� r$ r r r� � s
z8ProcessTestsBuilder.test_processExited.<locals>.cbExitedc s �� t� �tdddg�� d S r� )rS rc r: r� r r � cbAllLost� s z9ProcessTestsBuilder.test_processExited.<locals>.cbAllLostc s � � � S r! r8 r� r; r r r= � r5 z8ProcessTestsBuilder.test_processExited.<locals>.<lambda>Nr� )r$ r� r� r� r )r� r{ r� r< r$ r �test_processExited� s, � �
z&ProcessTestsBuilder.test_processExitedc C sF t | �� �}t|d�� }|�tj�|�tj � W 5 Q R X tj�|�S )zj
Write the given list of lines to a text file and return the absolute
path to it.
Zwt) r Zmktemp�openrM rP rQ rT r� �abspath)r$ Z sourceLinesZscript�
scriptFiler r r �makeSourceFile� s "z"ProcessTestsBuilder.makeSourceFilec s� d��� dt�d�f dd��d�f dg��t��d� ��� ���fdd �� �fd
d ��� ���fd d
�}��|� ���� dS )z�
Spawning a process with an executable which is a script starting
with an interpreter definition line (#!) uses that interpreter to
evaluate the script.
s this is the shebang outputz#!%sr� z
import syszsys.stdout.write('%s')zsys.stdout.flush()i� c sD | \}}}t d|||f � � �|�� � �|d� � �|d� d S )Nz cbProcessExited((%r, %r, %d))r5 r )r rS )rd �outr �code)r$ �
shebangOutputr r �cbProcessExited s
z9ProcessTestsBuilder.test_shebang.<locals>.cbProcessExitedc s � � � | S r! r8 )Z passthroughr; r r �shutdown s z2ProcessTestsBuilder.test_shebang.<locals>.shutdownc s0 t j��d�} | ��� | �� � | �t� d S )Nr; )r �getProcessOutputAndValue�addBothrB r� r ��d)r� r< r� r� r r �start! s
z/ProcessTestsBuilder.test_shebang.<locals>.startN)r� r@ r� rP �chmodr> rR rC )r$ r� r )r� r< r� r$ r� r� r � test_shebang s �
z ProcessTestsBuilder.test_shebangc s� d�dddddg� d� tttdd ���}t|t�r<|�d
� ��� �� �fd d ���fd
d��� ����fdd�}��|� �� �� dS )zq
Arguments given to spawnProcess are passed to the child process as
originally intended.
s! twisted.internet.test.process_clis hello� "s |<>^&s "\\"hello\\"s "foo\ bar baz\""� rO � r� c s, | \}}}|� d�}|�� ��� |� d S )N� )�split�poprS )Z finishedArgsr� r r� )rd r$ r r �processFinished: s
zMProcessTestsBuilder.test_processCommandLineArguments.<locals>.processFinishedc s � � � | S r! r8 )rn r; r r r� A s zFProcessTestsBuilder.test_processCommandLineArguments.<locals>.shutdownc s6 t d �} | �� ��fdd�� | ��� | ��� d S )Nc s t jtd�g� t�d�S )Nr� )r� r< )r r� r@ r� )Zdummy)rd r< �usr r r= G s
�zZProcessTestsBuilder.test_processCommandLineArguments.<locals>.spawnChild.<locals>.<lambda>)r rB r� r� )rd r r< r� r r r �
spawnChildE s
zHProcessTestsBuilder.test_processCommandLineArguments.<locals>.spawnChildN)
rT �map�chrr
r� r r� r> rR rC )r$ ZallCharsr
r )rd r r< r$ r� r r � test_processCommandLineArguments+ s
z4ProcessTestsBuilder.test_processCommandLineArgumentsN)r/ r0 r1 r2 r7 r� r r� r� r� r� r� r� r r
r r r r r� Z s -/3 &r� c @ s6 e Zd ZdZdZe�� r dZne�� r2dZddiZ dS )�PTYProcessTestsBuilderzi
Builder defining tests relating to L{IReactorProcess} for child processes
which have a PTY.
Tz"PTYs are not supported on Windows.z,PTYs are flaky from a Darwin bug. See #8840.z(twisted.internet.pollreactor.PollReactorz$macOS's poll() does not support PTYsN)
r/ r0 r1 r2 r7 r r� r ZisMacOSXZskippedReactorsr r r r r S s �r c @ s e Zd ZdZdd� ZdS )�PotentialZombieWarningTestszE
Tests for L{twisted.internet.error.PotentialZombieWarning}.
c C s\ ddl m} |j | �| jg�}| �|d d t� | �|d d d� | �t|�d� dS )z�
Accessing L{PotentialZombieWarning} via the
I{PotentialZombieWarning} attribute of L{twisted.internet.error}
results in a deprecation warning being emitted.
r )�error�category�messagez�twisted.internet.error.PotentialZombieWarning was deprecated in Twisted 10.0.0: There is no longer any potential for zombie process.rO N)�twisted.internetr ZPotentialZombieWarningZ
flushWarnings�test_deprecatedrS �DeprecationWarningr� )r$ r �warningsr r r r j s
�z+PotentialZombieWarningTests.test_deprecatedN)r/ r0 r1 r2 r r r r r r f s r c @ s& e Zd ZdZdd� Ze�� s"de_dS )�/ProcessIsUnimportableOnUnsupportedPlatormsTestsz�
Tests to ensure that L{twisted.internet.process} is unimportable on
platforms where it does not work (namely Windows).
c C s* | � t�� ddl}|jj W 5 Q R X dS )zI
L{twisted.internet.process} is unimportable on Windows.
r N)r_ � ImportErrorZtwisted.internet.processZinternetr )r$ �twistedr r r �test_unimportableOnWindows� s zJProcessIsUnimportableOnUnsupportedPlatormsTests.test_unimportableOnWindowszOnly relevant on Windows.N)r/ r0 r1 r2 r r r� r r r r r r ~ s r )Hr2 Z
__future__r r r r� rP rj r� ri r r� Ztwisted.trial.unittestr Z#twisted.internet.test.reactormixinsr Ztwisted.python.logr r Ztwisted.python.runtimer Ztwisted.python.filepathr
r Ztwisted.python.compatr r
r r r r r Ztwisted.internet.interfacesr r Ztwisted.internet.deferr r Ztwisted.internet.protocolr Ztwisted.internet.errorr r �
executableZ _asBytesPathr@ �__file__�parentr� r� r� r r �dict�environr� �pathseprT r� �getuidr� r� r r r3 r� �globals�updateZmakeTestCaseClassesr r r r r r r �<module> sb
� ~ v