| 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 : /lib/python3/dist-packages/twisted/test/__pycache__/ |
Upload File : |
o
�b( � @ s� d Z ddlZddlZddlZddlZddlZddlZz
ddlZddl Z
W n
e y1 dZ dZY nw e
Z eZddl m
Z
ddlmZ ddlmZ ddlmZ ddlmZmZmZ ddlmZmZmZ dd l m Z dd
l m Z dd l m!Z! dd l"m#Z#m$Z$ dd
l%m&Z& ddl'm(Z(m)Z)m*Z* ddl+m,Z, ddl-m.Z. ddl/m0Z0 ddl1m(Z2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z; ddl<m=Z= ddl>m?Z? ddl@mAZA e5d�ZBeBr�ddlCmDZDmEZEmFZF e5d �ZGe5d �ZHe5d �ZIe5d �ZJd d!� ZKG d"d#� d#�ZLG d$d%� d%ejM�ZNG d&d'� d'e;jO�ZPG d(d)� d)eA�ZQeeB d*�G d+d,� d,eA��ZRG d-d.� d.eA�ZSG d/d0� d0�ZTG d1d2� d2ejU�ZVG d3d4� d4eA�ZWeeB d*�G d5d6� d6eA��ZXeeB d*�G d7d8� d8eA��ZYeeB d*�G d9d:� d:eA��ZZG d;d<� d<�Z[ee#�G d=d>� d>e[��Z\G d?d@� d@�Z]G dAdB� dBeA�Z^dCdD� Z_dEdF� Z`G dGdH� dHeA�ZaeeB d*�G dIdJ� dJeA��ZbeeB dK�G dLdM� dMeA��Zcee$�G dNdO� dOe=��ZdG dPdQ� dQe;jO�ZedRdS� ZfG dTdU� dUeA�ZgdS )VzE
Tests for L{twisted.application.app} and L{twisted.scripts.twistd}.
� N)�StringIO)�skipIf)� implementer)� verifyObject)�internet�logger�plugin)�app�reactors�service)�
IServiceMaker)� ReactorBase)�Deferred)�IReactorDaemonize� _ISupportsExitSignalCapturing)�AlternateReactor)� ILogObserver�globalLogBeginner�globalLogPublisher)�util)�
Componentized)� UserDatabase)r �textFromEventDict)�
requireModule)� platformType)�
UsageError)�twistd)�
MemoryReactor)�MockOS)�TestCaseztwistd.scripts._twistd_unix)�UnixApplicationRunner�
UnixAppLogger�checkPIDztwistd.python.syslog�profile�pstats�cProfilec s| t �t�� �}t�t�� ��t� }|�||j |� |j
|j |j � � ��fdd�}| t d|j
� | td|� | t d|j� dS )au
Patch L{pwd.getpwnam} so that it behaves as though only one user exists
and patch L{grp.getgrnam} so that it behaves as though only one group
exists.
@param patch: A function like L{TestCase.patch} which will be used to
install the fake implementations.
@type user: C{str}
@param user: The name of the single user which will exist.
@type uid: C{int}
@param uid: The UID of the single user which will exist.
@type group: C{str}
@param group: The name of the single user which will exist.
@type gid: C{int}
@param gid: The GID of the single group which will exist.
c s< t ��}�||��j�< � ||��j�< t|�}�|i| S �N)�list�index�gr_name�gr_gid�tuple)�name�result��gid�grent�group� �:/usr/lib/python3/dist-packages/twisted/test/test_twistd.py�getgrnamd s
z#patchUserDatabase.<locals>.getgrnam�getpwnamr4 �getpwuidN)�pwdr6 �os�getuid�grp�getgrgid�getgidr �addUser� pw_passwd�pw_gecos�pw_dir�pw_shellr5 )�patch�user�uidr1 r/ �pwent�databaser4 r2 r. r3 �patchUserDatabaseC s � rG c @ � e Zd ZdZdZdd� ZdS )�MockServiceMakerzO
A non-implementation of L{twisted.application.service.IServiceMaker}.
�ueoac C s || _ t�� | _| jS )ze
Take a L{usage.Options} instance and return a
L{service.IService} provider.
)�optionsr �Service��selfrK r2 r2 r3 � makeServicew s
z MockServiceMaker.makeServiceN)�__name__�
__module__� __qualname__�__doc__�tapnamerO r2 r2 r2 r3 rI p s rI c @ s e Zd ZdZdd� ZdS )�CrippledAppLoggerz*
@see: CrippledApplicationRunner.
c C � d S r& r2 �rN � applicationr2 r2 r3 �start� � zCrippledAppLogger.startN)rP rQ rR rS rY r2 r2 r2 r3 rU � s rU c @ s$ e Zd ZdZeZdd� Zdd� ZdS )�CrippledApplicationRunnerz�
An application runner that cripples the platform-specific runner and
nasty side-effect-having code so that we can use it without actually
running any environment-affecting code.
c C rV r& r2 �rN r2 r2 r3 �preApplication� rZ z(CrippledApplicationRunner.preApplicationc C rV r& r2 r\ r2 r2 r3 �postApplication� rZ z)CrippledApplicationRunner.postApplicationN)rP rQ rR rS rU �
loggerFactoryr] r^ r2 r2 r2 r3 r[ � s
r[ c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Ze e
d �d
d� �Z e e
d �dd� �Z e e
d �dd� �Z
dd� Zdd� Zdd� Zdd� ZdS ) �ServerOptionsTestszT
Non-platform-specific tests for the platform-specific ServerOptions class.
c s� G dd� d�}|d�� |d��|d��|d��� ����fdd�}t �� }��|jtj� ||_|j}� ���g}t||�D ]&\}}|\}} }
} ��||j� �� | � ��|
� |j
�f ��| |j � q>d S )
zh
subCommands is built from IServiceMaker plugins, and is sorted
alphabetically.
c @ s e Zd Zdd� Zdd� ZdS )z7ServerOptionsTests.test_subCommands.<locals>.FakePluginc S s || _ d| | _d| | _d S )Nz options for �description of )rT �_options� description�rN r, r2 r2 r3 �__init__� s
z@ServerOptionsTests.test_subCommands.<locals>.FakePlugin.__init__c S � | j S r& )rb r\ r2 r2 r3 rK � s z?ServerOptionsTests.test_subCommands.<locals>.FakePlugin.optionsN)rP rQ rR re rK r2 r2 r2 r3 �
FakePlugin� s rg �apple�banana�coconut�donutc 3 s* � �� | t� �V �V �V � V d S r& )� assertEqualr )� interface�rh ri rj rk rN r2 r3 �
getPlugins� s �
z7ServerOptionsTests.test_subCommands.<locals>.getPluginsN) r �
ServerOptionsrl � _getPluginsr ro � subCommands�ziprT � assertIsNonerb rc ) rN rg ro �configrr �
expectedOrder�
subCommand�expectedCommandr, �shortcut� parserClass�
documentationr2 rn r3 �test_subCommands� s$
�z#ServerOptionsTests.test_subCommandsc s� G dd� d�}|d�� |d��|d��|d��� ���fdd�}t �� }��|jtj� ||_t� |_��t |j
d g� |j� � �g �� ���fD ]}���fd
d �}||j � ||j
� qI���t��d ���� d
S )zP
Reactor names are listed alphabetically by I{--help-reactors}.
c @ � e Zd Zdd� ZdS )zGServerOptionsTests.test_sortedReactorHelp.<locals>.FakeReactorInstallerc S s d| | _ d| | _d| _d S )Nzname of ra ztwisted.internet.default)� shortNamerc �
moduleNamerd r2 r2 r3 re � s
zPServerOptionsTests.test_sortedReactorHelp.<locals>.FakeReactorInstaller.__init__N)rP rQ rR re r2 r2 r2 r3 �FakeReactorInstaller� � r� rh ri rj rk c 3 s � �V �V �V � V d S r& r2 r2 )rh ri rj rk r2 r3 �getReactorTypes� s
�
zBServerOptionsTests.test_sortedReactorHelp.<locals>.getReactorTypesz--help-reactorsc s �� | � � ��� �| �� d S r& )�assertIn�appendr( )�s)�
helpOutput�indexesrN r2 r3 �getIndex� s z;ServerOptionsTests.test_sortedReactorHelp.<locals>.getIndexz9reactor descriptions were not in alphabetical order: {!r}N)r rp rl �_getReactorTypesr
r� r �
messageOutput� assertRaises�
SystemExit� parseOptions�getvaluer~ rc �sorted�format)rN r� r� ru �reactorr� r2 )rh ri rj rk r� r� rN r3 �test_sortedReactorHelp� s0
��z)ServerOptionsTests.test_sortedReactorHelpc C s( t �� }d|_|�� | �|d � dS )zS
postOptions should set no_save to True when a subcommand is used.
rJ �no_saveN)r rp rw � postOptions�
assertTrue�rN ru r2 r2 r3 �&test_postOptionsSubCommandCausesNoSave� s z9ServerOptionsTests.test_postOptionsSubCommandCausesNoSavec C s" t �� }|�� | �|d � dS )zR
If no sub command is used, postOptions should not touch no_save.
r� N)r rp r� � assertFalser� r2 r2 r3 �(test_postOptionsNoSubCommandSavesAsUsual s z;ServerOptionsTests.test_postOptionsNoSubCommandSavesAsUsualc C s. t �� }t|�}tjjD ]}| �||� q dS )zq
All the profilers that can be used in L{app.AppProfiler} are listed in
the help output.
N)r rp �strr � AppProfiler� profilersr� )rN ru r� �profilerr2 r2 r3 �test_listAllProfilers
s
�z(ServerOptionsTests.test_listAllProfilers�twistd unix not availablec C s t �� }| �|d � dS )zG
The default value for the C{umask} option is L{None}.
�umaskN)r rp rt r� r2 r2 r3 �test_defaultUmask s z$ServerOptionsTests.test_defaultUmaskc C sH t �� }|�ddg� | �|d d� |�ddg� | �|d d� dS )zh
The value given for the C{umask} option is parsed as an octal integer
literal.
�--umask�123r� �S �0123N)r rp r� rl r� r2 r2 r3 �
test_umask s
z ServerOptionsTests.test_umaskc C s t �� }| �t|jddg� dS )z�
If a value is given for the C{umask} option which cannot be parsed as
an integer, L{UsageError} is raised by L{ServerOptions.parseOptions}.
r� �abcdefN)r rp r� r r� r� r2 r2 r3 �test_invalidUmask( s z$ServerOptionsTests.test_invalidUmaskc C �H t �� }| �t|jddg�}| �|jd �d�� | �d|jd � dS )zQ
C{--logger} with an unimportable module raises a L{UsageError}.
�--loggerzno.such.module.I.hoper zeLogger 'no.such.module.I.hope' could not be imported: 'no.such.module.I.hope' does not name an object�
N� r rp r� r r� r� �args�
startswith� assertNotIn�rN ru �er2 r2 r3 �&test_unimportableConfiguredLogObserver1 s �
��z9ServerOptionsTests.test_unimportableConfiguredLogObserverc C r� )zP
C{--logger} with a non-existent object raises a L{UsageError}.
r� z twisted.test.test_twistd.FOOBARr z{Logger 'twisted.test.test_twistd.FOOBAR' could not be imported: module 'twisted.test.test_twistd' has no attribute 'FOOBAR'r� Nr� r� r2 r2 r3 �*test_badAttributeWithConfiguredLogObserverA s �
��z=ServerOptionsTests.test_badAttributeWithConfiguredLogObserverc C sv ddl m} tdkr
d}nd}d�||j|j�}t� }tj|d�}| �t |j
dg�}| � |j d � | �
|�� |� d S )
z2
C{--version} prints the version.
r )� copyright�win32z (the Twisted Windows runner)z(the Twisted daemon)ztwistd {} {}
{}
��stdoutz --versionN)�twistedr� r r� �versionr r rp r� r� r� �assertIs�coderl r� )rN r� r, �expectedOutputr� ru r� r2 r2 r3 � test_versionT s
� z ServerOptionsTests.test_versionc C s( t � }tj|d�}| �t|jdg� dS )zI
Command is printed when an invalid option is requested.
r� z web --fooN)r r rp r� r r� )rN r� ru r2 r2 r3 �!test_printSubCommandForUsageErrorh s z4ServerOptionsTests.test_printSubCommandForUsageErrorN)rP rQ rR rS r| r� r� r� r� r � _twistd_unixr� r� r� r� r� r� r� r2 r2 r2 r3 r` � s" +/
r` r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�
CheckPIDTestsz
Tests for L{checkPID}.
c C s | � tjddd� � td� dS )z7
Nonexistent PID file is not an error.
�existsc S � dS �NFr2 )�_r2 r2 r3 �<lambda>| � z.CheckPIDTests.test_notExists.<locals>.<lambda>znon-existent PID fileN)rB r8 �pathr" r\ r2 r2 r3 �test_notExistsx s z CheckPIDTests.test_notExistsc C s\ | � � }t|d��
}|�d� W d � n1 sw Y | �tt|�}| �d|j� dS )zI
Non-numeric content in a PID file causes a system exit.
�wz non-numericNznon-numeric value)�mktemp�open�writer� r� r" r� r� )rN �pidfile�fr� r2 r2 r3 �test_nonNumeric s �z CheckPIDTests.test_nonNumericc C sr | � � }t|d��
}|�d� W d � n1 sw Y dd� }| �td|� | �tt|�}| �d|j � dS )zE
Another running twistd server causes a system exit.
r� �42Nc S rV r& r2 ��pid�sigr2 r2 r3 �kill� rZ z/CheckPIDTests.test_anotherRunning.<locals>.killr� zAnother twistd server)
r� r� r� rB r8 r� r� r" r� r� �rN r� r� r� r� r2 r2 r3 �test_anotherRunning� s �z!CheckPIDTests.test_anotherRunningc C s| | � � }t|d��}|�tt�� d �� W d � n1 s w Y dd� }| �td|� t|� | �tj �
|�� dS )zJ
Stale PID file is removed without causing a system exit.
r� � Nc S � t tjd���N�fake)�OSError�errno�ESRCHr� r2 r2 r3 r� � � z&CheckPIDTests.test_stale.<locals>.killr� ) r� r� r� r� r8 �getpidrB r" r� r� r� )rN r� r� r� r2 r2 r3 �
test_stale� s �zCheckPIDTests.test_stalec C s� | � � }t|d��
}|�d� W d � n1 sw Y dd� }| �td|� | �tt|�}| �|j d� | �
|j d � d�� dS ) z�
An unexpected L{OSError} when checking the validity of a
PID in a C{pidfile} terminates the process via L{SystemExit}.
r� �3581Nc S r� r� �r� r� �EBADFr� r2 r2 r3 r� � r� z2CheckPIDTests.test_unexpectedOSError.<locals>.killr� r zCan't check status of PID)
r� r� r� rB r8 r� r� r" � assertIsNotr� r� r� r� r� r2 r2 r3 �test_unexpectedOSError� s �z$CheckPIDTests.test_unexpectedOSErrorN) rP rQ rR rS r� r� r� r� r� r2 r2 r2 r3 r� r s
r� c @ � e Zd ZdZdd� Zdd� ZdS )� TapFileTestszM
Test twistd-related functionality that requires a tap file on disk.
c C sN | � � | _t| jd��}t�t�d�|� W d � dS 1 s w Y dS )zP
Create a trivial Application and put it in a tap file on disk.
�wb�Hi!N)r� �tapfiler� �pickle�dumpr � Application)rN r� r2 r2 r3 �setUp� s
"�zTapFileTests.setUpc C s< t �� }|�d| jg� t|��� }| �t�|�j d� dS )z�
Ensure that the createOrGetApplication call that 'twistd -f foo.tap'
makes will load the Application out of foo.tap.
z-fr� N)
r rp r� r� r[ �createOrGetApplicationrl r �IServicer, )rN ru rX r2 r2 r3 �&test_createOrGetApplicationWithTapFile� s z3TapFileTests.test_createOrGetApplicationWithTapFileN)rP rQ rR rS r� r� r2 r2 r2 r3 r� � s r� c @ �( e Zd ZdZdd� Zdd� Zdd� ZdS ) �TestLoggerFactoryz8
A logger factory for L{TestApplicationRunner}.
c C �
|| _ d S r& )�runner)rN r� r2 r2 r3 re � �
zTestLoggerFactory.__init__c C s" | j j�d� t| j d�| j _dS )zC
Save the logging start on the C{runner} instance.
�logrX N)r� �orderr� �hasattr�hadApplicationLogObserverrW r2 r2 r3 rY � s zTestLoggerFactory.startc C r� )z%
Don't log anything.
Nr2 r\ r2 r2 r3 �stop� r� zTestLoggerFactory.stopN)rP rQ rR rS re rY r� r2 r2 r2 r3 r� � s
r� c @ r� ) �TestApplicationRunnerz`
An ApplicationRunner which tracks the environment in which its methods are
called.
c C s" t j�| |� g | _t| �| _d S r& )r �ApplicationRunnerre r� r� r rM r2 r2 r3 re � s z TestApplicationRunner.__init__c C � | j �d� t| d�| _d S )N�prerX )r� r� r� � hadApplicationPreApplicationr\ r2 r2 r3 r] � � z$TestApplicationRunner.preApplicationc C r� )N�postrX )r� r� r� � hadApplicationPostApplicationr\ r2 r2 r3 r^ � r z%TestApplicationRunner.postApplicationN)rP rQ rR rS re r] r^ r2 r2 r2 r3 r� � s
r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zee e
d
d � d �d
d� �Z ee e
d
d � d �dd� �Z dd� Z
dd� Zdd� Zdd� Zd S )�ApplicationRunnerTestszR
Non-platform-specific tests for the platform-specific ApplicationRunner.
c C s4 t �� }t� | _d| ji|_t� |_d|_|| _d S )N� test_command) r rp rI � serviceMaker�
loadedPlugins�object�
subOptionsrw ru r� r2 r2 r3 r� � s
z ApplicationRunnerTests.setUpc C sL t | j�}|�� | �| jj| jjd� | �| jjt�|j �j
d d� dS )z�
Ensure that a twistd plugin gets used in appropriate ways: it
is passed its Options instance, and the service it returns is
added to the application.
zKServiceMaker.makeService needs to be passed the correct sub Command object.r zPServiceMaker.makeService's result needs to be set as a child of the Application.N) r[ ru �runr� r rK r r r� rX �services)rN �arunnerr2 r2 r3 �,test_applicationRunnerGetsCorrectApplication s
��zCApplicationRunnerTests.test_applicationRunnerGetsCorrectApplicationc C sL t | j�}|�� | �|j� | �|j� | �|j� | �|j g d�� dS )z�
Test thet preApplication and postApplication methods are
called by ApplicationRunner.run() when appropriate.
)r� r� r N)
r� ru r
r� r r� r r� rl r� )rN r� r2 r2 r3 �test_preAndPostApplication s
z1ApplicationRunnerTests.test_preAndPostApplicationc s� | j �|� g � G � fdd�dtj�}ttjtj�G � fdd�d��}|� }ttj|� ttj|� || j �}|� � ||_
|� � | � � dddd||fd d
g� d S ) a.
Assert that given a particular command line, an application is started
as a particular UID/GID.
@param argv: A list of strings giving the options to parse.
@param uid: An integer giving the expected UID.
@param gid: An integer giving the expected GID.
c s8 e Zd Z� fdd�Z� fdd�Z� fdd�Zdd� Zd S )
z\ApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunnerc � � � d� d S )N� environment�r� �rN �chroot�rundir�nodaemonr� r� ��eventsr2 r3 �setupEnvironment8 � zmApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.setupEnvironmentc s � � d|||f� d S )N�
privilegesr )rN �euidrD r/ r r2 r3 �shedPrivileges; s zkApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.shedPrivilegesc r )Nr� r )rN r� � oldstdout� oldstderrr r2 r3 � startReactor> r ziApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.startReactorc S rV r& r2 )rN r� r2 r2 r3 � removePIDA rZ zfApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.removePIDN)rP rQ rR r r r r r2 r r2 r3 �FakeUnixApplicationRunner7 s
r! c s\ e Zd ZdZdZdZdZdZdZdd� Z dd� Z
dd� Z � fdd �Z � fd
d �Z
d d
� ZdS )zNApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeServiceNc S rV r& r2 rd r2 r2 r3 �setNameN rZ zVApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.setNamec S rV r& r2 )rN �parentr2 r2 r3 �setServiceParentQ rZ z_ApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.setServiceParentc S rV r& r2 r\ r2 r2 r3 �disownServiceParentT rZ zbApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.disownServiceParentc r )N�privilegedStartServicer r\ r r2 r3 r& W r zeApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.privilegedStartServicec r )N� startServicer r\ r r2 r3 r' Z r z[ApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.startServicec S rV r& r2 r\ r2 r2 r3 � stopService] rZ zZApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.stopService)rP rQ rR r# �runningr, � processNamerD r/ r" r$ r% r& r' r( r2 r r2 r3 � FakeServiceD s r+ r r& r Fr' r� N)
ru r� r �_SomeApplicationRunnerr r r� �IProcessr r] rX r^ rl )rN �argvrD r/ r! r+ rX r� r2 r r3 �"_applicationStartsWithConfiguredID* s*
��z9ApplicationRunnerTests._applicationStartsWithConfiguredID�setuidNz5Platform does not support --uid/--gid twistd options.c C s* d}d}| � dt|�dt|�g||� dS )a
L{postApplication} should change the UID and GID to the values
specified as numeric strings by the configuration after running
L{service.IService.privilegedStartService} and before running
L{service.IService.startService}.
�� �� �--uid�--gidN)r/ r� )rN rD r/ r2 r2 r3 �.test_applicationStartsWithConfiguredNumericIDst s
�zEApplicationRunnerTests.test_applicationStartsWithConfiguredNumericIDsc C s< d}d}d}d}t | j||||� | �d|d|g||� dS )a
L{postApplication} should change the UID and GID to the values
specified as user and group names by the configuration after running
L{service.IService.privilegedStartService} and before running
L{service.IService.startService}.
�foor1 �barr2 r3 r4 N)rG rB r/ )rN rC rD r1 r/ r2 r2 r3 �+test_applicationStartsWithConfiguredNameIDs� s �zBApplicationRunnerTests.test_applicationStartsWithConfiguredNameIDsc C s8 t � }t�dddd��}|�|dd� | �|jd� dS )z7
L{startReactor} calls L{reactor.run}.
Fr# �r# r� �debugNz'startReactor did not call reactor.run())� DummyReactorr r� r r� �called�rN r� r� r2 r2 r3 � test_startReactorRunsTheReactor� s
�z6ApplicationRunnerTests.test_startReactorRunsTheReactorc C sD t � }| �td|� t�dddd��}|�ddd� | �|j� dS )zN
L{ApplicationRunner} chooses a reactor if none is specified.
r� Fr# r9 N)r; rB r r r� r r� r< r= r2 r2 r3 �*test_applicationRunnerChoosesReactorIfNone� s
�zAApplicationRunnerTests.test_applicationRunnerChoosesReactorIfNonec C sH G dd� dt �}|� }t�dddd��}|�|dd� | �d|j� dS )zg
If the reactor exits with a signal, the application runner caches
the signal.
c @ r� )z[ApplicationRunnerTests.test_applicationRunnerCapturesSignal.<locals>.DummyReactorWithSignal��
A dummy reactor, providing a C{run} method, and setting the
_exitSignal attribute to a nonzero value.
c S r� �z=
Dummy method, does nothing.
Nr2 r\ r2 r2 r3 � installWaker� r� zhApplicationRunnerTests.test_applicationRunnerCapturesSignal.<locals>.DummyReactorWithSignal.installWakerc S �
d| _ dS )zZ
A fake run method setting _exitSignal to a nonzero value
� N�� _exitSignalr\ r2 r2 r3 r
� s
z_ApplicationRunnerTests.test_applicationRunnerCapturesSignal.<locals>.DummyReactorWithSignal.runN�rP rQ rR rS rB r
r2 r2 r2 r3 �DummyReactorWithSignal� � rH Fr# r9 NrD )r
r r� r � assertEqualsrF )rN rH r� r� r2 r2 r3 �$test_applicationRunnerCapturesSignal� s
�z;ApplicationRunnerTests.test_applicationRunnerCapturesSignalc C sF G dd� d�}|� }t �dddd��}|�|dd� | �d|j� dS )z�
The runner sets its _exitSignal instance attribute to None if
the reactor does not implement L{_ISupportsExitSignalCapturing}.
c @ r� )ziApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal.<locals>.DummyReactorWithExitSignalAttributer@ c S r� rA r2 r\ r2 r2 r3 rB � r� zvApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal.<locals>.DummyReactorWithExitSignalAttribute.installWakerc S rC )z�
A fake run method setting _exitSignal to a nonzero value
that should be ignored.
rD NrE r\ r2 r2 r3 r
� s
zmApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal.<locals>.DummyReactorWithExitSignalAttribute.runNrG r2 r2 r2 r3 �#DummyReactorWithExitSignalAttribute� rI rL Fr# r9 N)r r� r rJ rF )rN rL r� r� r2 r2 r3 �%test_applicationRunnerIgnoresNoSignal� s
�z<ApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal)rP rQ rR rS r� r
r r/ r �getattrr8 r5 r8 r> r? rK rM r2 r2 r2 r3 r � s( J �
�
r c @ sv e Zd ZdZe� Zdd� Zdd� Zdd� Zdd � Z d
d � Z
d d
� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� ZdS )�*UnixApplicationRunnerSetupEnvironmentTestsa�
Tests for L{UnixApplicationRunner.setupEnvironment}.
@ivar root: The root of the filesystem, or C{unset} if none has been
specified with a call to L{os.chroot} (patched for this TestCase with
L{UnixApplicationRunnerSetupEnvironmentTests.chroot}).
@ivar cwd: The current working directory of the process, or C{unset} if
none has been specified with a call to L{os.chdir} (patched for this
TestCase with L{UnixApplicationRunnerSetupEnvironmentTests.chdir}).
@ivar mask: The current file creation mask of the process, or C{unset} if
none has been specified with a call to L{os.umask} (patched for this
TestCase with L{UnixApplicationRunnerSetupEnvironmentTests.umask}).
@ivar daemon: A boolean indicating whether daemonization has been performed
by a call to L{_twistd_unix.daemonize} (patched for this TestCase with
L{UnixApplicationRunnerSetupEnvironmentTests}.
c s� � j � _� j � _� j � _d� _t�� � _� �td� fdd�� � �td� fdd�� � �td� fdd�� t t
� � �� _ � j
� j _
d S ) NFr c � t � d| �S )N�root��setattr�r� r\ r2 r3 r� � zBUnixApplicationRunnerSetupEnvironmentTests.setUp.<locals>.<lambda>�chdirc rP )N�cwdrR rT r\ r2 r3 r�
rU r� c rP )N�maskrR )rX r\ r2 r3 r� rU )�unsetrQ rW rX �daemonr8 r� r� rB r r rp r� � daemonizer\ r2 r\ r3 r� s
z0UnixApplicationRunnerSetupEnvironmentTests.setUpc s d� _ � �td� fdd�� dS )z�
Indicate that daemonization has happened and change the PID so that the
value written to the pidfile can be tested in the daemonization case.
Tr� c s
� j d S �Nr� )r� r2 r\ r2 r3 r� s
zFUnixApplicationRunnerSetupEnvironmentTests.daemonize.<locals>.<lambda>N)rZ rB r8 �rN r� r2 r\ r3 r[ s z4UnixApplicationRunnerSetupEnvironmentTests.daemonizec C s& | j �ddddd� | �| jd� dS )z�
L{UnixApplicationRunner.setupEnvironment} changes the root of the
filesystem if passed a non-L{None} value for the C{chroot} parameter.
�/foo/bar�.TN)r� r rl rQ r\ r2 r2 r3 � test_chroot � z6UnixApplicationRunnerSetupEnvironmentTests.test_chrootc C �( | j �ddddd� | �| j| j� dS )z�
L{UnixApplicationRunner.setupEnvironment} does not change the root of
the filesystem if passed L{None} for the C{chroot} parameter.
Nr_ T)r� r r� rQ rY r\ r2 r2 r3 �
test_noChroot" s z8UnixApplicationRunnerSetupEnvironmentTests.test_noChrootc C s& | j �ddddd� | �| jd� dS )z�
L{UnixApplicationRunner.setupEnvironment} changes the working directory
of the process to the path given for the C{rundir} parameter.
Nr^ T)r� r rl rW r\ r2 r2 r3 �test_changeWorkingDirectory* ra zFUnixApplicationRunnerSetupEnvironmentTests.test_changeWorkingDirectoryc C sN t t� �� | j�ddddd� W d � n1 sw Y | �| j� dS )z�
L{UnixApplicationRunner.setupEnvironment} daemonizes the process if
C{False} is passed for the C{nodaemon} parameter.
Nr_ F)r �FakeDaemonizingReactorr� r r� rZ r\ r2 r2 r3 �test_daemonize2 s �z9UnixApplicationRunnerSetupEnvironmentTests.test_daemonizec C s$ | j �ddddd� | �| j� dS )z�
L{UnixApplicationRunner.setupEnvironment} does not daemonize the
process if C{True} is passed for the C{nodaemon} parameter.
Nr_ T)r� r r� rZ r\ r2 r2 r3 �test_noDaemonize; s z;UnixApplicationRunnerSetupEnvironmentTests.test_noDaemonizec C sd | � � }| j�dddd|� t|d��}t|�� �}W d � n1 s$w Y | �|| j� dS )z�
L{UnixApplicationRunner.setupEnvironment} writes the process's PID to
the file specified by the C{pidfile} parameter.
Nr_ T�rb)r� r� r r� �int�readrl r� �rN r� r� r� r2 r2 r3 �test_nonDaemonPIDFileC s �z@UnixApplicationRunnerSetupEnvironmentTests.test_nonDaemonPIDFilec C s� | � � }tt� �� | j�dddd|� W d � n1 s w Y t|d��}t|�� �}W d � n1 s9w Y | �|| j d � dS )z�
L{UnixApplicationRunner.setupEnvironment} writes the daemonized
process's PID to the file specified by the C{pidfile} parameter if
C{nodaemon} is C{False}.
Nr_ Frh r� )
r� r re r� r r� ri rj rl r� rk r2 r2 r3 �test_daemonPIDFileN s � �z=UnixApplicationRunnerSetupEnvironmentTests.test_daemonPIDFilec C sP t t� �� | j�ddddd� W d � n1 sw Y | �| jd� dS )z�
L{UnixApplicationRunner.setupEnvironment} changes the process umask to
the value specified by the C{umask} parameter.
Nr_ F�{ �r re r� r rl rX r\ r2 r2 r3 r� [ s �z5UnixApplicationRunnerSetupEnvironmentTests.test_umaskc C rb )z�
L{UnixApplicationRunner.setupEnvironment} doesn't change the process
umask if L{None} is passed for the C{umask} parameter and C{True} is
passed for the C{nodaemon} parameter.
Nr_ T)r� r r� rX rY r\ r2 r2 r3 �test_noDaemonizeNoUmaskd s zBUnixApplicationRunnerSetupEnvironmentTests.test_noDaemonizeNoUmaskc C sP t t� �� | j�ddddd� W d � n1 sw Y | �| jd� dS )z�
L{UnixApplicationRunner.setupEnvironment} changes the process umask to
C{0077} if L{None} is passed for the C{umask} parameter and C{False} is
passed for the C{nodaemon} parameter.
Nr_ F�? ro r\ r2 r2 r3 �test_daemonizedNoUmaskm s �zAUnixApplicationRunnerSetupEnvironmentTests.test_daemonizedNoUmaskN)rP rQ rR rS r rY r� r[ r` rc rd rf rg rl rm r� rp rr r2 r2 r2 r3 rO � s
rO c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�*UnixApplicationRunnerStartApplicationTestsz>
Tests for L{UnixApplicationRunner.startApplication}.
c s� t �� }|�g d�� t�d�}t|�| _g � � fdd�}t�| jj �j
}t�|�j
}|� � }|� d� | �
||� | �td|� | �tddd � � | �td
d d � � | j�|� | �
� g d �� d
S )z�
L{UnixApplicationRunner.startApplication} calls
L{UnixApplicationRunner.setupEnvironment} with the chroot, rundir,
nodaemon, umask, and pidfile parameters from the configuration it is
constructed with.
) �
--nodaemonr� �0070z--chroot� /foo/chrootz--rundir� /foo/rundirz --pidfile� /foo/pidfile�test_setupEnvironmentc s � � |||||f� d S r& )�extendr �r� r2 r3 �fakeSetupEnvironment� s z^UnixApplicationRunnerStartApplicationTests.test_setupEnvironment.<locals>.fakeSetupEnvironmentrN r r c _ rV r& r2 ��a�kwr2 r2 r3 r� � r� zRUnixApplicationRunnerStartApplicationTests.test_setupEnvironment.<locals>.<lambda>�startApplicationc _ rV r& r2 r} r2 r2 r3 r� � r� )rv rw T�8 rx N)r rp r� r r� r r� �inspect� signaturer �
parameters�copy�poprl rB r r� )rN rK rX r| �setupEnvironmentParameters� fakeSetupEnvironmentParametersr2 r{ r3 ry ~ s4 �
����
z@UnixApplicationRunnerStartApplicationTests.test_setupEnvironmentc s4 � fdd�}� � td|� ti �}|�ddd� dS )zf
L{UnixApplicationRunner.shedPrivileges} switches the user ID
of the process.
c s( � � | d� � � |d� � � |d� d S )N�� �6 �# �rl �rD r/ r r\ r2 r3 �
switchUIDPass� s zUUnixApplicationRunnerStartApplicationTests.test_shedPrivileges.<locals>.switchUIDPass� switchUIDr� r� r� N)rB r� r r )rN r� r� r2 r\ r3 �test_shedPrivileges� s z>UnixApplicationRunnerStartApplicationTests.test_shedPrivilegesc C sD dd� }t i �}| �td|� | �t|jddd�}| �|jd� dS )z�
An unexpected L{OSError} when calling
L{twisted.scripts._twistd_unix.shedPrivileges}
terminates the process via L{SystemExit}.
c S r� r� r� r� r2 r2 r3 �
switchUIDFail� r� zZUnixApplicationRunnerStartApplicationTests.test_shedPrivilegesError.<locals>.switchUIDFailr� r� r� Nr� )r rB r� r� r� r rl r� )rN r� r� �excr2 r2 r3 �test_shedPrivilegesError� s
zCUnixApplicationRunnerStartApplicationTests.test_shedPrivilegesErrorc s� t � j|�|�� � ��fdd�}� �fdd�}� �fdd�}� �td|� � �td|� � �td |� t�� }|�d
d t��g� t� d �} t
|�� _ t
|�}
|
� | � d
S )zj
Common code for tests which try to pass the the UID to
L{UnixApplicationRunner}.
c s � � | �� � � |�� d S r& r� )rD r/ �rN � wantedGid� wantedUidr2 r3 �
initgroups� r zFUnixApplicationRunnerStartApplicationTests._setUID.<locals>.initgroupsc � � � | �� d S r& r� )rD )rN r� r2 r3 r0 � � zBUnixApplicationRunnerStartApplicationTests._setUID.<locals>.setuidc r� r& r� )r/ )rN r� r2 r3 �setgid� r� zBUnixApplicationRunnerStartApplicationTests._setUID.<locals>.setgidr� r0 r� rt r3 ry N)
rG rB r r8 r rp r� r� r r� r r� r� ) rN �
wantedUserr� � wantedGroupr� r� r0 r� rK rX r� r2 r� r3 �_setUID� s
z2UnixApplicationRunnerStartApplicationTests._setUIDc C s | � dddd� dS )z�
Starting an application with L{UnixApplicationRunner} configured
with a UID and no GUID will result in the GUID being
set to the default GUID for that UID.
r6 i r7 i� N)r� r\ r2 r2 r3 �test_setUidWithoutGid� s z@UnixApplicationRunnerStartApplicationTests.test_setUidWithoutGidc C sT t �� }| �d|dd� | �� }| �dt|�� d�||�}| �||d d � dS ) zz
If the specified UID is the same as the current UID of the process,
then a warning is displayed.
�morefoo�morebari� r� z\tried to drop privileges and setuid {} but uid is already {}; should we be root? Continuing.r �messageN)r8 r9 r� �
flushWarningsrl �lenr� )rN �
currentUid�
warningsShown�expectedWarningr2 r2 r3 �test_setUidSameAsCurrentUid� s �zFUnixApplicationRunnerStartApplicationTests.test_setUidSameAsCurrentUidN)
rP rQ rR rS ry r� r� r� r� r� r2 r2 r2 r3 rs x s 4 rs c @ r� )�#UnixApplicationRunnerRemovePIDTestsz7
Tests for L{UnixApplicationRunner.removePID}.
c C sV t i �}| �� }t�|� tj�|d�}t|d��� |�|� | � tj�
|�� dS )zp
L{UnixApplicationRunner.removePID} deletes the file the name of
which is passed to it.
zfoo.pidr� N) r r� r8 �makedirsr� �joinr� �closer r� r� )rN r� r� r� r2 r2 r3 �test_removePID s
z2UnixApplicationRunnerRemovePIDTests.test_removePIDc C sF t i �}|�d� | �t�}| �t|�d� | �|d jjtj� dS )zr
Calling L{UnixApplicationRunner.removePID} with a non-existent filename
logs an OSError.
�fakepidr� r N) r r �flushLoggedErrorsr� rl r� �valuer� �ENOENT)rN r� �errorsr2 r2 r3 �test_removePIDErrors s
z8UnixApplicationRunnerRemovePIDTests.test_removePIDErrorsN)rP rQ rR rS r� r� r2 r2 r2 r3 r� s
r� c @ �0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �FakeNonDaemonizingReactora�
A dummy reactor, providing C{beforeDaemonize} and C{afterDaemonize}
methods, but not announcing this, and logging whether the methods have been
called.
@ivar _beforeDaemonizeCalled: if C{beforeDaemonize} has been called or not.
@type _beforeDaemonizeCalled: C{bool}
@ivar _afterDaemonizeCalled: if C{afterDaemonize} has been called or not.
@type _afterDaemonizeCalled: C{bool}
c C s d| _ d| _d S r� )�_beforeDaemonizeCalled�_afterDaemonizeCalledr\ r2 r2 r3 re 0 s
z"FakeNonDaemonizingReactor.__init__c C �
d| _ d S �NT)r� r\ r2 r2 r3 �beforeDaemonize4 r� z)FakeNonDaemonizingReactor.beforeDaemonizec C r� r� )r� r\ r2 r2 r3 �afterDaemonize7 r� z(FakeNonDaemonizingReactor.afterDaemonizec O r� )z*
Skip event registration.
Nr2 )rN r� r r2 r2 r3 �addSystemEventTrigger: r� z/FakeNonDaemonizingReactor.addSystemEventTriggerN)rP rQ rR rS re r� r� r� r2 r2 r2 r3 r� $ s r� c @ s e Zd ZdZdS )re z�
A dummy reactor, providing C{beforeDaemonize} and C{afterDaemonize}
methods, announcing this, and logging whether the methods have been called.
N)rP rQ rR rS r2 r2 r2 r3 re @ s re c @ rH )r; z�
A dummy reactor, only providing a C{run} method and checking that it
has been called.
@ivar called: if C{run} has been called or not.
@type called: C{bool}
Fc C s | j rtd��d| _ dS )zV
A fake run method, checking that it's been called one and only time.
zAlready calledTN)r< � RuntimeErrorr\ r2 r2 r3 r
S s
�DummyReactor.runN)rP rQ rR rS r< r
r2 r2 r2 r3 r; H s r; c @ s� e Zd ZdZee d�dd� �Zdd� Zee d�dd� �Zd d
� Z ee d�d d � �Z
ee d
�dd� �Z ee d
�dd� �Z
dd� Zdd� Zdd� Zdd� ZdS )�AppProfilingTestsz'
Tests for L{app.AppProfiler}.
z profile module not availablec C s� t �� }| �� |d< d|d< t�|�}t� }|�|� | �|j� t |d �� }|�
� }W d � n1 s6w Y | � d|� | � d|� dS )z�
L{app.ProfileRunner.run} should call the C{run} method of the reactor
and save profile data in the specified file.
r# r� Nr� �function calls� r rp r� r r� r; r
r� r< r� rj r� �rN ru r� r� r� �datar2 r2 r3 � test_profilea �
� z AppProfilingTests.test_profilec C sP t � }| �td|�}||�}|�� |�� |�� }| �d|� | �d|� d S )Nr� r� z(run))r rB �sys� print_stats�restorer� r� )rN �
statsClassr# �outr� �statsr� r2 r2 r3 �
_testStatsu s z AppProfilingTests._testStatsc C s` t �� }| �� |d< d|d< d|d< t�|�}t� }|�|� | �|j� | � t
j |d � dS )z�
With the C{savestats} option specified, L{app.ProfileRunner.run}
should save the raw stats object instead of a summary output.
r# r� T� savestatsN� r rp r� r r� r; r
r� r< r� r$ �Stats�rN ru r� r� r2 r2 r3 �test_profileSaveStats� s
z'AppProfilingTests.test_profileSaveStatsc C st t j�� }t�� }d|d< t�|�}dt jd< z| �t|j d� W t j�
� t j� |� dS t j�
� t j� |� w )z�
When the C{profile} module is not present, L{app.ProfilerRunner.run}
should raise a C{SystemExit} exception.
r# r� N� r� �modulesr� r rp r r� r� r� r
�clear�update�rN � savedModulesru r� r2 r2 r3 �test_withoutProfile� s
�z%AppProfilingTests.test_withoutProfilec C st G dd� dt j�}| �t d|� t�� }| �� |d< d|d< t�|�}t� }t j
}| � t |j
|� | �t j
|� dS )z�
When an error happens during the print of the stats, C{sys.stdout}
should be restored to its initial value.
c @ r} )zGAppProfilingTests.test_profilePrintStatsError.<locals>.ErroneousProfilec S s t d��)N�Boom�r� r\ r2 r2 r3 r� � � zSAppProfilingTests.test_profilePrintStatsError.<locals>.ErroneousProfile.print_statsN)rP rQ rR r� r2 r2 r2 r3 �ErroneousProfile� r� r� �Profiler# r� N)r# r� rB r rp r� r r� r; r� r� r� r� r
r� )rN r� ru r� r� � oldStdoutr2 r2 r3 �test_profilePrintStatsError� s
z-AppProfilingTests.test_profilePrintStatsErrorz cProfile module not availablec C s� t �� }| �� |d< d|d< t�|�}t� }|�|� | �|j� t |d �� }|�
� }W d � n1 s6w Y | � d|� | � d|� dS )z�
L{app.CProfileRunner.run} should call the C{run} method of the
reactor and save profile data in the specified file.
r# r% r� Nr
r� r� r� r2 r2 r3 �
test_cProfile� r� z AppProfilingTests.test_cProfilec C s` t �� }| �� |d< d|d< d|d< t�|�}t� }|�|� | �|j� | � t
j |d � dS )z�
With the C{savestats} option specified,
L{app.CProfileRunner.run} should save the raw stats object
instead of a summary output.
r# r% r� Tr� Nr� r� r2 r2 r3 �test_cProfileSaveStats� s
z(AppProfilingTests.test_cProfileSaveStatsc C st t j�� }dt jd< t�� }d|d< t�|�}z| �t|j d� W t j�
� t j� |� dS t j�
� t j� |� w )z�
When the C{cProfile} module is not present,
L{app.CProfileRunner.run} should raise a C{SystemExit}
exception and log the C{ImportError}.
Nr% r� r� r� r2 r2 r3 �test_withoutCProfile� s
�z&AppProfilingTests.test_withoutCProfilec C s@ t �� }| �� |d< d|d< | �ttj|�}| �t|�d� dS )zq
Check that L{app.AppProfiler} raises L{SystemExit} when given an
unknown profiler name.
r# �foobarr� z!Unsupported profiler name: foobarN) r rp r� r� r� r r� rl r� )rN ru �errorr2 r2 r3 �test_unknownProfiler� s
z&AppProfilingTests.test_unknownProfilerc C s t �i �}| �|jd� dS )zU
L{app.Profiler} defaults to the cprofile profiler if not specified.
�cprofileN�r r� rl r� �rN r� r2 r2 r3 �test_defaultProfiler s
z&AppProfilingTests.test_defaultProfilerc C s t �ddi�}| �|jd� dS )ze
The case of the profiler name passed to L{app.AppProfiler} is not
relevant.
r� �CprOfiler� Nr� r� r2 r2 r3 � test_profilerNameCaseInsentive
s z0AppProfilingTests.test_profilerNameCaseInsentiveN)rP rQ rR rS r r# r� r� r� r� r� r% r� r� r� r� r� r� r2 r2 r2 r3 r� \ s$
r� c s( g � t j�� �fdd�}| t d|� � S )a
Patch L{logger.textFileLogObserver} to record every call and keep a
reference to the passed log file for tests.
@param patch: a callback for patching (usually L{TestCase.patch}).
@return: the list that keeps track of the log files.
@rtype: C{list}
c s � � | � �| g|�R i |��S r& r )�logFiler� �kwargs��logFiles�oldFileLogObserverr2 r3 �observer# s
z+_patchTextFileLogObserver.<locals>.observer�textFileLogObserver)r r� )rB r� r2 r� r3 �_patchTextFileLogObserver s
r� c s( g � G � fdd�d�}| � td|� � S )zu
Make fake syslog, and return list to which prefix and then log
messages will be appended if it is used.
c s$ e Zd Z� fdd�Z� fdd�ZdS )z(_setupSyslog.<locals>.fakesyslogobserverc � � � |� d S r& r )rN �prefix�� logMessagesr2 r3 re 3 r z1_setupSyslog.<locals>.fakesyslogobserver.__init__c r� r& r )rN � eventDictr� r2 r3 �emit6 r z-_setupSyslog.<locals>.fakesyslogobserver.emitN)rP rQ rR re r� r2 r� r2 r3 �fakesyslogobserver2 s r� �SyslogObserver)rB �syslog)�testCaser� r2 r� r3 � _setupSyslog+ s r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z i e
j fdd�Z dd� Z
dd� Zdd� Zdd� Zee d�ee d�dd� ��Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(S ))�AppLoggerTestsz�
Tests for L{app.AppLogger}.
@ivar observers: list of observers installed during the tests.
@type observers: C{list}
c �$ g � _ � fdd�}� �td|� dS )z�
Override L{globaLogBeginner.beginLoggingTo} so that we can trace the
observers installed in C{self.observers}.
c s$ | D ]
}� j �|� t�|� qd S r& )� observersr� r � addObserver)r r� r\ r2 r3 �beginLoggingToL s �z,AppLoggerTests.setUp.<locals>.beginLoggingTor N)r rB r )rN r r2 r\ r3 r� E s zAppLoggerTests.setUpc C s | j D ]}t�|� qdS )z1
Remove all installed observers.
N)r r �removeObserver�rN r� r2 r2 r3 �tearDownS s
�zAppLoggerTests.tearDownc C s t t�G dd� d��}|� S )z�
Make a new observer which captures all logs sent to it.
@return: An observer that stores all logs sent to it.
@rtype: Callable that implements L{ILogObserver}.
c @ s e Zd Zg Zdd� ZdS )z2AppLoggerTests._makeObserver.<locals>.TestObserverc S s | j �|� d S r& )�_logsr� )rN �eventr2 r2 r3 �__call__f r� z;AppLoggerTests._makeObserver.<locals>.TestObserver.__call__N)rP rQ rR r r r2 r2 r2 r3 � TestObserverb s r )r r )rN r r2 r2 r3 �
_makeObserverZ s z AppLoggerTests._makeObserverc C s@ | � | j|g� | �d|jd d � | �d|jd d � dS )z�
Ensure that initial C{twistd} logs are written to logs.
@param observer: The observer made by L{self._makeObserver).
� starting upr �
log_formatz
reactor classr� N)rl r r� r r r2 r2 r3 �_checkObserverk s z AppLoggerTests._checkObserverc s: t �i �}| �� � � fdd�|_|�t� � | �� � dS )z�
L{app.AppLogger.start} calls L{globalLogBeginner.addObserver}, and then
writes some messages about twistd and the reactor.
c � � S r& r2 r2 �r� r2 r3 r� | r� z+AppLoggerTests.test_start.<locals>.<lambda>N)r � AppLoggerr
�_getLogObserverrY r r
)rN r r2 r r3 �
test_startu s
zAppLoggerTests.test_startc C s< t � }| �� }|�t|� t�i �}|�|� | �|� dS )z�
When the L{ILogObserver} component is available on the application,
that object will be used as the log observer instead of constructing a
new one.
N)r r
� setComponentr r r rY r
)rN rX r� r r2 r2 r3 �$test_startUsesApplicationLogObserver� s
z3AppLoggerTests.test_startUsesApplicationLogObserverc s8 | � � � d� fdd�i}|�|� ||�}|�|� � S )a
Set up an AppLogger which exercises the C{logger} configuration option.
@type application: L{Componentized}
@param application: The L{Application} object to pass to
L{app.AppLogger.start}.
@type extraLogArgs: C{dict}
@param extraLogArgs: extra values to pass to AppLogger.
@type appLogger: L{AppLogger} class, or a subclass
@param appLogger: factory for L{AppLogger} instances.
@rtype: C{list}
@return: The logs accumulated by the log observer.
r c r r& r2 r2 r r2 r3 r� � r� z7AppLoggerTests._setupConfiguredLogger.<locals>.<lambda>)r
r� rY )rN rX � extraLogArgs� appLogger�logArgsr r2 r r3 �_setupConfiguredLogger� s
z%AppLoggerTests._setupConfiguredLoggerc C s t � }| �| �|�� dS )a
When the C{logger} key is specified in the configuration dictionary
(i.e., when C{--logger} is passed to twistd), the initial log observer
will be the log observer returned from the callable which the value
refers to in FQPN form.
N)r r
r rW r2 r2 r3 �#test_startUsesConfiguredLogObserver� s z2AppLoggerTests.test_startUsesConfiguredLogObserverc C s< | � � }t� }|�t|� | �| �|�� | �|jg � dS )zk
C{--logger} takes precedence over a L{ILogObserver} component set on
Application.
N)r
r r r r
r rl r )rN r� rX r2 r2 r3 �(test_configuredLogObserverBeatsComponent� s
z7AppLoggerTests.test_configuredLogObserverBeatsComponentc C s8 g }t � }|�t|j� | �| �|�� | �|g � dS )zq
C{--logger} takes precedence over a L{LegacyILogObserver} component
set on Application.
N)r r �LegacyILogObserverr� r
r rl )rN �nonlogsrX r2 r2 r3 �.test_configuredLogObserverBeatsLegacyComponent� s
z=AppLoggerTests.test_configuredLogObserverBeatsLegacyComponentc C sZ g }| � � }t� }|�t|� |�t|j� t�i �}|�|� | � |� | �
|g � dS )zw
A L{ILogObserver} takes precedence over a L{LegacyILogObserver}
component set on Application.
N) r
r r r r r� r r rY r
rl )rN r r� rX r r2 r2 r3 �.test_loggerComponentBeatsLegacyLoggerComponent� s
z=AppLoggerTests.test_loggerComponentBeatsLegacyLoggerComponentr� zsyslog not availablec C s6 t | �}t� }| �| �|ddit�� | �|g � dS )z`
C{--logger} takes precedence over a C{--syslog} command line
argument.
r� TN)r� r r
r r! rl )rN �logsrX r2 r2 r3 �%test_configuredLogObserverBeatsSyslog� s �z4AppLoggerTests.test_configuredLogObserverBeatsSyslogc C s: t � }| �� }| �| �|ddi�� | �tj�|�� dS )za
C{--logger} takes precedence over a C{--logfile} command line
argument.
�logfiler� N)r r� r
r r� r8 r� r� )rN rX r� r2 r2 r3 �&test_configuredLogObserverBeatsLogfile� s �z5AppLoggerTests.test_configuredLogObserverBeatsLogfilec C s~ t �ddi�}t| j�}|�� | �t|�d� | �|d tj � t �ddi�}|�� | �t|�d� | �|d tj � dS )z�
When logfile is empty or set to C{-}, L{app.AppLogger._getLogObserver}
returns a log observer pointing at C{sys.stdout}.
r! �-r� r � rD N)
r r r� rB r rl r� r� r� r� )rN r r� r2 r2 r3 �test_getLogObserverStdout� s
z(AppLoggerTests.test_getLogObserverStdoutc C sd t | j�}| �� }t�d|i�}|�� }| �|jj� | � t
|�d� | � |d j t j �
|�� dS )z�
When passing the C{logfile} option, L{app.AppLogger._getLogObserver}
returns a log observer pointing at the specified path.
r! r� r N)r� rB r� r r r �
addCleanup�_outFiler� rl r� r� r8 �abspath)rN r� �filename�sutr� r2 r2 r3 �test_getLogObserverFile s
z&AppLoggerTests.test_getLogObserverFilec sp g � t � }� fdd�}| �td|� t�i �}||_|�� | �� |g� |�� | �� |g� | �|j� dS )z�
L{app.AppLogger.stop} removes the observer created in C{start}, and
reinitialize its C{_observer} so that if C{stop} is called several
times it doesn't break.
c s � � | � d S r& r r ��removedr2 r3 �remove r z(AppLoggerTests.test_stop.<locals>.remover N) r rB r r r � _observerr� rl rt )rN r� r. r r2 r, r3 � test_stop s
zAppLoggerTests.test_stopc sz g �t �i �}tt�G �fdd�d��� � fdd�|_|�t� � | �dt�d �� | � | j
g�}| � t |�d|� dS )zt
L{app.AppLogger} using a legacy logger observer still works, wrapping
it in a compat shim.
c s e Zd ZdZ� fdd�ZdS )z;AppLoggerTests.test_legacyObservers.<locals>.LoggerObserverzX
An observer which implements the legacy L{LegacyILogObserver}.
c s � � |� dS )z<
Add C{x} to the logs list.
Nr )rN �x�r r2 r3 r 5 s zDAppLoggerTests.test_legacyObservers.<locals>.LoggerObserver.__call__N)rP rQ rR rS r r2 r2 r2 r3 �LoggerObserver/ s r3 c s � � S r& r2 r2 )r3 r2 r3 r� ; � z5AppLoggerTests.test_legacyObservers.<locals>.<lambda>r r N)
r r r r �_observerFactoryrY r r� r r� �test_legacyObserversrl r� �rN r �warningsr2 )r3 r r3 r6 ' s
z#AppLoggerTests.test_legacyObserversc st g � t �i �}� fdd�|_|�t� � | �dt� d �� | �| jg�}| � t
|�d|� | � |d d d� dS ) z�
L{app.AppLogger} using a logger observer which does not implement
L{ILogObserver} or L{LegacyILogObserver} will be wrapped in a compat
shim and raise a L{DeprecationWarning}.
c s � j S r& r r2 r2 r2 r3 r� J r4 zAAppLoggerTests.test_unmarkedObserversDeprecated.<locals>.<lambda>r r r� r� aZ Passing a logger factory which makes log observers which do not implement twisted.logger.ILogObserver or twisted.python.log.ILogObserver to twisted.application.app.AppLogger was deprecated in Twisted 16.2. Please use a factory that produces twisted.logger.ILogObserver (or the legacy twisted.python.log.ILogObserver) implementing objects instead.N) r r r rY r r� r r� � test_unmarkedObserversDeprecatedrl r� r7 r2 r2 r3 r9 B s
�z/AppLoggerTests.test_unmarkedObserversDeprecatedN)rP rQ rR rS r� r r
r
r r r r r r r r r r r� r� r r" r% r+ r0 r6 r9 r2 r2 r2 r3 r� = s.
�
r� c @ sT e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z e
e d�dd� �Z dS )�UnixAppLoggerTestszw
Tests for L{UnixAppLogger}.
@ivar signals: list of signal handlers installed.
@type signals: C{list}
c r� )zs
Fake C{signal.signal} for not installing the handlers but saving them
in C{self.signals}.
c s � j �| |f� d S r& )�signalsr� )r� r� r\ r2 r3 �
fakeSignalp s z,UnixAppLoggerTests.setUp.<locals>.fakeSignal�signalN)r; rB r= )rN r< r2 r\ r3 r� i s zUnixAppLoggerTests.setUpc C s~ t | j�}tddd��}|�� | �t|�d� | �|d tj� tddd��}|�� | �t|�d� | �|d tj� dS ) z�
When non-daemonized and C{logfile} is empty or set to C{-},
L{UnixAppLogger._getLogObserver} returns a log observer pointing at
C{sys.stdout}.
r# T�r! r r� r r$ rD N) r� rB r! r rl r� r� r� r� �rN r� r r2 r2 r3 r% u s
z,UnixAppLoggerTests.test_getLogObserverStdoutc C s0 t ddd��}| �t|j�}| �t|�d� dS )z
When daemonized and C{logfile} is set to C{-},
L{UnixAppLogger._getLogObserver} raises C{SystemExit}.
r# Fr> z&Daemons cannot log to stdout, exiting!N)r! r� r� r rl r� )rN r r� r2 r2 r3 � test_getLogObserverStdoutDaemon� s z2UnixAppLoggerTests.test_getLogObserverStdoutDaemonc s� t | j�}| �� }td|i�}|�� }| �|jj� | �t |�d� | �|d j
t j
� |�� | �t | j
�d� | �| j
d d tj� t� � � fdd�}||d _| j
d d }|dd� � S )z�
When C{logfile} contains a file name, L{app.AppLogger._getLogObserver}
returns a log observer pointing at the specified path, and a signal
handler rotating the log is installed.
r! r� r c s � � d � d S r& )�callbackr2 ��dr2 r3 �rotate� r z:UnixAppLoggerTests.test_getLogObserverFile.<locals>.rotateN)r� rB r� r! r r& r' r� rl r� r� r8 r( r; r= �SIGUSR1r rD )rN r� r) r* r� rD � rotateLogr2 rB r3 r+ � s
z*UnixAppLoggerTests.test_getLogObserverFilec sV � fdd�}� � td|� � �� }td|i�}|�� }� �|jj� � �� j g � dS )zy
If a signal handler is already installed,
L{UnixAppLogger._getLogObserver} doesn't override it.
c s � � | tj� t� S r& )rl r= rE r )r� r\ r2 r3 �
fakeGetSignal� s zVUnixAppLoggerTests.test_getLogObserverDontOverrideSignalHandler.<locals>.fakeGetSignal� getsignalr! N)
rB r= r� r! r r& r' r� rl r; )rN rG r) r* r� r2 r\ r3 �,test_getLogObserverDontOverrideSignalHandler� s z?UnixAppLoggerTests.test_getLogObserverDontOverrideSignalHandlerc C sN t | j�}tddd��}|�� | �t|�d� | �|d jtj�d�� dS )z�
When daemonized and C{logfile} is empty, the observer returned by
L{UnixAppLogger._getLogObserver} points at C{twistd.log} in the current
directory.
r$ Fr> r� r z
twistd.logN) r� rB r! r rl r� r� r8 r( r? r2 r2 r3 � test_getLogObserverDefaultFile� s
z1UnixAppLoggerTests.test_getLogObserverDefaultFiler� c C sP t | �}tddd��}|�� }| �|dg� |ddi� | �|dddig� dS )z�
If C{syslog} is set to C{True}, L{UnixAppLogger._getLogObserver} starts
a L{syslog.SyslogObserver} with given C{prefix}.
Tz test-prefix)r� r� r~ �bN)r� r! r rl )rN r r r� r2 r2 r3 �test_getLogObserverSyslog� s z,UnixAppLoggerTests.test_getLogObserverSyslogN)
rP rQ rR rS r� r% r@ r+ rI rJ r r� rL r2 r2 r2 r3 r: ` s
r: z!twistd unix support not availablec @ 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 )#�DaemonizeTestszH
Tests for L{_twistd_unix.UnixApplicationRunner} daemonization.
c C sb t � | _t�� | _| �td| j� t�| j�| _t �
d�| j_ t j
| j_t j| j_dd� | j_d S )Nr8 r� c W rV r& r2 r{ r2 r2 r3 r� � r� z&DaemonizeTests.setUp.<locals>.<lambda>)r �mockosr rp ru rB r� r r� r r� rX r� r� r �stderrr r r\ r2 r2 r3 r� � s
zDaemonizeTests.setUpc C s` t t� ��
| j�� W d � n1 sw Y | �| jjg d�� | �| jjddg� dS )zw
When double fork succeeded in C{daemonize}, the child process writes
B{0} to the status pipe.
N)�rV r_ �r� rq ��forkT�setsidrR )r� ���� 0��unlinkz
twistd.pid���rU )r re r� r^ rl rN �actions�closedr\ r2 r2 r3 � test_success� s �� zDaemonizeTests.test_successc C st d| j _d| j _tt� �� | �t| jj� W d � n1 s w Y | � | j j
g d�� | � | j j dg� dS )z�
The parent process initiating the C{daemonize} call reads data from the
status pipe and then exit the process.
FrV N)rP rQ rR �rj ����d ��exitr rW r^ ) rN �child�readDatar re r� � SystemErrorr� r^ rl rZ r[ r\ r2 r2 r3 �test_successInParent s �� z#DaemonizeTests.test_successInParentc s� g � � fdd�}|| j _tt� ��
| j�� W d � n1 s!w Y | �| j jg d�� | �| j jddg� | �ddg� � dS )z�
If the C{os.write} call to the status pipe raises an B{EINTR} error,
the process child retries to write.
c s( � � | |f� t� �dkrttj��d S r\ �r� r� r� r� �EINTR)�fdr� ��writtenr2 r3 � raisingWrite s
�z6DaemonizeTests.test_successEINTR.<locals>.raisingWriteN)rP rQ rR rT rR rW rY rU )rU rV ) rN r� r re r� r^ rl rZ r[ )rN rk r2 ri r3 �test_successEINTR s �� z DaemonizeTests.test_successEINTRc s� g � � fdd�}|| j _d| j _tt� �� | �t| jj� W d � n1 s(w Y | � | j j
g d�� | � | j j dg� | � ddg� � dS )z
If the C{os.read} call on the status pipe raises an B{EINTR} error, the
parent child retries to read.
c s( � � | |f� t� �dkrttj��dS )Nr� rV rf )rh �size�rj r2 r3 � raisingRead; s
z=DaemonizeTests.test_successInParentEINTR.<locals>.raisingReadFN)rP rQ rR r` rW r^ )r^ r_ ) rN rj rb r re r� rd r� r^ rl rZ r[ )rN ro r2 rn r3 �test_successInParentEINTR4 s ��
z(DaemonizeTests.test_successInParentEINTRc s� G � fdd�dt j�}|� }|�| jj� tt� �� | �t| jj � W d � n1 s-w Y | �
| j j ddddddd |fd
g� | �
| j j
d d g� dS ) z�
Assert L{UnixApplicationRunner.postApplication} writes
C{reported} to its status pipe if the service raises an
exception whose message is C{raised}.
c s e Zd Z� fdd�ZdS )z6DaemonizeTests.assertErrorWritten.<locals>.FakeServicec s t � ��r& r� r\ ��raisedr2 r3 r' Z r� zCDaemonizeTests.assertErrorWritten.<locals>.FakeService.startServiceN)rP rQ rR r' r2 rq r2 r3 r+ Y s r+ NrP rQ rR rT r� rU rW rY )r rL r$ r� rX r re r� r� r^ rl rN rZ r[ )rN rr �reportedr+ � errorServicer2 rq r3 �assertErrorWrittenR s$ ��� z!DaemonizeTests.assertErrorWrittenc C � | j ddd� dS )z�
If an error happens during daemonization, the child process writes the
exception error to the status pipe.
zSomething is wrongs" 1 RuntimeError: Something is wrong�rr rs N�ru r\ r2 r2 r3 �
test_errorp �
�zDaemonizeTests.test_errorc C rv )z�
If an error happens during daemonization, and that error's
message is Unicode, the child encodes the message as ascii
with backslash Unicode code points.
u •s 1 RuntimeError: \u2022rw Nrx r\ r2 r2 r3 �test_unicodeErrory s z DaemonizeTests.test_unicodeErrorc C s� d| j _|| j _t� }| �td|� tt� �� | �t | j
j � W d � n1 s*w Y | � |�
� |� | � | j j|� | � | j jdg� dS )a
Make L{os.read} appear to return C{readData}, and assert that
L{UnixApplicationRunner.postApplication} writes
C{errorMessage} to standard error and executes the calls
against L{os} functions specified in C{mockOSActions}.
F�
__stderr__Nr^ )rN rb rc r rB r� r re r� rd r� r^ rl r� rZ r[ )rN rc � errorMessage�
mockOSActions�errorIOr2 r2 r3 �assertErrorInParentBehavior� s �z*DaemonizeTests.assertErrorInParentBehaviorc C � | j ddg d�d� dS )z�
When the child writes an error message to the status pipe
during daemonization, the parent writes the repr of the
message to C{stderr} and exits with non-zero status code.
s 1 Exception: An identified errorzgAn error has occurred: b'Exception: An identified error'
Please look at log file for more information.
�rP rQ rR r] )ra r� rW �rc r} r~ N�r� r\ r2 r2 r3 �test_errorInParent� �
�z!DaemonizeTests.test_errorInParentc C r� )z�
When the child writes a non-ASCII error message to the status
pipe during daemonization, the parent writes the repr of the
message to C{stderr} and exits with a non-zero status code.
s 1 Exception: �zXAn error has occurred: b'Exception: \xff'
Please look at log file for more information.
r� r� Nr� r\ r2 r2 r3 �test_nonASCIIErrorInParent� r� z)DaemonizeTests.test_nonASCIIErrorInParentc C s, d}d� d�}| j|d� |�g d�d� dS )a
When the child writes a non-ASCII error message to the status
pipe during daemonization, and that message is too longer, the
parent writes the repr of the truncated message to C{stderr}
and exits with a non-zero status code.
�d 1 RuntimeError: \u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022\u2022zb'RuntimeError: {}'zb\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022\\u2022zHAn error has occurred: {}
Please look at log file for more information.
r� r� N)r� r� )rN �truncatedMessage�reportedMessager2 r2 r3 �&test_errorInParentWithTruncatedUnicode� s
�
�z5DaemonizeTests.test_errorInParentWithTruncatedUnicodec C rv )z{
If an error occurs during daemonization and its message is too
long, it's truncated by the child.
��xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxsd 1 RuntimeError: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxrw Nrx r\ r2 r2 r3 �test_errorMessageTruncated� rz z)DaemonizeTests.test_errorMessageTruncatedc C rv )z�
If an error occurs during daemonization and its message is
unicode and too long, it's truncated by the child, even if
this splits a unicode escape sequence.
uZ ••••••••••••••••••••••••••••••r� rw Nrx r\ r2 r2 r3 �!test_unicodeErrorMessageTruncated� s
�z0DaemonizeTests.test_unicodeErrorMessageTruncatedc C �. t � }| j�|� | �|j� | �|j� dS )z�
C{daemonize} indeed calls L{IReactorDaemonize.beforeDaemonize} and
L{IReactorDaemonize.afterDaemonize} if the reactor implements
L{IReactorDaemonize}.
N)re r� r[ r� r� r� r] r2 r2 r3 �test_hooksCalled� � z DaemonizeTests.test_hooksCalledc C r� )z�
C{daemonize} does NOT call L{IReactorDaemonize.beforeDaemonize} or
L{IReactorDaemonize.afterDaemonize} if the reactor does NOT implement
L{IReactorDaemonize}.
N)r� r� r[ r� r� r� r] r2 r2 r3 �test_hooksNotCalled� r� z"DaemonizeTests.test_hooksNotCalledN)rP rQ rR rS r� r\ re rl rp ru ry r{ r� r� r� r� r� r� r� r� r2 r2 r2 r3 rM � s$
rM c @ s* e Zd ZdZedd� �Zejdd� �ZdS )� SignalCapturingMemoryReactorz�
MemoryReactor that implements the _ISupportsExitSignalCapturing interface,
all other operations identical to MemoryReactor.
c C rf r& ��_valr\ r2 r2 r3 rF
s z(SignalCapturingMemoryReactor._exitSignalc C r� r& r� )rN �valr2 r2 r3 rF s
N)rP rQ rR rS �propertyrF �setterr2 r2 r2 r3 r� s
r� c s4 e Zd ZdZeZ� fdd�Zdd� Zdd� Z� Z S )� StubApplicationRunnerWithSignalz�
An application runner that uses a SignalCapturingMemoryReactor and
has a _signalValue attribute that it will set in the reactor.
@ivar _signalValue: The signal value to set on the reactor's _exitSignal
attribute.
c s t � �|� d | _d S r& )�superre � _signalValuer� �� __class__r2 r3 re ! s
z(StubApplicationRunnerWithSignal.__init__c C r� )z
Does nothing.
Nr2 r\ r2 r2 r3 r] % r� z.StubApplicationRunnerWithSignal.preApplicationc C s$ t � }| j|_| �|tjtj� dS )z`
Instantiate a SignalCapturingMemoryReactor and start it
in the runner.
N)r� r� rF r r� r� rO r] r2 r2 r3 r^ * s z/StubApplicationRunnerWithSignal.postApplication)
rP rQ rR rS rU r_ re r] r^ �
__classcell__r2 r2 r� r3 r� s r� c s � fdd�}|S )aI
Create a factory function to instantiate a
StubApplicationRunnerWithSignal that will report signum as the captured
signal..
@param signum: The integer signal number or None
@type signum: C{int} or C{None}
@return: A factory function to create stub runners.
@rtype: stubApplicationRunnerFactory
c s t | �}� |_|S )a�
Create a StubApplicationRunnerWithSignal using a reactor that
implements _ISupportsExitSignalCapturing and whose _exitSignal
attribute is set to signum.
@param config: The runner configuration, platform dependent.
@type config: L{twisted.scripts.twistd.ServerOptions}
@return: A runner to use for the test.
@rtype: twisted.test.test_twistd.StubApplicationRunnerWithSignal
)r� r� )ru r� ��signumr2 r3 � stubApplicationRunnerFactoryA s zIstubApplicationRunnerFactoryCreator.<locals>.stubApplicationRunnerFactoryr2 )r� r� r2 r� r3 �#stubApplicationRunnerFactoryCreator4 s
r� c @ r� ) �ExitWithSignalTestsz?
Tests for L{twisted.application.app._exitWithSignal}.
c sR t �� � _dt� i� j_t� � j_d� j_ddg� _� fdd�}� � t
d|� dS )zM
Set up the server options and a fake for use by test cases.
r Nc s | � j d< |� j d< dS )z�
Fake method to capture arguments passed to os.kill.
@param pid: The pid of the process being killed.
@param sig: The signal sent to the process.
r r� N)� fakeKillArgsr� r\ r2 r3 �fakeKilld s
z+ExitWithSignalTests.setUp.<locals>.fakeKillr� ) r rp ru rI r r r rw r� rB r8 )rN r� r2 r\ r3 r� Z s
zExitWithSignalTests.setUpc s� ddg� � fdd�}| � td|� t�tj� | �� d tj� | �� d tj� | �| jd t� � � | �| jd tj� dS )z�
exitWithSignal replaces the existing signal handler with the default
handler and sends the replaced signal to the current process.
Nc s | � d< |� d< d S )Nr r� r2 )r� �handler��fakeSignalArgsr2 r3 � fake_signaly s z<ExitWithSignalTests.test_exitWithSignal.<locals>.fake_signalr= r r� )
rB r= r �_exitWithSignal�SIGINTrJ �SIG_DFLr� r8 r� )rN r� r2 r� r3 �test_exitWithSignalq s z'ExitWithSignalTests.test_exitWithSignalc C sB | � tdtd�� t�| j� | �| jd � | �| jd � dS )zb
_exitWithSignal is not called if the runner does not exit with a
signal.
r, Nr r� )rB r r� �runAppru rt r� r\ r2 r2 r3 �test_normalExit� s
� z#ExitWithSignalTests.test_normalExitc C sN | � tdttj�� t�| j� | �| jd t �
� � | �| jd tj� dS )zP
_exitWithSignal is called when the runner exits with a signal.
r, r r� N) rB r r� r= r� r� ru rJ r� r8 r� r\ r2 r2 r3 �test_runnerExitsWithSignal� s � z.ExitWithSignalTests.test_runnerExitsWithSignalN)rP rQ rR rS r� r� r� r� r2 r2 r2 r3 r� T s r� )hrS r� r� r8 r� r= r� r: �_grpr7 �_pwd� ImportError�ior �unittestr �zope.interfacer �zope.interface.verifyr r� r r r �twisted.applicationr r
r �twisted.application.servicer �twisted.internet.baser
�twisted.internet.deferr �twisted.internet.interfacesr r �#twisted.internet.test.modulehelpersr �twisted.loggerr r r �twisted.pythonr �twisted.python.componentsr �twisted.python.fakepwdr �twisted.python.logr r �twisted.python.reflectr �twisted.python.runtimer �twisted.python.usager �twisted.scriptsr �twisted.test.proto_helpersr �twisted.test.test_processr �twisted.trial.unittestr r� � twisted.scripts._twistd_unixr r! r" r� r# r$ r% rG rI r rU r, r[ r` r� r� r� r� r� r rO rs r� r� re r; r� r� r� r� r: rM r� r� r� r� r2 r2 r2 r3 �<module> s� � -
YF
u
;
%
{ +