0x1949 Team - FAZEMRX - MANAGER
Edit File: test_application.cpython-310.pyc
o �b\� � @ s6 d Z ddlZddlZddlZddlmZ zddlZW n ey% dZY nw ddlm Z ddl m Z m Z m Z mZ ddlmZ ddlmZmZmZmZ ddlmZ dd lmZ dd lmZm Z dd l m Z dd l m Z dd l!m"Z" ddl#m$Z$ ddl%m&Z&m'Z' G dd� d�Z(G dd� de'�Z)e*ed�r�e�+� Z,e�-� Z.nd Z,Z.G dd� de'�Z/G dd� de'�Z0G dd� de'�Z1G dd � d e'�Z2G d d � d e'�Z3G d d � d ej4�Z5G d!d"� d"�Z6G d#d$� d$�Z7G d%d&� d&e j8�Z9G d'd(� d(e'�Z:G d)d*� d*e'�Z;G d+d,� d,e j<�Z=G d-d.� d.e"e'�Z>G d/d0� d0e'�Z?G d1d2� d2e'�Z@dS )3zU Tests for L{twisted.application} and its interaction with L{twisted.persisted.sob}. � N)�StringIO)�skipIf)�app�internet�reactors�service)� backoffPolicy)�defer� interfaces�protocol�reactor)�sob)�twisted_reactors)�basic�wire)�usage)� platformType)�TwistedModulesMixin)� MemoryReactor)�SkipTest�TestCasec @ s e Zd ZdZdS )�DummyN)�__name__� __module__� __qualname__� processName� r r �?/usr/lib/python3/dist-packages/twisted/test/test_application.pyr # s r c @ st e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS ) � ServiceTestsc C s$ t �� }|�d� | �|jd� d S �N�hello)r �Service�setName� assertEqual�name��self�sr r r �testName( s zServiceTests.testNamec C s> t �� }t �� }|�|� | �t|�|g� | �|j|� d S �N)r r! � MultiService�setServiceParentr# �list�parent�r& r' �pr r r � testParent- s zServiceTests.testParentc C sL t �� }t �d�}|�|� | �tt �|��|g� | �|jt �|�� d S )N� )r r! � Applicationr+ r# r, �IServiceCollectionr- r. r r r �testApplicationAsParent4 s z$ServiceTests.testApplicationAsParentc C sZ t �� }t �� }|�d� |�|� | �t|�|g� | �|j|� | �|�d�|� d S r ) r r! r* r" r+ r# r, r- �getServiceNamedr. r r r �testNamedChild; s zServiceTests.testNamedChildc C s8 t �� }t �� }|�d� |�|� | �t|jd� d S )Nr �lala�r r! r* r" r+ � assertRaises� RuntimeErrorr. r r r �testDoublyNamedChildD s z!ServiceTests.testDoublyNamedChildc C sJ t �� }t �� }|�d� |�|� t �� }|�d� | �t|j|� d S r r8 r. r r r �testDuplicateNamedChildK s z$ServiceTests.testDuplicateNamedChildc C sb t �� }t �� }|�|� | �t|�|g� | �|j|� |�� | �t|�g � | �|j� d S r) ) r r! r* r+ r# r, r- �disownServiceParent� assertIsNoner. r r r � testDisowningT s zServiceTests.testDisowningc C s@ t �� }| �|j� |�� | �|j� |�� | �|j� d S r) )r r! � assertFalse�running� startService� assertTrue� stopServicer% r r r � testRunning^ s zServiceTests.testRunningc C sv t �� }t �� }|�|� | �|j� | �|j� |�� | �|j� | �|j� |�� | �|j� | �|j� d S r) ) r r! r* r+ r@ rA rB rC rD r. r r r �testRunningChildren1f s z!ServiceTests.testRunningChildren1c sZ t �� � � �fdd�}t �� }||_||_t �� }� �|� |�|� |�� |�� d S )Nc s �� � j� d S r) )rC rA r �r' r& r r � checkRunningv � z7ServiceTests.testRunningChildren2.<locals>.checkRunning)r r! rD rB r* r+ )r& rH �tr/ r rG r �testRunningChildren2s s z!ServiceTests.testRunningChildren2c C sR t �� }|�� t �� }| �|j� |�|� | �|j� |�� | �|j� d S r) ) r r* rB r! r@ rA r+ rC r= )r& r/ r' r r r �testAddingIntoRunning� s z"ServiceTests.testAddingIntoRunningc sV t �� � � fdd�}|� _t �� }t �� }� �|� |�|� |�� | �� j� d S )Nc s d� _ d S �N� )�privilegedStartedr �r' r r �pss� � z(ServiceTests.testPrivileged.<locals>.pss)r r! �privilegedStartServicer* r+ rC rO )r& rQ �s1r/ r rP r �testPrivileged� s zServiceTests.testPrivilegedc C s6 t �� }|�� t�|�}| �|j� | �|j� d S r) )r r! rB �copyr@ rA rC )r& r' rT r r r � testCopying� s zServiceTests.testCopyingN)r r r r( r0 r4 r6 r; r< r? rE rF rK rL rU rW r r r r r ' s r �getuidc @ �$ e Zd Zdd� Zdd� Zdd� ZdS )� ProcessTestsc C s, t �dd�}| �|jd� | �|jd� d S )N� � )r �Processr# �uid�gid�r& r/ r r r �testID� s zProcessTests.testIDc C sn t �d�}| �|jd� | �|j� t jdd�}| �|j� | �|jd� t �� }| �|j� | �|j� d S )Nr[ )r_ )r r] r# r^ r> r_ r` r r r � testDefaults� s zProcessTests.testDefaultsc C s, t �� }| �|j� d|_| �|jd� d S r )r r] r> r r# r` r r r �testProcessName� s z ProcessTests.testProcessNameN)r r r ra rb rc r r r r rZ � s rZ c @ rY )�InterfacesTestsc C � | � tj�t�� �� d S r) )rC r �IService� providedByr! �r& r r r � testService� � zInterfacesTests.testServicec C s0 | � tj�t�� �� | � tj�t�� �� d S r) )rC r rf rg r* r3 rh r r r �testMultiService� s z InterfacesTests.testMultiServicec C re r) )rC r �IProcessrg r] rh r r r � testProcess� rj zInterfacesTests.testProcessN)r r r ri rk rm r r r r rd � � rd c @ �, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �ApplicationTestsc C s( t �d� t �dd� t �ddd� d S �Nr r[ r\ )r r2 rh r r r �testConstructor� s z ApplicationTests.testConstructorc C s� t �d�}| �t �|�j� | �t �|�j� t �dd�}| �t �|�jd� | �t �|�j� t �ddd�}| �t �|�jd� | �t �|�jd� d S rq )r r2 r> rl r^ r_ r# �r& �ar r r �testProcessComponent� s z%ApplicationTests.testProcessComponentc C sL t �d�}| �t �|�t �|�� | �t �|�jd� | �t �|�j� d S r ) r r2 �assertIsrf r3 r# r$ r> r- rs r r r �testServiceComponent� s z%ApplicationTests.testServiceComponentc C sB t �d�}t�|�}| �|jd� | �|jd� | �|j|� d S )Nr �pickle) r r2 r � IPersistabler# �styler$ rv �original)r& rt r/ r r r �testPersistableComponent� s z)ApplicationTests.testPersistableComponentN)r r r rr ru rw r| r r r r rp � s rp c @ � e Zd Zdd� ZdS )� LoadingTestsc C s� t �d�}t�|�}d�� D ] }|�|� |�� t �d|d |�}| �t � |�j d� qt dd��}|� ddg� W d � n1 sEw Y t �dd �}| �t � |�j d� d S ) Nr � source picklezhello.tar z hello.tac�w�(from twisted.application import service �+application = service.Application('hello') �python) r r2 r ry �split�setStyle�save�loadApplicationr# rf r$ �open� writelines)r& rt r/ rz �a1�fr r r �test_simpleStoreAndLoad� s �� � z$LoadingTests.test_simpleStoreAndLoadN)r r r r� r r r r r~ � � r~ c @ ro ) �AppSupportTestsc C s | � t�d�� d S )Nr )r> r � getPassphraserh r r r �testPassphrase s z AppSupportTests.testPassphrasec C s� t �d�}dddd�}d�� D ]1}|�� }d|ddi�||�< t�|��|� t�|�jdd� t � |d�}| � t � |�j d� q|�� }d|d < tdd ��}|�d d g� W d � n1 s`w Y t � |d�}| � t � |�j d� dS ) zL Test loading an application file in different dump format. r N)�file�sourcer� r �helloapplicationrx r� ��filenamer� r� r� r� )r r2 r� rV �getr ry r� r� r �getApplicationr# rf r$ r� r� )r& rt � baseconfigrz �configr� r� r r r �testLoadApplication s( �� � z#AppSupportTests.testLoadApplicationc C s� t �d�}d�� D ]4}d�� D ]-}t�|��|� t�|�jdd� t�d|d d|d� t � d|�}| � t � |�j d� qq d S )Nr7 r � converttestr� zconverttest.outr ) r r2 r� r ry r� r� r � convertStyler� r# rf r$ )r& �appl�instyle�outstyle�appl2r r r �test_convertStyle s � ��z!AppSupportTests.test_convertStylec C s, t �d�}t�|d� | �t �|�j� d S )Nr7 r )r r2 r �startApplicationrC rf rA )r& r� r r r �test_startApplication) s z%AppSupportTests.test_startApplicationN)r r r r� r� r� r� r r r r r� s r� c @ rY )�Fooc C � | j �d� d S )Ns lalala )� transport�writerh r r r �connectionMade0 rI zFoo.connectionMadec C s || j _| j�� d S r) )�factory�liner� �loseConnection)r& r� r r r � lineReceived3 � zFoo.lineReceivedc C s | j j�| j j� d S r) )r� �d�callbackr� �r& �reasonr r r �connectionLost7 s zFoo.connectionLostN)r r r r� r� r� r r r r r� / rn r� c @ s e Zd ZdZdd� Zdd� ZdS )�DummyAppNc C s || j |j< d S r) ��servicesr$ �r& r r r r � addService> rI zDummyApp.addServicec C s | j |j= d S r) r� r� r r r � removeServiceA � zDummyApp.removeService)r r r r r� r� r r r r r� ; s r� c @ s e Zd Zdd� Zdd� ZdS )� TimerTargetc C s g | _ d S r) ��lrh r r r �__init__F rR zTimerTarget.__init__c C s | j �|� d S r) )r� �append)r& �whatr r r r� I rI zTimerTarget.appendN)r r r r� r� r r r r r� E s r� c @ r} )�TestEchoc C r� �NT)r� r� r� r r r r� N rI zTestEcho.connectionLostN)r r r r� r r r r r� M r� r� c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zee� e d � d �d d � �Z d d� Z ee� e d � d �dd� �Z ee� e d � d �dd� �Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd S )#� InternetTestsc s� t �� � � �� t�� }t|_t�� t_t � d|�}|� � � |j � � j}t�� }t�� |_t|_d |_t �d||�� � � |j�| jd� |j�� fdd�� |j�dd� � |jS )Nr � 127.0.0.1� lalalac � � � � S r) �rD ��xrP r r �<lambda>b � z'InternetTests.testTCP.<locals>.<lambda>c S � t jS r) �r� r� r� r r r r� c � )r r* rB r � ServerFactoryr� r �Deferredr� r � TCPServerr+ �_port�getHost�port� ClientFactoryr� r� � TCPClient� addCallbackr# )r& r� rJ �numr rP r �testTCPS s" zInternetTests.testTCPc sh t �td�s td��t�� �t�d��}|�� |j � � j � | � � d� � �fdd�}t �|j��|�S )z� Test L{internet.UDPServer} with a random port: starting the service should give it valid port, and stopService should free it so that we can start a server on the same port again. Nz)This reactor does not support UDP socketsr c s t �� ��}|�� |�� S r) )r � UDPServerrB rD )�ignoredrJ �r� r/ r r �onStopt s z&InternetTests.test_UDP.<locals>.onStop)r � IReactorUDPr r r �DatagramProtocolr r� rB r� r� r� �assertNotEqualr � maybeDeferredrD r� )r& rJ r� r r� r �test_UDPf s zInternetTests.test_UDPc s� t �� }t|_ t�� t_t�d|��d�_�� � �j � � j }t � � }t�� |_t|_ d |_t�d||�� � �� |j�| jd� |j�� fdd�� |j��fdd�� |j�dd� � |jS ) Nr rN r� r� c r� r) r� r� )�cr r r� � r� z.InternetTests.testPrivileged.<locals>.<lambda>c r� r) r� r� �rJ r r r� � r� c S r� r) r� r� r r r r� � r� )r r� r� r r� r� r r� � privilegedrS r� r� r� r� r� r� r� rB r� r# )r& r� r� r )r� rJ r rU { s$ z InternetTests.testPrivilegedc sp t �� }tj|_ t�d|�}|�� |j�� j }|� � t � � � t � � }� fdd�|_t�d||�}|�� � S )Nr c � � � d �S r) �r� ��args�r� r r r� � � z<InternetTests.testConnectionGettingRefused.<locals>.<lambda>r� )r r� r �Echor r� rB r� r� r� rD r r� r� �clientConnectionFailedr� )r& r� rJ r� r� r r� r � testConnectionGettingRefused� s z*InternetTests.testConnectionGettingRefusedNz1This reactor does not support UNIX domain socketsc s� t �� � � �� t�� }t|_t�� t_t � d|�}|� � � t� � }t |_t�� |_d |_t �d|�� � � |j�| jd� |j�� fdd�� |j�dd� � |j�| j|� � |jS )N�echo.sktr� c r� r) r� r� rP r r r� � r� z(InternetTests.testUNIX.<locals>.<lambda>c S r� r) r� r� r r r r� � r� )r r* rB r r� r� r r� r� r � UNIXServerr+ r� r� r� � UNIXClientr� r# � _cbTestUnix�r& r� rJ r rP r �testUNIX� s" zInternetTests.testUNIXc s\ t �� t_d |_t �� |_� �� |j�| jd� |j�� fdd�� |j�dd� � |jS )Nr� c r� r) r� r� rP r r r� � r� z+InternetTests._cbTestUnix.<locals>.<lambda>c S r� r) r� r� r r r r� � r� )r r� r� r� r� rB r� r# )r& r� r� r' r rP r r� � s zInternetTests._cbTestUnixc C s� t �� }tj|_ t�d|�}|�� | �|jd � t � |�}| � |j� |� � | � |j� | � |j � t �� }tj|_ t�d|�}|�� | �|jd � t � |�}| � |j� |� � | � |j� | � |j � d S )Nr� )r r� r r� r r� rB �failIfIdenticalr� rV r> rD r@ rA r� r� � _connection)r& r� rJ �t1r r r � testVolatile� s( zInternetTests.testVolatilec sf t �� }tj|_ t�d|�}|�� |�� | �|j � t � � }t � � � � fdd�|_ t�d|� � S )Nr� c r� r) r� r� r� r r r� � r� z2InternetTests.testStoppingServer.<locals>.<lambda>)r r� r r� r r� rB rD r@ rA r� r r� r� r � connectUNIXr� r r� r �testStoppingServer� s z InternetTests.testStoppingServerc C sJ t � }t�d|jd�}|�� t�|�}|�� t�|�}| � |j � d S )NrN r ) r� r � TimerServicer� rB rx �dumpsrD �loadsr@ rA )r& �target�t0r' rJ r r r �testPickledTimer� s z InternetTests.testPickledTimerc sb t �� � t�ddd� ���j�� �fdd�}|�_��� � ��fdd�� � ��fdd�� � S )NrN c S s dd S )NrN r r r r r r r� � r� z/InternetTests.testBrokenTimer.<locals>.<lambda>c s �| � � � d � d S r) r� )�why)r� � oldFailedr r �_failed� r� z.InternetTests.testBrokenTimer.<locals>._failedc s � j S r) r� r� r� r r r� r� c s � � tgdd� � �t�D ��S )Nc S s g | ]}|j j�qS r )�value� __class__)�.0�or r r � <listcomp> s zCInternetTests.testBrokenTimer.<locals>.<lambda>.<locals>.<listcomp>)r# �ZeroDivisionError�flushLoggedErrorsr� rh r r r� s �)r r� r r� r rB r� )r& r r )r� r r& rJ r �testBrokenTimer� s �z InternetTests.testBrokenTimerc C s� g d�}|dd� D ]}t td| �td�s|�|� q |D ]U}dD ]P}|dkr-|dkr-q"|dkr6|dkr6q"| �tt|| �� t t|| �j}dd d�| }| �tt|| �p_|d ko_|dk� t t|| �� }| �t � |�|� q"q dS ) z� L{twisted.application.internet} dynamically defines a set of L{service.Service} subclasses that in general have corresponding reactor.listenXXX or reactor.connectXXX calls. )�TCP�UNIX�SSL�UDP� UNIXDatagram� MulticastN�IReactor)�Server�Clientr r r �listen�connect) �getattrr r �removerC �hasattrr �methodr# r rf )r& �trans�tran�sider �prefixr r r r �test_everythingThere s, ����z"InternetTests.test_everythingTherec C s( t jD ]}| �tt |�|� d�� qdS )z� L{twisted.application.internet} dynamically defines L{service.Service} subclasses. This test ensures that the subclasses exposed by C{__all__} are valid attributes of the module. z1 not importable from twisted.application.internetN)r �__all__rC r )r& �clsr r r �test_importAll$ s ��z InternetTests.test_importAllc C sF t � }t� }tjd||d�}|�� | �|j�� dd� d|f� dS )z� L{internet._AbstractServer} supports a C{reactor} keyword argument that can be used to parametrize the reactor used to listen for connections. �� �r N� )r �objectr r� rB r# � tcpServers�pop�r& r r� rJ r r r �#test_reactorParametrizationInServer0 s "z1InternetTests.test_reactorParametrizationInServerc C sL t � }t�� }tjdd||d�}|�� | �|j�� dd� dd|f� dS )z� L{internet._AbstractClient} supports a C{reactor} keyword arguments that can be used to parametrize the reactor used to create new client connections. r� r" r# N� ) r r r� r r� rB r# � tcpClientsr' r( r r r �#test_reactorParametrizationInClient= s $z1InternetTests.test_reactorParametrizationInClientc C sv t � }t�� }tjd||d�}|�� | �|j�� dd� d|f� |� � |�� | �|j�� dd� d|f� dS )z� Like L{test_reactorParametrizationInServer}, but stop and restart the service and check that the given reactor is still used. r" r# Nr$ ) r r �Factoryr r� rB r# r& r' rD r( r r r �0test_reactorParametrizationInServerMultipleStartJ s "z>InternetTests.test_reactorParametrizationInServerMultipleStartc C s| t � }t�� }tjdd||d�}|�� | �|j�� dd� dd|f� |� � |�� | �|j�� dd� dd|f� dS )z� Like L{test_reactorParametrizationInClient}, but stop and restart the service and check that the given reactor is still used. r� r" r# Nr* ) r r r� r r� rB r# r+ r' rD r( r r r �0test_reactorParametrizationInClientMultipleStartY s $z>InternetTests.test_reactorParametrizationInClientMultipleStart)r r r r� r� rU r� r r � IReactorUNIXr r� r� r� r� r� r r r! r) r, r. r/ r r r r r� R s: � � � r� c @ ro ) �TimerBasicTestsc sZ t �� }t�d|jd�� _� j�� |�� jd� |�� fdd�� |�� fdd�� |S )NrN r c � � j �� S r) �rJ rD r� rh r r r� o r� z/TimerBasicTests.testTimerRuns.<locals>.<lambda>c s � � � jj�S r) )r@ rJ rA r� rh r r r� p s ) r r� r r� r� rJ rB r� r# )r& r� r rh r � testTimerRunsj s z TimerBasicTests.testTimerRunsc C s | j �� S r) r3 rh r r r �tearDowns rR zTimerBasicTests.tearDownc s� t �� }t �� � � df|dfg��fdd�}t�d|��_�j�� �fdd�}� �fdd �}�fd d �}|�|� |�|� |�|� |S ) N�bar�fooc s � � � \} }| �|� d S r) )r' r� )r� �arg)�workr r �trigger| � z1TimerBasicTests.testTimerRestart.<locals>.triggerrN c s � � | d� � j�� S )Nr7 �r# rJ rD ��resultrh r r � onFirstResult� s z7TimerBasicTests.testTimerRestart.<locals>.onFirstResultc s �� �jj� �j�� � S r) )r@ rJ rA rB )r� )�d2r& r r � onFirstStop� s z5TimerBasicTests.testTimerRestart.<locals>.onFirstStopc s � � | d� � j�� d S )Nr6 r< r= rh r r �onSecondResult� r; z8TimerBasicTests.testTimerRestart.<locals>.onSecondResult)r r� r r� rJ rB r� )r& �d1r: r? rA rB r )r@ r& r9 r �testTimerRestartv s z TimerBasicTests.testTimerRestartc s` g � � fdd�}t �� }t�d|dd|��_�j�� |��jdgd � |��fdd�� |S )Nc s( � � | � t� �|kr|�� � d S d S r) )r� �lenr� )�data�numberr� r� r r r: � s �z/TimerBasicTests.testTimerLoops.<locals>.triggerg{�G�z�?r � c r2 r) r3 r� rh r r r� � r� z0TimerBasicTests.testTimerLoops.<locals>.<lambda>)r r� r r� rJ rB r� r# )r& r: r� r )r� r& r �testTimerLoops� s z TimerBasicTests.testTimerLoopsN)r r r r4 r5 rD rI r r r r r1 i s r1 c @ s e Zd ZdZdd� ZdS )� FakeReactorz6 A fake reactor with a hooked install method. c O s$ t jj| g|�R i |�� || _dS )zv @param install: any callable that will be used as install method. @type install: C{callable} N)r �Reactorr� �install)r& rL r� �kwargsr r r r� � s zFakeReactor.__init__N)r r r �__doc__r� r r r r rJ � s rJ c @ sz e Zd ZdZdd� Zdd� Zd dd�Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � ZdS ) �PluggableReactorTestsz: Tests for the reactor discovery/inspection APIs. c C s g | _ g | _tj| _| jt_dS )aI Override the L{reactors.getPlugins} function, normally bound to L{twisted.plugin.getPlugins}, in order to control which L{IReactorInstaller} plugins are seen as available. C{self.pluginResults} can be customized and will be used as the result of calls to C{reactors.getPlugins}. N)� pluginCalls� pluginResultsr � getPlugins�originalFunction� _getPluginsrh r r r �setUp� s zPluggableReactorTests.setUpc C s | j t_dS )z> Restore the original L{reactors.getPlugins}. N)rS r rR rh r r r r5 � s z PluggableReactorTests.tearDownNc C s | j �||f� t| j�S )zy Stand-in for the real getPlugins method which records its arguments and returns a fixed result. )rP r� r, rQ )r& � interface�packager r r rT � s z!PluggableReactorTests._getPluginsc C sv d}t d }d}t�|||�g| _t�� }| �| jtjdfg� |D ]}|j|kr3| �|j |� dS q"| � d� dS )zP Test that reactor plugins are returned from L{getReactorTypes} �fakereactortestz .fakereactor� descriptionNz6Reactor plugin not present in getReactorTypes() result) r r rK rQ �getReactorTypesr# rP �IReactorInstaller� shortNamerY �fail)r& r$ rW rY � reactorTypes�rr r r �test_getPluginReactorTypes� s �z0PluggableReactorTests.test_getPluginReactorTypesc sX g � � fdd�}t |dtd�}d|i}| �|� t�ddd�}|�� | �� dg� dS )zy Test that L{reactors.Reactor.install} loads the correct module and calls its install attribute. c � � � d� d S r� �r� r �� installedr r rL � r� z?PluggableReactorTests.test_reactorInstallation.<locals>.installrX � described� fakereactorTN)rJ r �replaceSysModulesr rK rL r# )r& rL � fakeReactor�modules� installerr rc r �test_reactorInstallation� s z.PluggableReactorTests.test_reactorInstallationc sJ g � � fdd�}d}t }d}t||||�g| _t�|� | �� dg� dS )zu Test that the L{reactors.installReactor} function correctly installs the specified reactor. c ra r� rb r rc r r rL � r� z:PluggableReactorTests.test_installReactor.<locals>.installrX rY TN�r rJ rQ r �installReactorr# �r& rL r$ rW rY r rc r �test_installReactor� s z)PluggableReactorTests.test_installReactorc sL t � � � �fdd�}d}t}d}t||||�g�_t�|�}��|� � dS )zt Test that the L{reactors.installReactor} function correctly returns the installed reactor. c s ddl m} ��| d� � d S )Nr �r r )�twistedr �patchrp �r r& r r rL s zHPluggableReactorTests.test_installReactorReturnsReactor.<locals>.installrX rY N)r% r rJ rQ r rm rv )r& rL r$ rW rY rd r rs r �!test_installReactorReturnsReactor s z7PluggableReactorTests.test_installReactorReturnsReactorc sb g � � fdd�}d}t }d}t||||�}tdd� d||�}||g| _t�|� | �� dg� d S ) z� Test that the L{reactors.installReactor} function correctly installs the specified reactor when there are multiple reactor plugins. c ra r� rb r rc r r rL # r� zIPluggableReactorTests.test_installReactorMultiplePlugins.<locals>.installrX rY c S s d S r) r r r r r r� * � zJPluggableReactorTests.test_installReactorMultiplePlugins.<locals>.<lambda>� otherreactorTNrl )r& rL r$ rW rY rh � otherReactorr rc r �"test_installReactorMultiplePlugins s z8PluggableReactorTests.test_installReactorMultiplePluginsc C s g | _ | �tjtjd� dS )z� Test that L{reactors.installReactor} raises L{reactors.NoSuchReactor} when asked to install a reactor which it cannot find. � somereactorN)rQ r9 r � NoSuchReactorrm rh r r r � test_installNonExistentReactor/ s �z4PluggableReactorTests.test_installNonExistentReactorc C s: dd� }d}t }d}t||||�g| _| �ttj|� dS )z� Test that L{reactors.installReactor} raises an exception when asked to install a reactor which doesn't work in this environment. c S s t d��)N�Missing foo bar�� ImportErrorr r r r rL ? � zFPluggableReactorTests.test_installNotAvailableReactor.<locals>.installrX rY N)r rJ rQ r9 r~ r rm rn r r r � test_installNotAvailableReactor9 s z5PluggableReactorTests.test_installNotAvailableReactorc s� g �d� d�G ��fdd�dt jtj�}� �fdd�}t|dtd�g| _|� }|�g d �� | ��d � � | ��� � �d � | �|d d� d S )zx Test that the reactor selected is installed as soon as possible, ie when the option is parsed. zreactor installedzsubcommands loadedc s e Zd Ze� �fdd��ZdS )zQPluggableReactorTests.test_reactorSelectionMixin.<locals>.ReactorSelectionOptionsc s �� �� dd � fdd�dfgS )N� subcommandc s � S r) r r rh r r r� U ru zoPluggableReactorTests.test_reactorSelectionMixin.<locals>.ReactorSelectionOptions.subCommands.<locals>.<lambda>ztest subcommandrb rh ��SUBCOMMAND_EVENT�executedrh r � subCommandsR s z]PluggableReactorTests.test_reactorSelectionMixin.<locals>.ReactorSelectionOptions.subCommandsN)r r r �propertyr� r r� r r �ReactorSelectionOptionsQ s r� c s �� � � d S r) rb r )� INSTALL_EVENTr� r r rL W r� zAPluggableReactorTests.test_reactorSelectionMixin.<locals>.installrX re �z --reactorrX r� r rN r N) r �Optionsr �ReactorSelectionMixinrJ r rQ � parseOptionsr# �count)r& r� rL �optionsr )r� r� r� r �test_reactorSelectionMixinH s �z0PluggableReactorTests.test_reactorSelectionMixinc C sh G dd� dt jtj�}g | _|� }t� |_| �t j|j g d��}| � d|j d � | � d|j d � dS )z� Test that the usage mixin exits when trying to use a non existent reactor (the name not matching to any reactor), giving an error message. c @ � e Zd ZdS )z\PluggableReactorTests.test_reactorSelectionMixinNonExistent.<locals>.ReactorSelectionOptionsN�r r r r r r r r� k � r� r� rX r � help-reactorsN) r r� r r� rQ r � messageOutputr9 � UsageErrorr� �assertInr� )r& r� r� �er r r �%test_reactorSelectionMixinNonExistentd s �z;PluggableReactorTests.test_reactorSelectionMixinNonExistentc s� G dd� dt jtj�}d� � fdd�}d}t}d}t||||�g| _|� }t� |_| � t j |j g d��}| � � |j d � | � d |j d � d S ) z� Test that the usage mixin exits when trying to use a reactor not available (the reactor raises an error at installation), giving an error message. c @ r� )z]PluggableReactorTests.test_reactorSelectionMixinNotAvailable.<locals>.ReactorSelectionOptionsNr� r r r r r� � r� r� r| c s t � ��r) r} r ��messager r rL � r zMPluggableReactorTests.test_reactorSelectionMixinNotAvailable.<locals>.installrX rY r� r r� N)r r� r r� r rJ rQ r r� r9 r� r� r� r� )r& r� rL r$ rW rY r� r� r r� r �&test_reactorSelectionMixinNotAvailablez s �z<PluggableReactorTests.test_reactorSelectionMixinNotAvailabler) )r r r rN rU r5 rT r` rk ro rt rx r{ r� r� r� r� r r r r rO � s rO c @ sr e Zd ZdZdd� Zeed�dd� �Zee d�dd � �Zee d kd �d d � �Z ee d kd�dd� �Z dd� Z dS )�HelpReactorsTestsz6 --help-reactors lists the available reactors c C s6 t �� | _t� | j_| �t| jj� | jj�� | _ dS )z3 Get the text from --help-reactors N) r r� r� r r� r9 � SystemExit�opt_help_reactors�getvaluer� rh r r r rU � s zHelpReactorsTests.setUpz$Not applicable, asyncio is availablec C �, | � tjj| j� | � dtjj | j� dS )zX --help-reactors should NOT display the asyncio reactor on Python < 3.4 �!N)r� r �asynciorY r� r\ rh r r r �test_lacksAsyncIO� � z#HelpReactorsTests.test_lacksAsyncIOz asyncio library not availablec C �, | � tjj| j� | �dtjj | j� dS )zU --help-reactors should display the asyncio reactor on Python >= 3.4 r� N)r� r r� rY r� � assertNotInr\ rh r r r �test_hasAsyncIO� r� z!HelpReactorsTests.test_hasAsyncIO�win32z Test only applicable on Windowsc C r� )zL --help-reactors should display the iocp reactor on Windows r� N)r� r �iocprY r� r� r\ rh r r r �test_iocpWin32� r� z HelpReactorsTests.test_iocpWin32z Test not applicable on Windowsc C r� )zP --help-reactors should NOT display the iocp reactor on Windows r� N)r� r r� rY r� r\ rh r r r �test_iocpNotWin32� r� z#HelpReactorsTests.test_iocpNotWin32c C sF dd� }t �� }||_t� |_| �t|j� |j�� }| � d|� dS )z> --help-reactors with only supported reactors c s s � t jV d S r) )r �defaultr r r r rZ � s � zEHelpReactorsTests.test_onlySupportedReactors.<locals>.getReactorTypeszreactors not availableN) r r� �_getReactorTypesr r� r9 r� r� r� r� )r& rZ r� r� r r r �test_onlySupportedReactors� s z,HelpReactorsTests.test_onlySupportedReactorsN) r r r rN rU r r� r� r� r r� r� r� r r r r r� � s r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �BackoffPolicyTestsz@ Tests of L{twisted.application.internet.backoffPolicy} c C sh t ddddd� d�}| �|d�d� | �|d �d � | �|d �d � | �|d �d� | �|d�d� dS )zI Test that L{backoffPolicy()} calculates expected values � �?� N@� �?c S � dS rM r r r r r r� � ru zCBackoffPolicyTests.test_calculates_correct_values.<locals>.<lambda>��jitterr r$ rN g @rH g UM@� �= �d N)r �assertAlmostEqualr# �r& �polr r r � test_calculates_correct_values� s z1BackoffPolicyTests.test_calculates_correct_valuesc C s8 t ddddd� d�}| �|d�d� | �|d �d� d S ) z� L{backoffPolicy()} does not fail for large values of the attempt parameter. In previous versions, this test failed when attempt was larger than 1750. See https://twistedmatrix.com/trac/ticket/9476 r� r� r� c S r� rM r r r r r r� � ru zLBackoffPolicyTests.test_does_not_overflow_on_high_attempts.<locals>.<lambda>r� �� r� i@B N�r r# r� r r r �'test_does_not_overflow_on_high_attempts� s z:BackoffPolicyTests.test_does_not_overflow_on_high_attemptsc C s( t ddddd� d�}| �|d�d� d S ) z� Even with unusual parameters, any L{OverflowError} within L{backoffPolicy()} will be caught and L{maxDelay} will be returned instead r� r� g _�Bc S r� rM r r r r r r� � ru zSBackoffPolicyTests.test_does_not_overflow_with_large_factor_value.<locals>.<lambda>r� r� r� Nr� r� r r r �.test_does_not_overflow_with_large_factor_value� s zABackoffPolicyTests.test_does_not_overflow_with_large_factor_valueN)r r r rN r� r� r� r r r r r� � s r� )ArN rV �osrx �ior r� r~ �unittestr �twisted.applicationr r r r � twisted.application.internetr �twisted.internetr r r r �twisted.persistedr �twisted.pluginsr �twisted.protocolsr r �twisted.pythonr �twisted.python.runtimer �#twisted.python.test.modules_helpersr �twisted.test.proto_helpersr �twisted.trial.unittestr r r r r rX �curuid�getgid�curgidrZ rd rp r~ r� � LineReceiverr� r� r� r� r� r� r1 rK rJ rO r� r� r r r r �<module> s\ � { / < g>