File: //usr/lib/python3/dist-packages/twisted/test/__pycache__/test_twistd.cpython-38.pyc
U
W[�! � @ sl d Z ddlmZmZ ddlZddlZddlZddlZddlZzddl Z ddl
Z
W n e k
rl d Z Z
Y nX z ddl Z
W n e k
r� ddl
Z
Y nX ddlmZ ddlmZ ddlmZ ddlmZ ddlmZmZmZ dd lmZm Z 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/m0Z0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m*Z7m8Z8 ddl9m:Z: ddl;m<Z< ddl=m>Z> ddl?m@Z@ zddl?mAZA W n e k
�r� dZAY n&X ddlBmCZC ddlBmDZD dd lBmEZE zdd l4mFZF W n e k
�r2 dZFY nX z ddlGZGW n e k
�rZ dZGY nX zddlHZHddlIZIW n e k
�r� dZIY nX eJed d�dk�r�d ZKndZKd d!� ZLG d"d#� d#eM�ZNG d$d%� d%e jO�ZPG d&d'� d'e@jQ�ZRG d(d)� d)ejS�ZTG d*d+� d+ejS�ZUG d,d-� d-ejS�ZVG d.d/� d/eM�ZWG d0d1� d1e jX�ZYG d2d3� d3ejS�ZZG d4d5� d5ejS�Z[G d6d7� d7ejS�Z\G d8d9� d9ejS�Z]G d:d;� d;eM�Z^ee#�G d<d=� d=e^��Z_G d>d?� d?eM�Z`G d@dA� dAejS�ZadBdC� ZbdDdE� ZcG dFdG� dGejS�ZdG dHdI� dIejS�ZeG dJdK� dKejS�Zfee$�G dLdM� dMe.��ZgG dNdO� dOe@jQ�ZhdPdQ� ZiG dRdS� dSejS�ZjeAdk�rhdTef_kdS )UzE
Tests for L{twisted.application.app} and L{twisted.scripts.twistd}.
� )�absolute_import�divisionN)� implementer)� verifyObject)�unittest)�MockOS)�plugin�logger�internet)�service�app�reactors)�
IServiceMaker)�Deferred)�IReactorDaemonize� _ISupportsExitSignalCapturing)�AlternateReactor)�globalLogBeginner�globalLogPublisher� ILogObserver)� ReactorBase)�
MemoryReactor)�NativeStringIO�_PY3)�
Componentized)�util)r �textFromEventDict)� platformType)�
UsageError)� UserDatabase)�twistd)� _twistd_unix)�checkPID)�UnixApplicationRunner)�
UnixAppLogger)�syslog�setuidz5Platform does not support --uid/--gid twistd options.c 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�indexZgr_nameZgr_gid�tuple)�name�result��gidZgrent�group� �:/usr/lib/python3/dist-packages/twisted/test/test_twistd.py�getgrnamy s
z#patchUserDatabase.<locals>.getgrnam�getpwnamr2 �getpwuidN)�pwdr4 �os�getuid�grpZgetgrgid�getgidr ZaddUserZ pw_passwdZpw_gecos�pw_dirZpw_shellr3 )�patch�user�uidr/ r. �pwentZdatabaser2 r0 r- r1 �patchUserDatabaseX s � r? c @ s 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��selfrB r0 r0 r1 � makeService� s
z MockServiceMaker.makeServiceN)�__name__�
__module__� __qualname__�__doc__�tapnamerF r0 r0 r0 r1 r@ � s r@ c @ s e Zd ZdZdd� ZdS )�CrippledAppLoggerz*
@see: CrippledApplicationRunner.
c C s d S r' r0 �rE � applicationr0 r0 r1 �start� s zCrippledAppLogger.startN)rG rH rI rJ rO r0 r0 r0 r1 rL � s rL 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 s d S r' r0 �rE r0 r0 r1 �preApplication� s z(CrippledApplicationRunner.preApplicationc C s d S r' r0 rQ r0 r0 r1 �postApplication� s z)CrippledApplicationRunner.postApplicationN)rG rH rI rJ rL �
loggerFactoryrR rS r0 r0 r0 r1 rP � s rP c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z e dkrjdZ
e
e _ e
_e _dd� Zdd� Zdd� ZdS )�ServerOptionsTestszT
Non-platform-specific tests for the platform-specific ServerOptions class.
c s� G dd� dt �}|d�� |d��|d��|d��� ����fdd�}t�� }��|jtj� ||_|j}� ���g}t||�D ]L\}}|\}} }
} ��||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 )rK �_options� description�rE r+ r0 r0 r1 �__init__� s
z@ServerOptionsTests.test_subCommands.<locals>.FakePlugin.__init__c S s | j S r' )rW rQ r0 r0 r1 rB � s z?ServerOptionsTests.test_subCommands.<locals>.FakePlugin.optionsN)rG rH rI rZ rB r0 r0 r0 r1 �
FakePlugin� s r[ �apple�banana�coconut�donutc 3 s( �� | t� �V �V �V � V d S r' )� assertEqualr )Z interface�r\ r] r^ r_ rE r0 r1 �
getPlugins� s
z7ServerOptionsTests.test_subCommands.<locals>.getPluginsN)
�objectr �
ServerOptionsr` Z _getPluginsr rb � subCommands�ziprK � assertIsNonerW rX ) rE r[ rb �configre Z
expectedOrder�
subCommandZexpectedCommandr+ ZshortcutZ parserClassZ
documentationr0 ra r1 �test_subCommands� s"
z#ServerOptionsTests.test_subCommandsc s� G dd� dt �}|d�� |d��|d��|d��� ���fdd�}t�� }��|jtj� ||_t� |_�� t
|j d g� |j� � �g �� ���fD ](}���fd
d �}||j
� ||j� q����t��d �f � d
S )zP
Reactor names are listed alphabetically by I{--help-reactors}.
c @ s e Zd Zdd� ZdS )zGServerOptionsTests.test_sortedReactorHelp.<locals>.FakeReactorInstallerc S s d| | _ d| | _d| _d S )Nzname of rV ztwisted.internet.default)� shortNamerX Z
moduleNamerY r0 r0 r1 rZ � s
zPServerOptionsTests.test_sortedReactorHelp.<locals>.FakeReactorInstaller.__init__N)rG rH rI rZ r0 r0 r0 r1 �FakeReactorInstaller� s rl r\ r] r^ r_ c 3 s �V �V �V � V d S r' r0 r0 )r\ r] r^ r_ r0 r1 �getReactorTypes� s zBServerOptionsTests.test_sortedReactorHelp.<locals>.getReactorTypesz--help-reactorsc s �� | � � ��� �| �� d S r' )�assertIn�appendr) )�s)�
helpOutput�indexesrE r0 r1 �getIndex� s z;ServerOptionsTests.test_sortedReactorHelp.<locals>.getIndexz7reactor descriptions were not in alphabetical order: %rN)rc r rd r` Z_getReactorTypesr
rm r Z
messageOutput� assertRaises�
SystemExit� parseOptions�getvaluerk rX �sorted)rE rl rm rh �reactorrs r0 )r\ r] r^ r_ rq rr rE r1 �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.
rA �no_saveN)r rd ri � postOptions�
assertTrue�rE rh r0 r0 r1 �&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 rd r| � assertFalser~ r0 r0 r1 �(test_postOptionsNoSubCommandSavesAsUsual s z;ServerOptionsTests.test_postOptionsNoSubCommandSavesAsUsualc C s. t �� }t|�}tjjD ]}| �||� qdS )zq
All the profilers that can be used in L{app.AppProfiler} are listed in
the help output.
N)r rd �strr � AppProfilerZ profilersrn )rE rh rq �profilerr0 r0 r1 �test_listAllProfilers s z(ServerOptionsTests.test_listAllProfilersc C s t �� }| �|d � dS )zG
The default value for the C{umask} option is L{None}.
�umaskN)r rd rg r~ r0 r0 r1 �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.
�--umaskZ123r� �S Z0123N)r rd rv r` r~ r0 r0 r1 �
test_umask2 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� ZabcdefN)r rd rt r rv r~ r0 r0 r1 �test_invalidUmask> s
�z$ServerOptionsTests.test_invalidUmaskN�twistd unix not availablec C sH 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 rd rt r rv r} �args�
startswith� assertNotIn�rE rh �er0 r0 r1 �&test_unimportableConfiguredLogObserverL s �
��z9ServerOptionsTests.test_unimportableConfiguredLogObserverc C sj t �� }| �t|jddg�}tjdkr>| �|jd � d�� n| �|jd � d�� | �
d|jd � dS ) zP
C{--logger} with a non-existent object raises a L{UsageError}.
r� z twisted.test.test_twistd.FOOBAR)� � r ziLogger 'twisted.test.test_twistd.FOOBAR' could not be imported: 'module' object has no attribute 'FOOBAR'z{Logger 'twisted.test.test_twistd.FOOBAR' could not be imported: module 'twisted.test.test_twistd' has no attribute 'FOOBAR'r� N) r rd rt r rv �sys� version_infor} r� r� r� r� r0 r0 r1 �*test_badAttributeWithConfiguredLogObserver[ s
�
��
��z=ServerOptionsTests.test_badAttributeWithConfiguredLogObserverc C sv ddl m} tdkrd}nd}d�||j|j�}t� }tj|d�}| �t |j
dg�}| � |j d � | �
|�� |� d S )
z2
C{--version} prints the version.
r )� copyrightZwin32z (the Twisted Windows runner)z(the Twisted daemon)ztwistd {} {}
{}
)�stdoutz --versionN)�twistedr� r �format�versionr r rd rt ru rv �assertIs�coder` rw )rE r� r+ ZexpectedOutputr� rh r� r0 r0 r1 � test_versionp s � z ServerOptionsTests.test_version)rG rH rI rJ rj rz r r� r� r� r� r� r! �msg�skipr� r� r� r0 r0 r0 r1 rU � s ++
rU c @ sD e Zd ZdZedkrdZdd� Zdd� Zdd � Zd
d � Z d d
� Z
dS )�
CheckPIDTestsz
Tests for L{checkPID}.
Nr� c C s | � tjddd� � td� dS )z7
Nonexistent PID file is not an error.
�existsc S s dS �NFr0 )�_r0 r0 r1 �<lambda>� � z.CheckPIDTests.test_notExists.<locals>.<lambda>znon-existent PID fileN)r; r6 �pathr" rQ r0 r0 r1 �test_notExists� s z CheckPIDTests.test_notExistsc C sH | � � }t|d��}|�d� W 5 Q R X | �tt|�}| �d|j� dS )zI
Non-numeric content in a PID file causes a system exit.
�wz non-numericznon-numeric valueN)�mktemp�open�writert ru r" rn r� )rE �pidfile�fr� r0 r0 r1 �test_nonNumeric� s
z CheckPIDTests.test_nonNumericc C s^ | � � }t|d��}|�d� W 5 Q R X dd� }| �td|� | �tt|�}| �d|j � dS )zE
Another running twistd server causes a system exit.
r� Z42c S s d S r' r0 ��pid�sigr0 r0 r1 �kill� s z/CheckPIDTests.test_anotherRunning.<locals>.killr� zAnother twistd serverN)
r� r� r� r; r6 rt ru r" rn r� �rE r� r� r� r� r0 r0 r1 �test_anotherRunning� s z!CheckPIDTests.test_anotherRunningc C sh | � � }t|d�� }|�tt�� d �� W 5 Q R X dd� }| �td|� t|� | �tj �
|�� dS )zJ
Stale PID file is removed without causing a system exit.
r� � c S s t tjd��d S �NZfake)�OSError�errnoZESRCHr� r0 r0 r1 r� � s z&CheckPIDTests.test_stale.<locals>.killr� N) r� r� r� r� r6 �getpidr; r" r� r� r� )rE r� r� r� r0 r0 r1 �
test_stale� s zCheckPIDTests.test_stalec C st | � � }t|d��}|�d� W 5 Q R X 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� Z3581c S s t tjd��d S r� �r� r� ZEBADFr� r0 r0 r1 r� � s z2CheckPIDTests.test_unexpectedOSError.<locals>.killr� Nr zCan't check status of PID)
r� r� r� r; r6 rt ru r" Z assertIsNotr� r} r� r� r� r0 r0 r1 �test_unexpectedOSError� s z$CheckPIDTests.test_unexpectedOSError) rG rH rI rJ r! r� r� r� r� r� r� r0 r0 r0 r1 r� � s r� c @ s e Zd ZdZdd� Zdd� ZdS )� TapFileTestszM
Test twistd-related functionality that requires a tap file on disk.
c C s8 | � � | _t| jd��}t�t�d�|� W 5 Q R X dS )zP
Create a trivial Application and put it in a tap file on disk.
�wb�Hi!N)r� �tapfiler� �pickle�dumpr � Application)rE r� r0 r0 r1 �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 rd rv r� rP ZcreateOrGetApplicationr` r �IServicer+ )rE rh rN r0 r0 r1 �&test_createOrGetApplicationWithTapFile� s �z3TapFileTests.test_createOrGetApplicationWithTapFileN)rG rH rI rJ r� r� r0 r0 r0 r1 r� � s r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �TestLoggerFactoryz8
A logger factory for L{TestApplicationRunner}.
c C s
|| _ d S r' )�runner)rE r� r0 r0 r1 rZ � s zTestLoggerFactory.__init__c C s" | j j�d� t| j d�| j _dS )zC
Save the logging start on the C{runner} instance.
�logrN N)r� �orderro �hasattr�hadApplicationLogObserverrM r0 r0 r1 rO � s �zTestLoggerFactory.startc C s dS )z%
Don't log anything.
Nr0 rQ r0 r0 r1 �stop� s zTestLoggerFactory.stopN)rG rH rI rJ rZ rO r� r0 r0 r0 r1 r� � s r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �TestApplicationRunnerz`
An ApplicationRunner which tracks the environment in which its methods are
called.
c C s" t j�| |� g | _t| �| _d S r' )r �ApplicationRunnerrZ r� r� r rD r0 r0 r1 rZ s z TestApplicationRunner.__init__c C s | j �d� t| d�| _d S )N�prerN )r� ro r� � hadApplicationPreApplicationrQ r0 r0 r1 rR s z$TestApplicationRunner.preApplicationc C s | j �d� t| d�| _d S )N�postrN )r� ro r� � hadApplicationPostApplicationrQ r0 r0 r1 rS s z%TestApplicationRunner.postApplicationN)rG rH rI rJ rZ rR rS r0 r0 r0 r1 r� s r� c @ sl e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Ze e_
d d
� Z e e _
dd� Z dd� Z
dd� Zdd� ZdS )�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 rd r@ � serviceMaker�
loadedPluginsrc �
subOptionsri rh r~ r0 r0 r1 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) rP rh �runr� r� rB r� r r� rN �services)rE Zarunnerr0 r0 r1 �,test_applicationRunnerGetsCorrectApplication% s
��zCApplicationRunnerTests.test_applicationRunnerGetsCorrectApplicationc C sN t | j�}|�� | �|j� | �|j� | �|j� | �|j dddg� dS )z�
Test thet preApplication and postApplication methods are
called by ApplicationRunner.run() when appropriate.
r� r� r� N)
r� rh r� r� r� r} r� r� r` r� )rE rp r0 r0 r1 �test_preAndPostApplication9 s
z1ApplicationRunnerTests.test_preAndPostApplicationc s� | j �|� g � G � fdd�dtj�}ttjtj�G � fdd�dt��}|� }t tj|� t tj|� || 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 s � � d� d S )N� environment�ro �rE �chrootZrundir�nodaemonr� r� �Zeventsr0 r1 �setupEnvironmentT s zmApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.setupEnvironmentc s � � d|||f� d S )N�
privilegesr� )rE �euidr= r. r� r0 r1 �shedPrivilegesX s zkApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.shedPrivilegesc s � � d� d S )Nry r� )rE ry � oldstdout� oldstderrr� r0 r1 � startReactor[ s ziApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.startReactorc S s d S r' r0 )rE r� r0 r0 r1 � removePID^ s zfApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeUnixApplicationRunner.removePIDN)rG rH rI r� r� r� r� r0 r� r0 r1 �FakeUnixApplicationRunnerS 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 s d S r' r0 rY r0 r0 r1 �setNamek s zVApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.setNamec S s d S r' r0 )rE �parentr0 r0 r1 �setServiceParentn s z_ApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.setServiceParentc S s d S r' r0 rQ r0 r0 r1 �disownServiceParentq s zbApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.disownServiceParentc s � � d� d S )N�privilegedStartServicer� rQ r� r0 r1 r� t s zeApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.privilegedStartServicec s � � d� d S )N� startServicer� rQ r� r0 r1 r� w s z[ApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.startServicec S s d S r' r0 rQ r0 r0 r1 � stopServicez s zZApplicationRunnerTests._applicationStartsWithConfiguredID.<locals>.FakeService.stopService)rG rH rI r� �runningr+ Z processNamer= r. r� r� r� r� r� r� r0 r� r0 r1 � FakeServicea s r� r� r� r� Fr� ry N)rh rv r �_SomeApplicationRunnerr r r� ZIProcessrc r rR rN rS r` )rE �argvr= r. r� r� rN r� r0 r� r1 �"_applicationStartsWithConfiguredIDF s(
��z9ApplicationRunnerTests._applicationStartsWithConfiguredIDc 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� )rE r= r. r0 r0 r1 �.test_applicationStartsWithConfiguredNumericIDs� 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}.
�foor� �barr� r� r� N)r? r; r� )rE r< r= r/ r. r0 r0 r1 �+test_applicationStartsWithConfiguredNameIDs� s
�zBApplicationRunnerTests.test_applicationStartsWithConfiguredNameIDsc C s8 t � }t�dddd��}|�|dd� | �|jd� dS )z7
L{startReactor} calls L{reactor.run}.
F�profile�r r� �debugNz'startReactor did not call reactor.run())� DummyReactorr r� r� r} �called�rE ry r� r0 r0 r1 � 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.
ry Fr r N)r r; r
r r� r� r} r r r0 r0 r1 �*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 @ s e Zd ZdZdd� Zdd� ZdS )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 s dS �z=
Dummy method, does nothing.
Nr0 rQ r0 r0 r1 � installWaker� s zhApplicationRunnerTests.test_applicationRunnerCapturesSignal.<locals>.DummyReactorWithSignal.installWakerc S s
d| _ dS )zZ
A fake run method setting _exitSignal to a nonzero value
� N�� _exitSignalrQ r0 r0 r1 r� � s z_ApplicationRunnerTests.test_applicationRunnerCapturesSignal.<locals>.DummyReactorWithSignal.runN�rG rH rI rJ r r� r0 r0 r0 r1 �DummyReactorWithSignal� s r Fr r Nr )r r r� r� � assertEqualsr )rE r ry r� r0 r0 r1 �$test_applicationRunnerCapturesSignal� s �z;ApplicationRunnerTests.test_applicationRunnerCapturesSignalc C sH G dd� dt �}|� }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 @ s e Zd ZdZdd� Zdd� ZdS )ziApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal.<locals>.DummyReactorWithExitSignalAttributer c S s dS r
r0 rQ r0 r0 r1 r � s zvApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal.<locals>.DummyReactorWithExitSignalAttribute.installWakerc S s
d| _ dS )z�
A fake run method setting _exitSignal to a nonzero value
that should be ignored.
r Nr rQ r0 r0 r1 r� � s zmApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal.<locals>.DummyReactorWithExitSignalAttribute.runNr r0 r0 r0 r1 �#DummyReactorWithExitSignalAttribute� s r Fr r N)rc r r� r� r r )rE r ry r� r0 r0 r1 �%test_applicationRunnerIgnoresNoSignal� s �z<ApplicationRunnerTests.test_applicationRunnerIgnoresNoSignalN)rG rH rI rJ r� r� r� r� r �
setuidSkipr� r r
r r r r0 r0 r0 r1 r� s
F r� c @ s� e Zd ZdZedkrdZe� Zdd� Zdd� Z dd � Z
d
d � Z d d
� Z dd� Z
dd� Zdd� Zdd� 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}.
Nr� c s� � j � _� j � _� j � _d� _t�� � _� �td� fdd�� � �td� fdd�� � �td� fdd�� t t
� � �� _ � j
� j _
d S ) NFr� c s t � d| �S )N�root��setattr�r� rQ r0 r1 r� ( r� zBUnixApplicationRunnerSetupEnvironmentTests.setUp.<locals>.<lambda>�chdirc s t � d| �S )N�cwdr r rQ r0 r1 r� ) r� r� c s t � d| �S )N�maskr )r rQ r0 r1 r� * r� )�unsetr r r �daemonr6 r� r� r; r# r rd r� � daemonizerQ r0 rQ r1 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� r0 rQ r0 r1 r� 5 r� zFUnixApplicationRunnerSetupEnvironmentTests.daemonize.<locals>.<lambda>N)r" r; r6 �rE ry r0 rQ r1 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� r` r rQ r0 r0 r1 � test_chroot8 s z6UnixApplicationRunnerSetupEnvironmentTests.test_chrootc C s( | 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� r r! rQ r0 r0 r1 �
test_noChrootA 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� r` r rQ r0 r0 r1 �test_changeWorkingDirectoryJ s zFUnixApplicationRunnerSetupEnvironmentTests.test_changeWorkingDirectoryc C s: t t� �� | j�ddddd� W 5 Q R X | �| 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} r" rQ r0 r0 r1 �test_daemonizeS 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� r" rQ r0 r0 r1 �test_noDaemonize] s z;UnixApplicationRunnerSetupEnvironmentTests.test_noDaemonizec C sP | � � }| j�dddd|� t|d��}t|�� �}W 5 Q R X | �|| 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�readr` r� �rE r� r� r� r0 r0 r1 �test_nonDaemonPIDFilef s
z@UnixApplicationRunnerSetupEnvironmentTests.test_nonDaemonPIDFilec C sj | � � }tt� �� | j�dddd|� W 5 Q R X t|d��}t|�� �}W 5 Q R X | �|| 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' Fr. r� )
r� r r+ r� r� r� r/ r0 r` r� r1 r0 r0 r1 �test_daemonPIDFiler s z=UnixApplicationRunnerSetupEnvironmentTests.test_daemonPIDFilec C s< t t� �� | j�ddddd� W 5 Q R X | �| jd� dS )z�
L{UnixApplicationRunner.setupEnvironment} changes the process umask to
the value specified by the C{umask} parameter.
Nr' F�{ �r r+ r� r� r` r rQ r0 r0 r1 r� � s z5UnixApplicationRunnerSetupEnvironmentTests.test_umaskc C s( | j �ddddd� | �| j| j� dS )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� r r! rQ r0 r0 r1 �test_noDaemonizeNoUmask� s zBUnixApplicationRunnerSetupEnvironmentTests.test_noDaemonizeNoUmaskc C s< t t� �� | j�ddddd� W 5 Q R X | �| 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�? r5 rQ r0 r0 r1 �test_daemonizedNoUmask� s zAUnixApplicationRunnerSetupEnvironmentTests.test_daemonizedNoUmask)rG rH rI rJ r! r� rc r! r� r# r( r) r* r, r- r2 r3 r� r6 r8 r0 r0 r0 r1 r s
r c @ sL e Zd ZdZedkrdZdd� Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dS )�*UnixApplicationRunnerStartApplicationTestsz>
Tests for L{UnixApplicationRunner.startApplication}.
Nr� c s� t �� }|�ddddddddd g � t�d
�}t|�| _g � � fd d �}tr�t� | jj
�j }t� |�j }|� � }|�
d
� | �||� n | �t�| jj
�t�|�� | �td|� | �tddd� � | �tddd� � | j�|� | �� ddddd g� dS )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� Z0070z--chrootz /foo/chrootz--rundirz /foo/rundirz --pidfilez /foo/pidfile�test_setupEnvironmentc s � � |||||f� d S r' )�extendr� �r� r0 r1 �fakeSetupEnvironment� s z^UnixApplicationRunnerStartApplicationTests.test_setupEnvironment.<locals>.fakeSetupEnvironmentrE r� r� c _ s d S r' r0 ��a�kwr0 r0 r1 r� � r� zRUnixApplicationRunnerStartApplicationTests.test_setupEnvironment.<locals>.<lambda>�startApplicationc _ s d S r' r0 r? r0 r0 r1 r� � r� T�8 N)r rd rv r r� r# r� r �inspectZ signaturer� Z
parameters�copy�popr` Z
getargspecr; r rB )rE rB rN r> ZsetupEnvironmentParametersZ fakeSetupEnvironmentParametersr0 r= r1 r; � sT �
�
�
� ��� �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 �# �r` �r= r. r� rQ r0 r1 �
switchUIDPass� s zUUnixApplicationRunnerStartApplicationTests.test_shedPrivileges.<locals>.switchUIDPass� switchUIDrI rG rH N)r; r! r# r� )rE rL r� r0 rQ r1 �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 s t tjd��d S r� r� rK r0 r0 r1 �
switchUIDFail� s zZUnixApplicationRunnerStartApplicationTests.test_shedPrivilegesError.<locals>.switchUIDFailrM rI rG Nr� )r# r; r! rt ru r� r` r� )rE rO r� �excr0 r0 r1 �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' rJ )r= r. �rE � wantedGid� wantedUidr0 r1 �
initgroups s zFUnixApplicationRunnerStartApplicationTests._setUID.<locals>.initgroupsc s � � | �� d S r' rJ )r= )rE rT r0 r1 r& s zBUnixApplicationRunnerStartApplicationTests._setUID.<locals>.setuidc s � � | �� d S r' rJ )r. )rE rS r0 r1 �setgid s zBUnixApplicationRunnerStartApplicationTests._setUID.<locals>.setgidrU r& rV r: r� r; N)
r? r; r r6 r rd rv r� r r� r# r� rB ) rE Z
wantedUserrT Z wantedGrouprS rU r& rV rB rN r� r0 rR r1 �_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.
r i r i� N)rW rQ r0 r0 r1 �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.
ZmorefooZmorebari� r� z\tried to drop privileges and setuid {} but uid is already {}; should we be root? Continuing.r �messageN)r6 r7 rW �
flushWarningsr` �lenr� )rE Z
currentUidZ
warningsShownZexpectedWarningr0 r0 r1 �test_setUidSameAsCurrentUid% s ��zFUnixApplicationRunnerStartApplicationTests.test_setUidSameAsCurrentUid) rG rH rI rJ r! r� r; rN rQ rW rX r\ r0 r0 r0 r1 r9 � s 6 r9 c @ s, e Zd ZdZedkrdZdd� Zdd� ZdS )�#UnixApplicationRunnerRemovePIDTestsz7
Tests for L{UnixApplicationRunner.removePID}.
Nr� 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� r6 �makedirsr� �joinr� �closer� r� r� )rE r� r� r� r0 r0 r1 �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.
Zfakepidr� r N) r# r� ZflushLoggedErrorsr� r` r[ �valuer� ZENOENT)rE r� �errorsr0 r0 r1 �test_removePIDErrorsK s
z8UnixApplicationRunnerRemovePIDTests.test_removePIDErrors)rG rH rI rJ r! r� ra rd r0 r0 r0 r1 r] 5 s
r] c @ s0 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�_afterDaemonizeCalledrQ r0 r0 r1 rZ d s z"FakeNonDaemonizingReactor.__init__c C s
d| _ d S �NT)rf rQ r0 r0 r1 �beforeDaemonizei s z)FakeNonDaemonizingReactor.beforeDaemonizec C s
d| _ d S rh )rg rQ r0 r0 r1 �afterDaemonizem s z(FakeNonDaemonizingReactor.afterDaemonizec O s dS )z*
Skip event registration.
Nr0 )rE r� rA r0 r0 r1 �addSystemEventTriggerq s z/FakeNonDaemonizingReactor.addSystemEventTriggerN)rG rH rI rJ rZ ri rj rk r0 r0 r0 r1 re X s
re c @ s e Zd ZdZdS )r+ z�
A dummy reactor, providing C{beforeDaemonize} and C{afterDaemonize}
methods, announcing this, and logging whether the methods have been called.
N�rG rH rI rJ r0 r0 r0 r1 r+ x s r+ c @ s e Zd ZdZdZdd� ZdS )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 � RuntimeErrorrQ r0 r0 r1 r� � s �DummyReactor.runN)rG rH rI rJ r r� r0 r0 r0 r1 r � s r c @ s� e Zd ZdZdd� Zedkr"de_dd� Zdd � Zedkr@de_d
d � Z d d
� Z
edkr^de
_dd� Z e dkrtde _dd� Z
e dkr�de
_dd� Zdd� Zdd� Zdd� ZdS )�AppProfilingTestsz'
Tests for L{app.AppProfiler}.
c C s~ t �� }| �� |d< d|d< t�|�}t� }|�|� | �|j� t |d ��}|�
� }W 5 Q R X | � 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� rn �function callsN� r rd r� r r� r r� r} r r� r0 rn �rE rh r� ry r� �datar0 r0 r1 � test_profile� s
z AppProfilingTests.test_profileNz profile module not availablec C sP t � }| �td|�}||�}|�� |�� |�� }| �d|� | �d|� d S )Nr� rp z(run))r r; r� � print_statsZrestorerw rn )rE Z
statsClassr �outr� Zstatsrs r0 r0 r1 �
_testStats� 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 rd r� r r� r r� r} r rw �pstatsZStats�rE rh r� ry r0 r0 r1 �test_profileSaveStats� s
z'AppProfilingTests.test_profileSaveStatsc C s` t j�� }t�� }d|d< t�|�}dt jd< z| � t
|j d� W 5 t j�� t j�|� X dS )z�
When the C{profile} module is not present, L{app.ProfilerRunner.run}
should raise a C{SystemExit} exception.
r r� N� r� �modulesrE r rd r r� �clear�updatert ru r� �rE Z savedModulesrh r� r0 r0 r1 �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 @ s e Zd Zdd� ZdS )zGAppProfilingTests.test_profilePrintStatsError.<locals>.ErroneousProfilec S s t d��d S )NZBoom�rm rQ r0 r0 r1 ru � s zSAppProfilingTests.test_profilePrintStatsError.<locals>.ErroneousProfile.print_statsN)rG rH rI ru r0 r0 r0 r1 �ErroneousProfile� s r� �Profiler r� N)r r� r; r rd r� r r� r r� r� rt rm r� r� )rE r� rh r� ry Z oldStdoutr0 r0 r1 �test_profilePrintStatsError� s
z-AppProfilingTests.test_profilePrintStatsErrorc C s~ t �� }| �� |d< d|d< t�|�}t� }|�|� | �|j� t |d ��}|�
� }W 5 Q R X | � 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 �cProfiler� r� rp Nrq rr r0 r0 r1 �
test_cProfile s
z AppProfilingTests.test_cProfilez cProfile module not availablec 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� Trx Nry r{ r0 r0 r1 �test_cProfileSaveStats s
z(AppProfilingTests.test_cProfileSaveStatsc C s` t j�� }dt jd< t�� }d|d< t�|�}z| � t
|j d� W 5 t j�� t j�|� X dS )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� r0 r0 r1 �test_withoutCProfile0 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 Zfoobarr� z!Unsupported profiler name: foobarN) r rd r� rt ru r r� r` r� )rE rh �errorr0 r0 r1 �test_unknownProfilerC 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� r` r� �rE r� r0 r0 r1 �test_defaultProfilerP 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� ZCprOfiler� Nr� r� r0 r0 r1 � test_profilerNameCaseInsentiveX s z0AppProfilingTests.test_profilerNameCaseInsentive)rG rH rI rJ rt r r� rw r| r� r� r� r� r� r� r� r� r� r0 r0 r0 r1 ro � s,
ro 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{unittest.TestCase.patch}).
@return: the list that keeps track of the log files.
@rtype: C{list}
c s � � | � �| f|�|�S r' r� )ZlogFiler� �kwargs��logFilesZoldFileLogObserverr0 r1 �observero s
z+_patchTextFileLogObserver.<locals>.observer�textFileLogObserver)r r� )r; r� r0 r� r1 �_patchTextFileLogObserverb s
r� c s* g � G � fdd�dt �}| �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 s � � |� d S r' r� )rE �prefix�Z logMessagesr0 r1 rZ � s z1_setupSyslog.<locals>.fakesyslogobserver.__init__c s � � |� d S r' r� )rE Z eventDictr� r0 r1 �emit� s z-_setupSyslog.<locals>.fakesyslogobserver.emitN)rG rH rI rZ r� r0 r� r0 r1 �fakesyslogobserver s r� ZSyslogObserver)rc r; r% )ZtestCaser� r0 r� r1 � _setupSyslogx 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� Zdd� Zedks�edkr�de_d d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� ZdS )(�AppLoggerTestsz�
Tests for L{app.AppLogger}.
@ivar observers: list of observers installed during the tests.
@type observers: C{list}
c s$ 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' )� observersro r Z addObserver)r� r� rQ r0 r1 �beginLoggingTo� s z,AppLoggerTests.setUp.<locals>.beginLoggingTor� N)r� r; r )rE r� r0 rQ r1 r� � s zAppLoggerTests.setUpc C s | j D ]}t�|� qdS )z1
Remove all installed observers.
N)r� r �removeObserver�rE r� r0 r0 r1 �tearDown� s
zAppLoggerTests.tearDownc C s t t�G dd� dt��}|� 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' )�_logsro )rE Zeventr0 r0 r1 �__call__� s z;AppLoggerTests._makeObserver.<locals>.TestObserver.__call__N)rG rH rI r� r� r0 r0 r0 r1 � TestObserver� s r� )r r rc )rE r� r0 r0 r1 �
_makeObserver� 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 Z
log_formatz
reactor classr� N)r` r� rn r� r� r0 r0 r1 �_checkObserver� 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 � S r' r0 r0 �r� r0 r1 r� � r� z+AppLoggerTests.test_start.<locals>.<lambda>N)r � AppLoggerr� �_getLogObserverrO r r� )rE r r0 r� r1 �
test_start� 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� rO r� )rE rN r� r r0 r0 r1 �$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 s � S r' r0 r0 r� r0 r1 r� � r� z7AppLoggerTests._setupConfiguredLogger.<locals>.<lambda>)r� r� rO )rE rN Z extraLogArgsZ appLoggerZlogArgsr r0 r� r1 �_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� rM r0 r0 r1 �#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� r` r� )rE r� rN r0 r0 r1 �(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� �LegacyILogObserverro r� r� r` )rE �nonlogsrN r0 r0 r1 �.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� ro r r� rO r� r` )rE r� r� rN r r0 r0 r1 �.test_loggerComponentBeatsLegacyLoggerComponent s
z=AppLoggerTests.test_loggerComponentBeatsLegacyLoggerComponentc 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$ r` )rE �logsrN r0 r0 r1 �%test_configuredLogObserverBeatsSyslog- s
�z4AppLoggerTests.test_configuredLogObserverBeatsSyslogNz&Not on POSIX, or syslog not available.c 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� r6 r� r� )rE rN r� r0 r0 r1 �&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 � r N)
r r� r� r; r� r` r[ r� r� r� )rE r r� r0 r0 r1 �test_getLogObserverStdoutK s
z(AppLoggerTests.test_getLogObserverStdoutc C sV t | j�}| �� }t�d|i�}|�� | �t|�d� | �|d jt 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� r; r� r r� r� r` r[ r� r6 �abspath)rE r� �filenamer r0 r0 r1 �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� �Zremovedr0 r1 �removex s z(AppLoggerTests.test_stop.<locals>.remover� N) rc r; r r r� Z _observerr� r` rg )rE r� r� r r0 r� r1 � test_stopo s
zAppLoggerTests.test_stopc sz g �t �i �}tt�G �fdd�dt��� � 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� )rE �x�r� r0 r1 r� � s zDAppLoggerTests.test_legacyObservers.<locals>.LoggerObserver.__call__N)rG rH rI rJ r� r0 r� r0 r1 �LoggerObserver� s r� c s � � S r' r0 r0 )r� r0 r1 r� � r� z5AppLoggerTests.test_legacyObservers.<locals>.<lambda>r� r N)r r� r r� rc Z_observerFactoryrO r rn r rZ �test_legacyObserversr` r[ �rE r �warningsr0 )r� r� r1 r� � s
�z#AppLoggerTests.test_legacyObserversc sr 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� r0 r� r0 r1 r� � r� zAAppLoggerTests.test_unmarkedObserversDeprecated.<locals>.<lambda>r� r r� rY 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� rO r rn r rZ � test_unmarkedObserversDeprecatedr` r[ r� r0 r� r1 r� � s
��z/AppLoggerTests.test_unmarkedObserversDeprecated)rG rH rI rJ r� r� r� r� r� r� r r� r� r� r� r� r� r� r! r% r� r� r� r� r� r� r� r0 r0 r0 r1 r� � s0 �
� r� c @ sb e Zd ZdZedkrdZdd� Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z e
dkr^de _dS )�UnixAppLoggerTestszw
Tests for L{UnixAppLogger}.
@ivar signals: list of signal handlers installed.
@type signals: C{list}
Nr� c s$ g � _ � fdd�}� �td|� dS )zs
Fake C{signal.signal} for not installing the handlers but saving them
in C{self.signals}.
c s � j �| |f� d S r' )�signalsro )r� r� rQ r0 r1 �
fakeSignal� s z,UnixAppLoggerTests.setUp.<locals>.fakeSignal�signalN)r� r; r� )rE r� r0 rQ r1 r� � 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� r N) r� r; r$ r� r` r[ r� r� r� �rE r� r r0 r0 r1 r� � 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$ rt ru r� r` r� )rE r r� r0 r0 r1 � test_getLogObserverStdoutDaemon� s z2UnixAppLoggerTests.test_getLogObserverStdoutDaemonc s� t | j�}| �� }td|i�}|�� | �t|�d� | �|d jtj� |�� | �t| j
�d� | �| j
d d t j � 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' )�callbackr0 ��dr0 r1 �rotate s z:UnixAppLoggerTests.test_getLogObserverFile.<locals>.rotateN)r� r; r� r$ r� r` r[ r� r6 r� r� r� �SIGUSR1r r� )rE r� r� r r� Z rotateLogr0 r� r1 r� � s
z*UnixAppLoggerTests.test_getLogObserverFilec sH � fdd�}� � td|� � �� }td|i�}|�� � �� jg � dS )zy
If a signal handler is already installed,
L{UnixAppLogger._getLogObserver} doesn't override it.
c s � � | tj� t� S r' )r` r� r� rc )r� rQ r0 r1 �
fakeGetSignal s zVUnixAppLoggerTests.test_getLogObserverDontOverrideSignalHandler.<locals>.fakeGetSignal� getsignalr� N)r; r� r� r$ r� r` r� )rE r� r� r r0 rQ r1 �,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� r; r$ r� r` r[ r� r6 r� r� r0 r0 r1 � test_getLogObserverDefaultFile s
z1UnixAppLoggerTests.test_getLogObserverDefaultFilec 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� r` )rE r� r r� r0 r0 r1 �test_getLogObserverSyslog- s z,UnixAppLoggerTests.test_getLogObserverSyslogzSyslog not available)rG rH rI rJ r! r� r� r� r� r� r� r� r� r% r0 r0 r0 r1 r� � s
r� c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd 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 )Nr6 r� c W s d S r' r0 r= r0 r0 r1 r� K r� z&DaemonizeTests.setUp.<locals>.<lambda>)r �mockosr rd rh r; r! r# r� r r� rN r� r� r� �stderrr� r� rQ r0 r0 r1 r� C s
zDaemonizeTests.setUpc
C sV t t� �� | j�� W 5 Q R X | �| jjdddddddg� | �| jjddg� d S )
zw
When double fork succeeded in C{daemonize}, the child process writes
B{0} to the status pipe.
�r r' �r� r7 ��forkT�setsid)r� ���� 0��unlinkz
twistd.pid���r� N)r r+ r� rS r` r� �actions�closedrQ r0 r0 r1 � test_successN s ��zDaemonizeTests.test_successc C sh d| j _d| j _tt� �� | �t| jj� W 5 Q R X | � | j j
ddddddg� | � | j j d g� d
S ) z�
The parent process initiating the C{daemonize} call reads data from the
status pipe and then exit the process.
Fr� r� r� r� �r0 ����d ��exitr r� r� N) r� �child�readDatar r+ rt � SystemErrorr� rS r` r� r� rQ r0 r0 r1 �test_successInParent\ s ��z#DaemonizeTests.test_successInParentc s| g � � fdd�}|| j _tt� �� | j�� W 5 Q R X | �| j jddddddg� | �| j jdd g� | �d
d
g� � d S ) 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� �dkr$ttj��d S r$ �ro r[ �IOErrorr� ZEINTR)�fdrs �Zwrittenr0 r1 � raisingWrites s z6DaemonizeTests.test_successEINTR.<locals>.raisingWriter� r� r� r� r� r� r� )r� r� N) r� r� r r+ r� rS r` r� r� )rE r� r0 r� r1 �test_successEINTRl s ��z DaemonizeTests.test_successEINTRc s� g � � fdd�}|| j _d| j _tt� �� | �t| jj� W 5 Q R X | � | j j
dddddg� | � | j j d g� | � d
d
g� � d S ) 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� �dkr$ttj��dS )Nr� r� r� )r� �size�r0 r0 r1 � raisingRead� s
z=DaemonizeTests.test_successInParentEINTR.<locals>.raisingReadFr� r� r� r� r� r� )r� r� N) r� r0 r� r r+ rt r� r� rS r` r� r� )rE r� r0 r� r1 �test_successInParentEINTR� s ��z(DaemonizeTests.test_successInParentEINTRc s� G � fdd�dt j�}|� }|�| jj� tt� �� | �t| jj � W 5 Q R X | �
| j j ddddddd|fd g� | �
| j j
d
dg� d S ) 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 � ��d S r' r� rQ ��raisedr0 r1 r� � s zCDaemonizeTests.assertErrorWritten.<locals>.FakeService.startServiceN)rG rH rI r� r0 r� r0 r1 r� � s r� r� r� r� r� r� r� r� r� N)r rC r� r� rN r r+ rt rm rS r` r� r� r� )rE r �reportedr� Z errorServicer0 r� r1 �assertErrorWritten� s ��z!DaemonizeTests.assertErrorWrittenc C s | 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�r r N�r rQ r0 r0 r1 �
test_error� s �zDaemonizeTests.test_errorc C s | j ddd� dS )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: \u2022r Nr rQ r0 r0 r1 �test_unicodeError� s �z DaemonizeTests.test_unicodeErrorc C s� d| j _|| j _t� }| �td|� tt� �� | �t | j
j � W 5 Q R X | � |�
� |� | � | 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__r� N)r� r� r� r r; r� r r+ rt r� r� rS r` rw r� r� )rE r� � errorMessage�
mockOSActionsZerrorIOr0 r0 r1 �assertErrorInParentBehavior� s z*DaemonizeTests.assertErrorInParentBehaviorc C s | j ddddddddgd � d
S ) 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.
r� r� r� r� �r� r� r� �r� r r N�r
rQ r0 r0 r1 �test_errorInParent� s ��z!DaemonizeTests.test_errorInParentc C s | j ddddddddgd � d
S ) 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� r� r� r r� r Nr
rQ r0 r0 r1 �test_nonASCIIErrorInParent� s ��z)DaemonizeTests.test_nonASCIIErrorInParentc C s4 d}d� d�}| j|d� |�ddddd d
gd � d S )
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� r� r� r r� r N)r� r
)rE ZtruncatedMessageZreportedMessager0 r0 r1 �&test_errorInParentWithTruncatedUnicode s
� ��z5DaemonizeTests.test_errorInParentWithTruncatedUnicodec C s | j ddd� dS )z{
If an error occurs during daemonization and its message is too
long, it's truncated by the child.
Z�xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxsd 1 RuntimeError: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxr Nr rQ r0 r0 r1 �test_errorMessageTruncated s �z)DaemonizeTests.test_errorMessageTruncatedc C s | j ddd� dS )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 r Nr rQ r0 r0 r1 �!test_unicodeErrorMessageTruncated% s �z0DaemonizeTests.test_unicodeErrorMessageTruncatedc C s. t � }| j�|� | �|j� | �|j� dS )z�
C{daemonize} indeed calls L{IReactorDaemonize.beforeDaemonize} and
L{IReactorDaemonize.afterDaemonize} if the reactor implements
L{IReactorDaemonize}.
N)r+ r� r# r} rf rg r% r0 r0 r1 �test_hooksCalled1 s z DaemonizeTests.test_hooksCalledc C s. t � }| j�|� | �|j� | �|j� dS )z�
C{daemonize} does NOT call L{IReactorDaemonize.beforeDaemonize} or
L{IReactorDaemonize.afterDaemonize} if the reactor does NOT implement
L{IReactorDaemonize}.
N)re r� r# r� rf rg r% r0 r0 r1 �test_hooksNotCalled= s z"DaemonizeTests.test_hooksNotCalledN)rG rH rI rJ r� r� r� r� r� r r r r
r r r r r r r r0 r0 r0 r1 r� > s"
r� c @ s e Zd ZdZdS )� SignalCapturingMemoryReactorz�
MemoryReactor that implements the _ISupportsExitSignalCapturing interface,
all other operations identical to MemoryReactor.
Nrl r0 r0 r0 r1 r J 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 t| ��|� d | _d S r' )�superr rZ � _signalValuer~ �� __class__r0 r1 rZ ] s z(StubApplicationRunnerWithSignal.__init__c C s dS )z
Does nothing.
Nr0 rQ r0 r0 r1 rR b s z.StubApplicationRunnerWithSignal.preApplicationc C s$ t � }| j|_| �|tjtj� dS )z`
Instantiate a SignalCapturingMemoryReactor and start it
in the runner.
N)r r r r� r� r� r� r% r0 r0 r1 rS g s z/StubApplicationRunnerWithSignal.postApplication)
rG rH rI rJ rL rT rZ rR rS �
__classcell__r0 r0 r r1 r S 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 )rh r� ��signumr0 r1 � stubApplicationRunnerFactory s zIstubApplicationRunnerFactoryCreator.<locals>.stubApplicationRunnerFactoryr0 )r r r0 r r1 �#stubApplicationRunnerFactoryCreatorr s
r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �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� rQ r0 r1 �fakeKill� s
z+ExitWithSignalTests.setUp.<locals>.fakeKillr� ) r rd rh r@ r� rc r� ri r" r; r6 )rE r# r0 rQ r1 r� � 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� r0 )r� Zhandler�ZfakeSignalArgsr0 r1 � fake_signal� s z<ExitWithSignalTests.test_exitWithSignal.<locals>.fake_signalr� r r� )
r; r� r Z_exitWithSignal�SIGINTr �SIG_DFLr" r6 r� )rE r% r0 r$ r1 �test_exitWithSignal� 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� )r; r r �runApprh rg r" rQ r0 r0 r1 �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) r; r r r� r& r) rh r r" r6 r� rQ r0 r0 r1 �test_runnerExitsWithSignal� s � z.ExitWithSignalTests.test_runnerExitsWithSignalN)rG rH rI rJ r� r( r* r+ r0 r0 r0 r1 r! � s
r! z!twistd unix support not available)lrJ Z
__future__r r r� rD r� r6 r� r5 r8 � ImportErrorZcPickler� Zzope.interfacer Zzope.interface.verifyr Z
twisted.trialr Ztwisted.test.test_processr r� r r r
Ztwisted.applicationr r r
Ztwisted.application.servicer Ztwisted.internet.deferr Ztwisted.internet.interfacesr r Z#twisted.internet.test.modulehelpersr Ztwisted.loggerr r r Ztwisted.internet.baser Ztwisted.test.proto_helpersr Ztwisted.python.compatr r Ztwisted.python.componentsr Ztwisted.pythonr Ztwisted.python.logr� r Ztwisted.python.runtimer Ztwisted.python.usager Ztwisted.python.fakepwdr Ztwisted.scriptsr r! Z twisted.scripts._twistd_unixr" r# r$ r% r rz r� �getattrr r? rc r@ r� rL r� rP ZTestCaserU r� r� r� r� r� r� r r9 r] re r+ r ro r� r� r� r� r� r r r r! r� r0 r0 r0 r1 �<module> s�
.
TG s # N 4 !Q