| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/twisted/test/__pycache__/ |
Upload File : |
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>