← Back
Editing: test_core.cpython-38.pyc
U W[�+ � @ s� d Z ddlmZmZ eZddlZddlZddlZddl m Z ddl m Z m Z ddlmZ ddlmZ G dd � d e�ZG d d � d ee�ZG d d � d e�Ze� �e�� � e� �e�� � dS )z/ Tests for implementations of L{IReactorCore}. � )�division�absolute_importN)�FileDescriptor)�ReactorAlreadyRunning�ReactorNotRestartable)�Deferred)�ReactorBuilderc @ s e Zd ZdZdd� ZdS )�ObjectModelIntegrationMixinzN Helpers for tests about the object model of reactor-related objects. c C s@ | � |t� t�t|��}|D ] }| �t|t�d|f � q dS )a. Assert that the given object is an instance of a new-style class and that there are no classic classes in the inheritance hierarchy of that class. This is a beneficial condition because PyPy is better able to optimize attribute lookup on such classes. z%r is not new-styleN)ZassertIsInstance�object�inspectZgetmro�type� assertTrue� issubclass)�self�instance�mro�subclass� r �A/usr/lib/python3/dist-packages/twisted/internet/test/test_core.py�assertFullyNewStyle s �z/ObjectModelIntegrationMixin.assertFullyNewStyleN)�__name__� __module__� __qualname__�__doc__r r r r r r s r c @ s e Zd ZdZdd� ZdS )�ObjectModelIntegrationTestszH Test details of object model integration against all reactors. c C s | � � }| �|� dS )z� Checks that all reactors on a platform have method resolution order containing only new style classes. N)� buildReactorr �r �reactorr r r �test_newstyleReactor1 s z0ObjectModelIntegrationTests.test_newstyleReactorN)r r r r r r r r r r , s r 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 S ) �SystemEventTestsBuilderz{ Builder defining tests relating to L{IReactorCore.addSystemEventTrigger} and L{IReactorCore.fireSystemEvent}. c C s | � � }| �t|j� dS )zu C{reactor.stop()} raises L{RuntimeError} when called when the reactor has not been started. N)r � assertRaises� RuntimeError�stopr r r r �test_stopWhenNotStarted@ s z/SystemEventTestsBuilder.test_stopWhenNotStartedc C s0 | � � }|�|j� | �|� | �t|j� dS )zr C{reactor.stop()} raises L{RuntimeError} when called after the reactor has been stopped. N)r �callWhenRunningr" � runReactorr r! r r r r �test_stopWhenAlreadyStoppedI s z3SystemEventTestsBuilder.test_stopWhenAlreadyStoppedc C sR | � � }g }|�|jd� |�|jd� |�|j� | �|� | �|ddg� dS )zm Functions are run in the order that they were passed to L{reactor.callWhenRunning}. �first�secondN)r r$ �appendr" r% � assertEqual)r r �eventsr r r �test_callWhenRunningOrderT s z1SystemEventTestsBuilder.test_callWhenRunningOrderc s� | � � � i �� �fdd�}� �fdd�}� �fdd�}� �dd|� � �d d|� � �d d|� � �� j� | ��i � | �� � | ��d d d d �� dS )z� The reactor is not running when C{"before"} C{"startup"} triggers are called and is running when C{"during"} and C{"after"} C{"startup"} triggers are called. c s � j �d< d S )N�before��runningr �r �stater r � beforeStartupj s zKSystemEventTestsBuilder.test_runningForStartupEvents.<locals>.beforeStartupc s � j �d< d S )N�duringr. r r0 r r � duringStartupl s zKSystemEventTestsBuilder.test_runningForStartupEvents.<locals>.duringStartupc s � j �d< d S )N�afterr. r r0 r r � afterStartupn s zJSystemEventTestsBuilder.test_runningForStartupEvents.<locals>.afterStartupr- �startupr3 r5 FT)r- r3 r5 N)r �addSystemEventTriggerr$ r" r* r% )r r2 r4 r6 r r0 r � test_runningForStartupEventsb s$ ��z4SystemEventTestsBuilder.test_runningForStartupEventsc s� | � � }dg� � fdd�}� fdd�}|�dd|� |�dd|� g �� �fd d �}| �td |� |�|j� | �� d � | ��g � | �|� | � d�� | �� d d� dS ) ze Signal handlers are installed in responsed to the C{"during"} C{"startup"}. Nc s d� d< d S )Nr- r r r ��phaser r r2 � s zXSystemEventTestsBuilder.test_signalHandlersInstalledDuringStartup.<locals>.beforeStartupc s d� d< d S )Nr5 r r r r: r r r6 � s zWSystemEventTestsBuilder.test_signalHandlersInstalledDuringStartup.<locals>.afterStartupr- r7 r5 c s �� � d � d S )Nr �r) )Zsignum�action�r; ZsawPhaser r � fakeSignal� s zUSystemEventTestsBuilder.test_signalHandlersInstalledDuringStartup.<locals>.fakeSignal�signalr ) r r8 Zpatchr@ r$ r" Z assertIsNoner* r% ZassertIn)r r r2 r6 r? r r> r �)test_signalHandlersInstalledDuringStartup} s zASystemEventTestsBuilder.test_signalHandlersInstalledDuringStartupc sz | � � }g � |�dd� fdd�� |�dd� fdd�� |�dd� fdd�� |�|j� | �|� | �� d d d g� d S ) z� C{reactor.stop()} fires all three phases of shutdown event triggers before it makes C{reactor.run()} return. r- �shutdownc s � � d�S �N�r- rB r< r �r+ r r �<lambda>� � zASystemEventTestsBuilder.test_stopShutDownEvents.<locals>.<lambda>r3 c s � � d�S )N�r3 rB r< r rE r r rF � rG r5 c s � � d�S )N�r5 rB r< r rE r r rF � rG rD rH rI N)r r8 r$ r" r% r* r r rE r �test_stopShutDownEvents� s. � � � �z/SystemEventTestsBuilder.test_stopShutDownEventsc s` | � � �g � ��dd� jd� � �fdd�}��|� | �� g � | ��� | �� ddg� dS )zl C{"before"} C{"shutdown"} triggers are not run synchronously from L{reactor.stop}. r- rB zbefore shutdownc s �� � � �d� d S )N�stopped)r" r) r �r+ r r r �stopIt� s zPSystemEventTestsBuilder.test_shutdownFiresTriggersAsynchronously.<locals>.stopItrK N)r r8 r) r$ r* r% )r rM r rL r �(test_shutdownFiresTriggersAsynchronously� s � z@SystemEventTestsBuilder.test_shutdownFiresTriggersAsynchronouslyc s� dg�G dd� dt �}G �fdd�dt �}| �� }t|� |� g�� � fdd�|_|�|j� | �|� | �t| � t ��d� | � �d � d S ) z� A L{IFileDescriptor.connectionLost} implementation which raises an exception does not prevent the remaining L{IFileDescriptor}s from having their C{connectionLost} method called. Fc @ s e Zd Zdd� ZdS )zZSystemEventTestsBuilder.test_shutdownDisconnectsCleanly.<locals>.ProblematicFileDescriptorc S s t d��d S )Nz simulated connectionLost error)r! �r �reasonr r r �connectionLost� s ziSystemEventTestsBuilder.test_shutdownDisconnectsCleanly.<locals>.ProblematicFileDescriptor.connectionLostN�r r r rQ r r r r �ProblematicFileDescriptor� s rS c s e Zd Z� fdd�ZdS )zQSystemEventTestsBuilder.test_shutdownDisconnectsCleanly.<locals>.OKFileDescriptorc s d� d< d S )NTr r rO ��lostOKr r rQ � s z`SystemEventTestsBuilder.test_shutdownDisconnectsCleanly.<locals>.OKFileDescriptor.connectionLostNrR r rT r r �OKFileDescriptor� s rV c s � S )Nr r )�fdsr r rF � rG zISystemEventTestsBuilder.test_shutdownDisconnectsCleanly.<locals>.<lambda>� r N) r r �iterZ removeAllr$ r" r% r* �lenZflushLoggedErrorsr! r )r rS rV r r )rW rU r � test_shutdownDisconnectsCleanly� s z7SystemEventTestsBuilder.test_shutdownDisconnectsCleanlyc sN g � � ��fdd�}�� � ���|� ���j� ���� ��� dg� dS )z{ C{reactor.run()} raises L{ReactorAlreadyRunning} when called when the reactor is already running. c s �� t�j� � �d� d S �N�tested)r r �runr) r �r+ r r r r � reentrantRun� s z>SystemEventTestsBuilder.test_multipleRun.<locals>.reentrantRunr] N)r r$ r" r% r* )r r` r r_ r �test_multipleRun� s z(SystemEventTestsBuilder.test_multipleRunc sV g �� ��fdd�}��fdd�� | � � ���dd|� | ��� | ��ddg� d S ) z� When there is a C{'before'} C{'startup'} trigger which returns an unfired L{Deferred}, C{reactor.run()} starts the reactor and does not return until after C{reactor.stop()} is called c s. �� d� t� } | �� � ��d| jd � | S )N�triggerr )r) r Z addCallback� callLater�callback)�d�rd r+ r r r rb � s zUSystemEventTestsBuilder.test_runWithAsynchronousBeforeStartupTrigger.<locals>.triggerc s � � d� ��� d S )Nrd )r) r" )ZignoredrL r r rd � s zVSystemEventTestsBuilder.test_runWithAsynchronousBeforeStartupTrigger.<locals>.callbackr- r7 rb rd N)r r8 r% r* )r rb r rf r �,test_runWithAsynchronousBeforeStartupTrigger� s zDSystemEventTestsBuilder.test_runWithAsynchronousBeforeStartupTriggerc C sN | � � }|�d|j�}t�� }|�d� t�� | }| �|dk � |�� dS )z6 C{reactor.iterate()} does not block. � r � N)r rc �crash�timeZiterater Zcancel)r r �t�start�elapsedr r r � test_iterate s z$SystemEventTestsBuilder.test_iteratec sZ | � � }g � |�dd� fdd�� |�|jd|j� | �|� | �|j� | �� d� dS )zc C{reactor.crash()} stops the reactor and does not fire shutdown triggers. r- rB c s � � d�S rC r< r rE r r rF rG z4SystemEventTestsBuilder.test_crash.<locals>.<lambda>r z8Shutdown triggers invoked but they should not have been.N)r r8 r$ rc rj r% Z assertFalser/ r r rE r � test_crash s � �z"SystemEventTestsBuilder.test_crashc sd g � � �fdd�}| � � ���|� | ��� � �fdd�}��|� | ��� | �� ddg� dS )zp C{reactor.run()} restarts the reactor after it has been stopped by C{reactor.crash()}. c s � � d� ��� d S )Nrj )r) rj r rL r r rj - s z9SystemEventTestsBuilder.test_runAfterCrash.<locals>.crashc s � � d�jf� ��� d S )Nr" )r) r/ r" r rL r r r" 3 s z8SystemEventTestsBuilder.test_runAfterCrash.<locals>.stoprj )r" TN)r r$ r% r* )r rj r" r rL r �test_runAfterCrash' s z*SystemEventTestsBuilder.test_runAfterCrashc sR g � � ��fdd�}�� � ����j� ��dd|� ���� ��� dg� dS )z� C{reactor.run()} raises L{ReactorNotRestartable} when called when the reactor is being run after getting stopped priorly. c s �� t�j� � �d� d S r\ )r r r^ r) r r_ r r �restartA s z:SystemEventTestsBuilder.test_runAfterStop.<locals>.restartr5 rB r] N)r r$ r" r8 r% r* )r rr r r_ r �test_runAfterStop; s z)SystemEventTestsBuilder.test_runAfterStopN)r r r r r# r& r, r9 rA rJ rN r[ ra rg ro rp rq rs r r r r r ; s r )r Z __future__r r r Z __metaclass__r@ rk r Ztwisted.internet.abstractr Ztwisted.internet.errorr r Ztwisted.internet.deferr Z#twisted.internet.test.reactormixinsr r r r r �globals�updateZmakeTestCaseClassesr r r r �<module> s
Save File
Cancel