Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_process.cpython-39.pyc
Ðазад
a k�h|� � @ s( d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl Z ddl Z ddl m Z ddl mZmZmZ ddlmZmZ ddlmZmZ ddlmZ dd lmZ dd lm Z dd l m Z m Z dd l m!Z!m"Z" dd l#m$Z$ ddl%m&Z& e ej'��(� Z)e e j*��+� �+� Z,dZ-dZ.e/ej0�Z1ej2�3ej4�e1d< z.ddl5Z6ddl m7Z8 e�9� dk�r\dZ-dZ.W n$ e:�y� dZ5dZ7dZ-dZ.Y n 0 e6Z5e8Z7dd� Z;G dd� de�Z<G dd� de�Z=G d d � d e=�Z>e?� �@e>�A� � G d d � d e=�ZBe?� �@eB�A� � G d d!� d!e&�ZCG d"d#� d#e&�ZDG d$d%� d%e&�ZEdS )&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. � N)�skipIf)�utils)�Deferred�inlineCallbacks�succeed)� ProcessDone�ProcessTerminated)�IProcessTransport�IReactorProcess)�ProcessProtocol)�ReactorBuilder)� networkString)�FilePath�_asFilesystemBytes)�err�msg)�platform)�TestCaseF� � PYTHONPATH��processTz$Cannot change UID/GID except as rootz Cannot change UID/GID on Windowsc C s t du rd| _| 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-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__S s z)_ShutdownCallbackProcessProtocol.__init__c C s | j �|g ��|� d S r )r � setdefault�append)r! �fd�bytesr r r �childDataReceivedW 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 J s r c @ s� e Zd ZdZegZdd� Zdd� Zdd� Zdd � Z d d � Z d d � Z e e edd�du d�dd� �Zdd� Zdd� Zedd� �Zedd� �Zdd � Zd d � Ze ee�d d � �Ze ee�d!d"� �Zd#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>� r2 zHProcessTestsBuilderBase.test_processTransportInterface.<locals>.<lambda>N) r r � buildReactor� spawnProcess�pyExer4 � assertTruer Z providedBy� addCallback� runReactor)r! �ended�protocol� transportr r8 r � test_processTransportInterfacei 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 sN �� �ttd�g�} z�| � � W n& tyH td d� | �d� Y n0 d S )Nr1 z!Unhandled exception while writingZKILL)r< r= � BaseExceptionr � signalProcess�rC �� bytesToSend�programrB r9 �writer r �startup� s z3ProcessTestsBuilderBase._writeTest.<locals>.startupc s � � � S r r5 r7 r8 r r r: � r2 z4ProcessTestsBuilderBase._writeTest.<locals>.<lambda>r2 � N) r; r r r �os�linesep�callWhenRunningr? r@ � assertEqual�joinr )r! rK rA rL r rH 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 �rK �rC rI r r r rK � s z1ProcessTestsBuilderBase.test_write.<locals>.writeN�rS �r! rK 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 writeSequencerU r r r rK � s z9ProcessTestsBuilderBase.test_writeSequence.<locals>.writeNrV rW 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 )� writeToChildrU r r r rK � s z8ProcessTestsBuilderBase.test_writeToChild.<locals>.writeNrV rW 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 s2 z � � t| jd|� W | �|� n | �|� 0 d S )N� )� assertRaises�KeyErrorrZ rK rU �r! r r rK � s zIProcessTestsBuilderBase.test_writeToChildBadFileDescriptor.<locals>.writeNrV rW r r_ r �"test_writeToChildBadFileDescriptor� s z:ProcessTestsBuilderBase.test_writeToChildBadFileDescriptor�SIGCHLDNz;Platform lacks SIGCHLD, early-spawnProcess test can't work.c 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>.handlerr1 r2 )r4 �childFDs�x z,Timed out waiting for child process to exit.c s � � � S r r5 r7 r8 r r r: r2 zHProcessTestsBuilderBase.test_spawnProcessEarlyIsReaped.<locals>.<lambda>)r; r4 � threading�Event�signalra r r< r r= �wait�isSet�failr? r$ r@ r> )r! rf re rA �resultr )r9 rd r � test_spawnProcessEarlyIsReaped� s2 � z6ProcessTestsBuilderBase.test_spawnProcessEarlyIsReapedc 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. �TERMZSIGsE 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 rC rF �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|�d�� � �|g� d S �NzprocessExited(�)�r r( r) ��exitedr r � processExited0 s zRProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.processExitedc S s t d|�d�� d S �Nz processEnded(rz rw r) r r r r+ 9 s zQProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.processEndedN�r, r- r. r' rx r~ r+ r )r} rt r r �Exiter( s r� r1 r3 c sX | \}|� t� |j}t�� r:� �|j� � �|jd� n� �|j�� � �|j� d S )NrM ) �trapr �valuer � isWindowsZ assertIsNonerj rQ �exitCode)rc �failurer )r! �sigNumr r �cbExitedE s zFProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.cbExitedc s � � � S r r5 �Zignr8 r r r: Z r2 zFProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.<lambda>N) �getattrrj r r r; rP r< r= r4 r? � addErrbackr r@ )r! �sourcer� r� r )r} r9 r! rt 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 s� zvt �t�� �} t�| ddg� tj| ddgtjd�}|j� ��|j� � � W d � n1 sb0 Y W � � � n � � � 0 d S )N�-cz import time; time.sleep(0.1)z)import time; time.sleep(0.5);print('Foo'))�stdout) r= �decode�sys�getfilesystemencoding� subprocess�Popen�PIPEr� r$ �readr6 )�exe�f2�r9 rn r r �fl s �0zJProcessTestsBuilderBase.test_systemCallUninterruptedByChildExit.<locals>.fs Foo�asciiN)r; rP r@ rQ rN rO �encode)r! r� r r� r �'test_systemCallUninterruptedByChildExit^ 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� �� ��}g d �}| �|�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, '{}') 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 r5 r) r8 r r r+ � s zXProcessTestsBuilderBase.test_openFileDescriptors.<locals>.GatheringProtocol.processEndedN)r, r- r. rK Z outReceivedr+ r ��outputr9 r r �GatheringProtocol� s r� s -Wignorer1 r3 �r rM � N)r �format� twistedRoot�pathrN �pipeZ addCleanup�closer Z getrlimitZ RLIMIT_NOFILE�dup2�io�BytesIOr r; rP r< r= r4 r@ rb �eval�getvaluerQ � intersection) r! r� �r�wZ fudgeFactorZ unlikelyFDr� ZreportedChildFDsZstdFDsr r� r �test_openFileDescriptors� s8 �� � �z0ProcessTestsBuilderBase.test_openFileDescriptorsc sr dd� }| � td|� | � tddd� � | �� �t�� � �j� �fdd��}| j�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/0�single)� isinstance�strr� �compiler� )rc �kw�filename�codeobjr r r �execvpe� s z=ProcessTestsBuilderBase.test_errorDuringExec.<locals>.execvper� r� c S s dS )Nr� r r r r r r: � r2 z>ProcessTestsBuilderBase.test_errorDuringExec.<locals>.<lambda>c s0 G � �fdd�dt �} ��| � ttddg� d S )Nc s e Zd Z� jZ�fdd�ZdS )z[ProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcherc s � � � d S r r5 r) r8 r r r+ � s zhProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcher.processEndedN)r, r- r. rK Z errReceivedr+ r r� r r �TracebackCatcher� s r� r1 r2 )r r< r= )r� r� r r � whenRunning� s zAProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning� ��timeoutu ☃N) �patchrN r� r; r� r� rP r@ 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} r6 rQ r� r� )Z protoSelfr* �r9 r! r r r~ � s zWProcessTestsBuilderBase.test_timelyProcessExited.<locals>.ExitingProtocol.processExitedN)r, r- r. r} r~ r r� r r �ExitingProtocol� s r� r1 s raise SystemExit(0)r3 r� r� N) r; r rP r< r= r4 r@ r> r} )r! r� rB r r� r �test_timelyProcessExited� s � z0ProcessTestsBuilderBase.test_timelyProcessExitedc s� dd|� d�g}g � G � �fdd�dt �}| �� �|� }�j�j|ttdd�|�gfi |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 oszraise SystemExit(os.getz() != 1)c s e Zd Z� �fdd�ZdS )z@ProcessTestsBuilderBase._changeIDTest.<locals>.CaptureExitStatusc s � � |� ��� d S r )r$ r6 r) �� containerr9 r r r+ s zMProcessTestsBuilderBase._changeIDTest.<locals>.CaptureExitStatus.processEndedN)r, r- r. r+ r r� r r �CaptureExitStatus s r� r� � rM r N) r r; rP r< r= rR r@ rQ r� r� )r! �whichrJ r� rB 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. �uidN�r� r_ r r r �test_changeUID1 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� r_ r r r �test_changeGID9 s z&ProcessTestsBuilderBase.test_changeGIDc s� | � � �G dd� dt�� G � �fdd�dt�}|� }�j|ttddg| jd�}| ��� tdur�ttj � � �D ](\}}||ur�qnt� ||� | � d � qn| � 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, r- r. r r r r � TestExceptionI s r� c s e Zd Z� �fdd�ZdS )zBProcessTestsBuilderBase.test_processExitedRaises.<locals>.Protocolc s �� � � d��d S )NzprocessedExited raisedr5 r) �r� r9 r r r~ M s zPProcessTestsBuilderBase.test_processExitedRaises.<locals>.Protocol.processExitedN)r, r- r. r~ r r� r r �ProtocolL s r� r1 r2 r3 NzEAfter processExited raised, transport was left in reapProcessHandlersrM )r; � Exceptionr r< r= r4 r@ r �list�reapProcessHandlers�itemsZ unregisterReapProcessHandlerrm rQ �len�flushLoggedErrors)r! r� rB rC �pidre r r� r �test_processExitedRaisesA s" � �z0ProcessTestsBuilderBase.test_processExitedRaises) r, r- r. r/ r ZrequiredInterfacesrD rS rX rY r[ r` r r� rj ro r� r� r r� r� r� r� � _uidgidSkip�_uidgidSkipReasonr� r� r� r r r r r0 ^ s4 ! � <J# P " r0 c @ sn e Zd ZdZdZdZe�� r"dZndZdd� Z dd � Z d d � Z d d � Z dd� Z dd� Zdd� Zedd� �ZdS )�ProcessTestsBuilderzp Builder defining tests relating to L{IReactorProcess} for child processes which do not have a PTY. Fs$ twisted.internet.test.process_helpers windowsr2 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� c s$ e Zd Z� fdd�Z�fdd�ZdS )z<ProcessTestsBuilder.test_childConnectionLost.<locals>.Closerc s � � |� d S r �r( )r! rC )� connectedr r �makeConnection� s zKProcessTestsBuilder.test_childConnectionLost.<locals>.Closer.makeConnectionc s � | � d � d S r r� �r! ZchildFD��lostr r rx � s zPProcessTestsBuilder.test_childConnectionLost.<locals>.Closer.childConnectionLostN)r, r- r. r� rx r )r� r� r r �Closer� s r� s, twisted.internet.test.process_loseconnection� -m��envr4 c s � � d� �d �� fdd��S )Ns 2 r� c s � S r r r� rG r r r: � r2 zSProcessTestsBuilder.test_childConnectionLost.<locals>.cbConnected.<locals>.<lambda>�rK r? rG r� rG r � cbConnected� s zAProcessTestsBuilder.test_childConnectionLost.<locals>.cbConnectedc s � � d� �d �� fdd��S )Ns 1 rM c s � S r r r� rG r r r: � r2 zRProcessTestsBuilder.test_childConnectionLost.<locals>.lostSecond.<locals>.<lambda>r� rG r� rG r � lostSecond� s z@ProcessTestsBuilder.test_childConnectionLost.<locals>.lostSecondc S s | � d� d S )N� rT rG r r r � lostFirst� s z?ProcessTestsBuilder.test_childConnectionLost.<locals>.lostFirstc s � � � d S r r5 r7 r8 r r �cbEnded� s z=ProcessTestsBuilder.test_childConnectionLost.<locals>.cbEndedN) r r r; rP r< r= � properEnvr4 r? r� r r@ )r! r� �targetr� r� r� r� r )r� r� r9 r �test_childConnectionLostx 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 rq )r rC �loseConnectionrr r r r r' � s zFProcessTestsBuilder.test_processEnded.<locals>.Ender.childDataReceivedc s t d|f � � �|� d S ru )r r$ r� r� r r rx � s zHProcessTestsBuilder.test_processEnded.<locals>.Ender.childConnectionLostc S s t d|�d�� d S ry rw r) r r r r~ � s zBProcessTestsBuilder.test_processEnded.<locals>.Ender.processExitedc s t d|�d�� � �|g� d S r r{ r) )rA r r r+ � s zAProcessTestsBuilder.test_processEnded.<locals>.Ender.processEndedNr� r )rA r� r r �Ender� s r� r� � childr� c s( | \}|� t� ��t� �h d�� d S �N> r rM r� )r� r rQ rb �rc r� �r� r! r r r� � s z6ProcessTestsBuilder.test_processEnded.<locals>.cbEndedc s � � � S r r5 r� r8 r r r: � r2 z7ProcessTestsBuilder.test_processEnded.<locals>.<lambda>N�r r r; rP r< r= �keepStdioOpenProgram�keepStdioOpenArgr� r4 r? r� r r@ )r! r� r� r )rA r� r9 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 rq rw rr r r r r' � s zHProcessTestsBuilder.test_processExited.<locals>.Waiter.childDataReceivedc s2 t d|f � ��|� t��dkr.� �d � d S )Nrv � )r r$ r� r( r� )�allLostr� r r rx � s zJProcessTestsBuilder.test_processExited.<locals>.Waiter.childConnectionLostc s* t d|�d�� � �|g� | j�� d S ry )r r( rC r� r) r| r r r~ � s zDProcessTestsBuilder.test_processExited.<locals>.Waiter.processExitedN)r, r- r. r' rx r~ r )r� r} r� r r �Waiter� s r� s -ur� r� r� c s. | \}|� t� td�� �� ���g � � S )NzcbExited; lost = )r� r r rQ r� )r� r� r! r r r� s z8ProcessTestsBuilder.test_processExited.<locals>.cbExitedc s �� t� �h d�� d S r� )rQ rb r7 r� r r � cbAllLost s z9ProcessTestsBuilder.test_processExited.<locals>.cbAllLostc s � � � S r r5 r� r8 r r r: r2 z8ProcessTestsBuilder.test_processExited.<locals>.<lambda>Nr� )r! r� r� r� r )r� r} r� r9 r! r �test_processExited� s4 �� z&ProcessTestsBuilder.test_processExitedc C sZ t | �� �}t|d��(}|�tj�|�tj � W d � n1 sD0 Y tj�|�S )zj Write the given list of lines to a text file and return the absolute path to it. ZwtN) r �mktemp�openrK rN rO rR r� �abspath)r! Z sourceLines�script� scriptFiler r r �makeSourceFile s 6z"ProcessTestsBuilder.makeSourceFilec s� d��� d�t�d��dd���d��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#!{}r� z import syszsys.stdout.write('{}')zsys.stdout.flush()i� c sD | \}}}t d|||f � � �|�� � �|d� � �|d� d S )Nz cbProcessExited((%r, %r, %d))r2 r )r rQ )rc �outr �code)r! � shebangOutputr r �cbProcessExited; s z9ProcessTestsBuilder.test_shebang.<locals>.cbProcessExitedc s � � � | S r r5 )Z passthroughr8 r r �shutdownB s z2ProcessTestsBuilder.test_shebang.<locals>.shutdownc s0 t j��d�} | ��� | �� � | �t� d S )Nr8 )r �getProcessOutputAndValue�addBothr? r� r ��d)r r9 r r r r �startF s z/ProcessTestsBuilder.test_shebang.<locals>.startN) r r� r= r� rN �chmodr; rP r@ )r! r r )r r9 r r! r r r � test_shebang' s �� z ProcessTestsBuilder.test_shebangc s. � fdd�}� � � }|�||� � �|� dS )z< Pause producing and then resume producing. c sL z<t � }| j|ttddg� jd�}|�� |�� W | �� n | �� 0 d S )Nr1 r2 r3 )r r< r= r4 ZpauseProducingZresumeProducingr6 )r9 rB rC r_ r r �pauseAndResumeT s � zHProcessTestsBuilder.test_pauseAndResumeProducing.<locals>.pauseAndResumeN)r; rP r@ )r! r r9 r r_ r � test_pauseAndResumeProducingO s z0ProcessTestsBuilder.test_pauseAndResumeProducingc s� d�g d�� d� tttdd���}t|t�r6|�d� ��� �� �fdd���fd d ��� ����fd d �}��|� �� �� d S )zq Arguments given to spawnProcess are passed to the child process as originally intended. s! twisted.internet.test.process_cli)s hello� "s |<>^&s "\\"hello\\"s "foo\ bar baz\""r rM � r� c s, | \}}}|� d�}|�� ��� |� d S )N� )�split�poprQ )Z finishedArgsr� r r )rc r! r r �processFinishedr s zMProcessTestsBuilder.test_processCommandLineArguments.<locals>.processFinishedc s � � � | S r r5 )rn r8 r r r y s zFProcessTestsBuilder.test_processCommandLineArguments.<locals>.shutdownc s6 t d �} | �� ��fdd�� | ��� | ��� d S )Nc s t jtd�g� t�d�S )Nr� )r� r9 )r r r= r� )�dummy)rc r9 �usr r r: � s �zZProcessTestsBuilder.test_processCommandLineArguments.<locals>.spawnChild.<locals>.<lambda>)r r? r r )rc r r9 r r r r � spawnChild} s � zHProcessTestsBuilder.test_processCommandLineArguments.<locals>.spawnChildN) rR �map�chr�ranger� r� r� r; rP r@ )r! ZallCharsr r )rc r r9 r! r r r � test_processCommandLineArgumentsc s z4ProcessTestsBuilder.test_processCommandLineArgumentsc s` g �G �fdd�dt �� t� �fdd��}| �� }|�||� | �|� t��t�dg�� dS )z� Process is removed from reapProcessHandler dict before running ProcessProtocol.processEnded() callback. c s$ e Zd ZdZdd� Z� fdd�ZdS )ziProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.TestProcessProtocola7 Process protocol captures own presence in process.reapProcessHandlers at time of .processEnded() callback. @ivar deferred: A deferred fired when the .processEnded() callback has completed. @type deferred: L{Deferred<defer.Deferred>} c S s t � | _d S r )r �deferredr_ r r r r" � s zrProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.TestProcessProtocol.__init__c sJ ddl m} |j}|�� }| j|v r0� �d� n � �d� | j�d� dS )z� Capture whether the process has already been removed from process.reapProcessHandlers. @param status: unused r r z!process present but should not be�"process already removed as desiredN)�twisted.internetr r� �valuesrC r$ r! r( )r! �statusr �handlersZ processes��resultsr r r+ � s zvProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.TestProcessProtocol.processEndedN)r, r- r. r/ r" r+ r r' r r �TestProcessProtocol� s r) c 3 sp z`z$� � }| � |ttdg� |jV W n. tyT } z��|� W Y d}~n d}~0 0 W | �� n | �� 0 dS )a Launch and wait for a subprocess and allow the TestProcessProtocol to capture the order of the .processEnded() callback vs. removal from process.reapProcessHandlers. @param reactor: Reactor used to spawn the test process and to be stopped when checks are complete. @type reactor: object providing L{twisted.internet.interfaces.IReactorProcess} and L{twisted.internet.interfaces.IReactorCore}. z --versionN)r< r= r! r� r$ r6 )r9 ZtestProcessProtocol�e�r) r( r r �launchProcessAndWait� s � "zjProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.launchProcessAndWaitr" N)r r r; rP r@ �hamcrestZ assert_thatZequal_to)r! r, r9 r r+ r �8test_process_unregistered_before_protocol_ended_callback� s �zLProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callbackN)r, r- r. r/ r4 r� r r� r� r� r� r� r r r r r r. r r r r r� g s 52> ('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, r- r. r/ r4 r r� r ZisMacOSXZskippedReactorsr r r r r/ � 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.rM N)r# r1 ZPotentialZombieWarningZ flushWarnings�test_deprecatedrQ �DeprecationWarningr� )r! r1 �warningsr r r r4 � s �z+PotentialZombieWarningTests.test_deprecatedN)r, r- r. r/ r4 r r r r r0 � s r0 c @ s( e Zd ZdZee�� d�dd� �ZdS )�/ProcessIsUnimportableOnUnsupportedPlatormsTestsz� Tests to ensure that L{twisted.internet.process} is unimportable on platforms where it does not work (namely Windows). zOnly relevant on Windows.c C s> | � t�� ddl}|jj W d � n1 s00 Y 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_unimportableOnWindowsN)r, r- r. r/ r r r� r: r r r r r7 s r7 c @ sj e Zd Zze�dd� W n4 eyL Z z ee�Ze e�Z W Y dZ[n dZ[0 0 e dd� �Z e dd� �Z dS )�ReapingNonePidsLogsProperlyNc C sF t �d d � | �� \}| �t|j�| jd� | �t|j�| jd� d S �NzWrong error type loggedzWrong error message logged) r ZregisterReapProcessHandlerr� rQ �typer� � expected_typer� �expected_message)r! r1 r r r � test_registerReapProcessHandler" s ��z;ReapingNonePidsLogsProperly.test_registerReapProcessHandlerc C sL t �d �}|�� | �� \}| �t|j�| jd� | �t|j�| j d� d S r< ) r Z _BaseProcessZ reapProcessr� rQ r= r� r> r� r? )r! Z _baseProcessr1 r r r � test__BaseProcess_reapProcess2 s ��z9ReapingNonePidsLogsProperly.test__BaseProcess_reapProcess)r, r- r. rN �waitpidr� r* r� r? r= r> r r@ rA r r r r r; s r; )Fr/ r� rN rj r� r� rh Zunittestr r- r9 r# r Ztwisted.internet.deferr r r Ztwisted.internet.errorr r Ztwisted.internet.interfacesr r Ztwisted.internet.protocolr Z#twisted.internet.test.reactormixinsr Ztwisted.python.compatr Ztwisted.python.filepathr r Ztwisted.python.logr r Ztwisted.python.runtimer Ztwisted.trial.unittestr � executableZ _asBytesPathr= �__file__�parentr� r� r� �dict�environr� �pathseprR r� r Z _resourcer Z_process�getuidr8 r r r0 r� �globals�updateZmakeTestCaseClassesr/ r0 r7 r; r r r r �<module> sn q
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка