Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/trial/_dist/test/__pycache__/test_disttrial.cpython-39.pyc
Ðазад
a k�h�B � @ sj d Z ddlZddlZddlmZ ddlmZmZ ddlm Z m Z m Z ddl m Z mZmZmZ ddlmZ ddlmZmZ dd lmZmZ dd lmZ dd lm Z dd l m Z dd l m Z ddl!m"Z" ddl#m$Z$ ddl%m&Z& ddl'm(Z(m)Z)m*Z* ddl+m,Z,m-Z- ddl.m/Z/m0Z0 G dd� d�Z1ee j2�G dd� de ��Z3G dd� de/�Z4G dd� d�Z5G d d � d e0�Z6dS ) z- Tests for L{twisted.trial._dist.disttrial}. � N)�StringIO)� implementer�verify)�error� interfaces�reactor)�fail� gatherResults� maybeDeferred�succeed)�CONNECTION_DONE)�ProcessProtocol�Protocol)� Cooperator� deferLater)�Failure)�FilesystemLock)�MemoryReactorClock)� FakeScheduler)� DistReporter)�DistTrialRunner)� LocalWorker)�Reporter� TreeReporter� UncleanWarningsReporterWrapper)� ErrorHolder� TrialSuite)�SynchronousTestCase�TestCasec @ s e Zd ZdZdd� ZdS )� FakeTransportz* A simple fake process transport. c C s dS )z% Ignore write calls. N� )�self�fd�datar r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/trial/_dist/test/test_disttrial.py� writeToChild( s zFakeTransport.writeToChildN)�__name__� __module__� __qualname__�__doc__r% r r r r$ r # s r c @ sL e Zd ZdZdZdZdZdd� Zdi dddddfdd�Zd d � Z d d � Z dS ) �CountingReactorz� A fake reactor that counts the calls to L{IReactorCore.run}, L{IReactorCore.stop}, and L{IReactorProcess.spawnProcess}. r c C s t �| � || _d S �N)r �__init__�_workers)r! �workersr r r$ r, 9 s zCountingReactor.__init__r Nc C s* | j �|� |�t� � | jd7 _dS )z� See L{IReactorProcess.spawnProcess}. @param workerProto: See L{IReactorProcess.spawnProcess}. @param args: See L{IReactorProcess.spawnProcess}. @param kwargs: See L{IReactorProcess.spawnProcess}. � N)r- �append�makeConnectionr � spawnCount) r! Z workerProto� executable�args�env�path�uid�gid�usePTY�childFDsr r r$ � spawnProcess= s z CountingReactor.spawnProcessc C s t �| � | jd7 _dS )z+ See L{IReactorCore.stop}. r/ N)r �stop� stopCount�r! r r r$ r< T s zCountingReactor.stopc C s> | j d7 _ d| _d| _| jD ]\}}}||i |�� q dS )z* See L{IReactorCore.run}. r/ TN)�runCount�runningZhasRunZwhenRunningHooks)r! �fr4 �kwargsr r r$ �run[ s zCountingReactor.run) r& r' r( r) r2 r= r? r, r; r< rC r r r r$ r* . s � r* c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �CountingReactorTestsz' Tests for L{CountingReactor}. c C s g | _ t| j �| _d S r+ )r. r* r r> r r r$ �setUpn s zCountingReactorTests.setUpc C s t �tj| j� dS )zJ L{CountingReactor} instances provide L{IReactorProcess}. N)r Z verifyObjectr �IReactorProcessr r> r r r$ � test_providesIReactorProcessr s z1CountingReactorTests.test_providesIReactorProcessc C sj | � | jj� t� }dD ]L}| jj|tjtjgd� | �|j� | � | j |g| � | � | jj|� qdS )z� The process protocol for a spawned process is connected to a transport and appended onto the provided C{workers} list, and the reactor's C{spawnCount} increased. �r/ � �r4 N) � assertFalser r2 r r; �sysr3 � assertTrue� transport� assertEqualr. )r! �proto�countr r r$ �test_spawnProcessx s z&CountingReactorTests.test_spawnProcessc C s6 | � | jj� dD ] }| j�� | �| jj|� qdS )zB Stopping the reactor increments its C{stopCount} rH N)rK r r= r< rO )r! rQ r r r$ � test_stop� s z CountingReactorTests.test_stopc C sj | � | jj� g }| j�|jd� dD ]>}| j�� | �| jj|� | �| jjd� | �t|�|� q&dS )z� Running the reactor increments its C{runCount}, does not imply C{stop}, and calls L{IReactorCore.callWhenRunning} hooks. NrH r ) rK r r? ZcallWhenRunningr0 rC rO r= �len)r! ZwhenRunningCallsrQ r r r$ �test_run� s z CountingReactorTests.test_runN) r& r' r( r) rE rG rR rS rU r r r r$ rD i s rD c @ s e Zd ZdZdd� ZdS )�"EternalTerminationPredicateFactoryzI A rigged terminationPredicateFactory for which time never pass. c C s dS )z% See: L{task._Timer} Fr r> r r r$ �__call__� s z+EternalTerminationPredicateFactory.__call__N)r& r' r( r) rW r r r r$ rV � s rV c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"S )#�DistTrialRunnerTestsz' Tests for L{DistTrialRunner}. c C s$ t tdg | �� d�| _t� | j_dS )z. Create a runner for testing. � )�workingDirectoryN)r r �mktemp�runnerr �_streamr> r r r$ rE � s �zDistTrialRunnerTests.setUpc C s. |D ]$}|j �tjtj� |�tt�� qdS )z� Reap the workers and trap L{ConnectionDone} failures on their C{endDeferred}s. @param workers: The workers to reap. @type workers: An iterable of L{LocalWorker} N)Z endDeferredZ addErrbackr Ztrapr ZConnectionDoneZ processEndedr )r! r. �workerr r r$ �reap� s zDistTrialRunnerTests.reapc C s t � }t|td�}||fS )a Helper to create fake scheduler and cooperator in tests. The cooperator has a termination timer which will never inform the scheduler that the task needs to be terminated. @return: L{tuple} of (scheduler, cooperator) )� schedulerZterminationPredicateFactory)r r rV )r! r` � cooperatorr r r$ �$getFakeSchedulerAndEternalCooperator� s �z9DistTrialRunnerTests.getFakeSchedulerAndEternalCooperatorc C s4 t � }tt|��}| j�|� | �|�� dk� dS )ze L{DistTrialRunner.writeResults} writes to the stream specified in the init. r N)r r r r\ Z writeResultsrM �tell)r! ZstringIO�resultr r r$ �test_writeResults� s z&DistTrialRunnerTests.test_writeResultsc C sJ dd� t d�D �}| j�|d�}|D ]}| �|t� q$| �dt|�� dS )zv C{createLocalWorkers} iterates the list of protocols and create one L{LocalWorker} for each. c S s g | ] }t � �qS r )�object)�.0�xr r r$ � <listcomp>� � z@DistTrialRunnerTests.test_createLocalWorkers.<locals>.<listcomp>rY r6 N)�ranger\ ZcreateLocalWorkers�assertIsInstancer rO rT )r! � protocolsr. �sr r r$ �test_createLocalWorkers� s z,DistTrialRunnerTests.test_createLocalWorkersc s� dd� t d�D �}g � i �di dddddf� �fdd� }| j�||d g� | �� d � d � | �tj�� d �� | �d � d � | �tj� t j��d � dS )z� Given a C{spawnProcess} function, C{launchWorkerProcess} launches a python process with an existing path as its argument. c S s g | ] }t � �qS r )r )rg �ir r r$ ri � rj zCDistTrialRunnerTests.test_launchWorkerProcesses.<locals>.<listcomp>rY r Nr c s" � � |� � �|� ��|� d S r+ )r0 �extend�update) ZprocessProtocolr3 r4 r5 r6 r7 r8 r9 r: �� arguments� environmentr r$ �fakeSpawnProcess� s zIDistTrialRunnerTests.test_launchWorkerProcesses.<locals>.fakeSpawnProcessZfoor/ rI � � PYTHONPATH) rk r\ ZlaunchWorkerProcessesrO rM �osr6 �exists�pathsep�joinrL )r! rm rv r rs r$ �test_launchWorkerProcesses� s �z/DistTrialRunnerTests.test_launchWorkerProcessesc C sl g }t |�}| �| j|� t� }td�D ]}|�t� � q(| j�||� | � |j d� | � |j | jj � dS )zm C{run} starts the reactor exactly once and spawns each of the workers exactly once. � r/ N) r* � addCleanupr_ r rk �addTestr r\ rC rO r? r2 Z _workerNumber)r! r. � fakeReactor�suiterp r r r$ rU s z DistTrialRunnerTests.test_runc s� G � �fdd�dt �}� �� }t�|� tj�|d��t�d �}|�� � �|j � �� j _ g }||�}� �� j |� t � }td�D ]}|�t� � q�� j �||� dS )z� L{DistTrialRunner} checks if the test directory is already locked, and if it is generates a name based on it. c s e Zd Z� �fdd�ZdS )zKDistTrialRunnerTests.test_runUsedDirectory.<locals>.CountingReactorWithLockc s� | j �|� � �tj�|j�tj�tj��d t| j ���� t �d �}� � |� � � | j d7 _ |� t� � dd� |j_d S )Nz-1z-1.lockr/ c W s t d �S r+ �r rJ r r r$ �<lambda>1 rj zjDistTrialRunnerTests.test_runUsedDirectory.<locals>.CountingReactorWithLock.spawnProcess.<locals>.<lambda>)r- r0 rO ry r6 �abspathZ _logDirectoryr| �strr2 r rK �lockr1 r � _ampProtocolrC )Zoselfr^ r4 rB � localLock�r! rZ r r$ r; % s �� zXDistTrialRunnerTests.test_runUsedDirectory.<locals>.CountingReactorWithLock.spawnProcessN)r& r' r( r; r r� r r$ �CountingReactorWithLock$ s r� Z _trial_temp�.lockr~ N)r* r[ ry �mkdirr6 r| r r� r �unlockr\ �_workingDirectoryr_ r rk r� r rC )r! r� Z newDirectoryr� r. r� r� rp r r� r$ �test_runUsedDirectory s z*DistTrialRunnerTests.test_runUsedDirectoryc C sJ g }t |�}| �| j|� | j�t� |� | �|jd� | �|jd� dS )zh L{DistTrialRunner} doesn't try to start more workers than the number of tests. r/ N) r* r r_ r\ rC r rO r? r2 )r! r. r� r r r$ �test_minimalWorkerF s z'DistTrialRunnerTests.test_minimalWorkerc C sP g }t |�}| �| j|� d| j_| j�t� |�}| �|t� | �|j t � dS )z� Running with the C{unclean-warnings} option makes L{DistTrialRunner} uses the L{UncleanWarningsReporterWrapper}. TN) r* r r_ r\ Z_uncleanWarningsrC r rl r �originalr )r! r. r� rd r r r$ �test_runUncleanWarningsS s z,DistTrialRunnerTests.test_runUncleanWarningsc C sN t � }t� }| j�||�}| �|t� | jj�� }| �d|� | �d|� dS )z� When the suite contains no test, L{DistTrialRunner} takes a shortcut path without launching any process or starting the reactor. �Running 0 test�PASSEDN) rf r r\ rC rl r r] �getvalue�assertIn)r! r� r� rd �outputr r r$ �test_runWithoutTesta s z(DistTrialRunnerTests.test_runWithoutTestc C s~ t � }tdttd���}| j�||�}| �|t� | jj� � }| � d|� | � d|� | � d|� | � d|� | � d|� dS )z� Even if there is no test, the suite can contain an error (most likely, an import error): this should make the run fail, and the error should be printed. zan errorzfoo barr� zerrors=1ZFAILEDN) rf r r � RuntimeErrorr\ rC rl r r] r� r� )r! r� r rd r� r r r$ �!test_runWithoutTestButWithAnErrorn s z6DistTrialRunnerTests.test_runWithoutTestButWithAnErrorc C s� G dd� dt �}| �� \}}g }||�}| �| j|� | j�t� ||j�}| �|j d� | �|j d� |� � | �dt |j j�� dS )zw If for some reasons we can't connect to the worker process, the test suite catches and fails. c @ s e Zd Zdd� Zdd� ZdS )zMDistTrialRunnerTests.test_runUnexpectedError.<locals>.CountingReactorWithFailc _ s4 | j �|� |�t� � | jd7 _| j|j_d S �Nr/ )r- r0 r1 r r2 � failingRunr� rC �r! r^ r4 rB r r r$ r; � s zZDistTrialRunnerTests.test_runUnexpectedError.<locals>.CountingReactorWithFail.spawnProcessc S s t td��S )N�oops)r r� �r! �caserd r r r$ r� � s zXDistTrialRunnerTests.test_runUnexpectedError.<locals>.CountingReactorWithFail.failingRunN)r& r' r( r; r� r r r r$ �CountingReactorWithFail� s r� r/ N)r* rb r r_ r\ rC r � cooperaterO r? r2 �pumprT r� Zfailures)r! r� r` ra r. r� rd r r r$ �test_runUnexpectedError s z,DistTrialRunnerTests.test_runUnexpectedErrorc s� G dd� dt �}�jj�g }||�� �j�t� � � � ��fdd�}��t� j�� �dg� ��t� jd �dg� �� |� t t d|�S )zz L{DistTrialRunner} calls C{reactor.stop} and unlocks the test directory once the tests have run. c @ s e Zd Zdd� Zdd� ZdS )zODistTrialRunnerTests.test_runStopAfterTests.<locals>.CountingReactorWithSuccessc _ s4 | j �|� |�t� � | jd7 _| j|j_d S r� �r- r0 r1 r r2 � succeedingRunr� rC r� r r r$ r; � s z\DistTrialRunnerTests.test_runStopAfterTests.<locals>.CountingReactorWithSuccess.spawnProcessc S s t d �S r+ r� r� r r r$ r� � s z]DistTrialRunnerTests.test_runStopAfterTests.<locals>.CountingReactorWithSuccess.succeedingRunN�r& r' r( r; r� r r r r$ �CountingReactorWithSuccess� s r� c s, t �d �} ��| �� � ��d� j� d S )Nr� r/ �r rM r� rO r= �r� �r� r! rZ r r$ �check� s z:DistTrialRunnerTests.test_runStopAfterTests.<locals>.check�before�shutdownr ) r* r\ r� rC r rO �list�triggers�keysr_ r r )r! r� r. r� r r� r$ �test_runStopAfterTests� s z+DistTrialRunnerTests.test_runStopAfterTestsc s� g }�j j�t|�� �j �t� � � �fdd�}� ��fdd����t� j�� �dg� ��t� jd �dg� �� |� t dd� � jd d D ��� |�S ) z� L{DistTrialRunner} waits for the worker processes to stop when the reactor is stopping, and then unlocks the test directory, not trying to stop the reactor again. c s t td� �S )Nr )r r )Zign)� realCheckr r$ r� � s zEDistTrialRunnerTests.test_runWaitForProcessesDeferreds.<locals>.checkc s, t �d �} ��| �� � ��d� j� d S )Nr� r r� r� r� r r$ r� � s zIDistTrialRunnerTests.test_runWaitForProcessesDeferreds.<locals>.realCheckr� r� c S s( g | ] \}}}t |g|�R i |���qS r )r )rg rA �a�kwr r r$ ri � s �zJDistTrialRunnerTests.test_runWaitForProcessesDeferreds.<locals>.<listcomp>) r\ r� r* rC r rO r� r� r� r_ r Z addCallback)r! r. r� r )r� r� r! rZ r$ �!test_runWaitForProcessesDeferreds� s ���z6DistTrialRunnerTests.test_runWaitForProcessesDeferredsc s� g � G � fdd�dt �}g }||�}| �| j|� | �� \}}| jjt� ||jdd�}|�� | � dt � �� | � |� � � | jj �� }| �d|� | �d|� tdd�D ]}| �d |� �|� q�d S ) z L{DistTrialRunner} can run in C{untilFailure} mode where it will run the given tests until they fail. c s e Zd Zdd� Z� fdd�ZdS )zMDistTrialRunnerTests.test_runUntilFailure.<locals>.CountingReactorWithSuccessc _ s4 | j �|� |�t� � | jd7 _| j|j_d S r� r� r� r r r$ r; � s zZDistTrialRunnerTests.test_runUntilFailure.<locals>.CountingReactorWithSuccess.spawnProcessc s* � � d � t� �dkr"ttd��S td �S )N� r� )r0 rT r r� r r� �Zcalledr r$ r� � s z[DistTrialRunnerTests.test_runUntilFailure.<locals>.CountingReactorWithSuccess.succeedingRunNr� r r� r r$ r� � s r� T)r� Z untilFailurer� r� ZFAILr/ z Test Pass N)r* r r_ rb r\ rC r r� r� rO rT rK Z wasSuccessfulr] r� r� rk ) r! r� r. r� r` ra rd r� rp r r� r$ �test_runUntilFailure� s" � z)DistTrialRunnerTests.test_runUntilFailureN)r& r' r( r) rE r_ rb re ro r} rU r� r� r� r� r� r� r� r� r� r r r r$ rX � s" !( "!rX )7r) ry rL �ior Zzope.interfacer r Ztwisted.internetr r r Ztwisted.internet.deferr r r r Ztwisted.internet.mainr Ztwisted.internet.protocolr r Ztwisted.internet.taskr r Ztwisted.python.failurer Ztwisted.python.lockfiler Ztwisted.test.proto_helpersr Z twisted.test.test_cooperatorr Z twisted.trial._dist.distreporterr Z twisted.trial._dist.disttrialr Ztwisted.trial._dist.workerr Ztwisted.trial.reporterr r r Ztwisted.trial.runnerr r Ztwisted.trial.unittestr r r rF r* rD rV rX r r r r$ �<module> s2 :8
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка