| 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/application/runner/test/__pycache__/ |
Upload File : |
o
�b�8 � @ sd d Z ddlZddlmZ ddlmZ ddlmZ ddlm Z m
Z
m Z m Z m
Z
mZmZmZmZ ddlmZmZmZ ddlZddlmZ dd lmZm Z m Z m Z m Z m Z m!Z! dd
l"m#Z# d d l$m%Z% d
dl&m'Z' d
dl(m)Z)m*Z* d
dl%m+Z+ G dd� dej,j-j.�Z/edd�G dd� de+��Z0G dd� de)�Z1G dd� d�Z2G dd � d �Z3G d d � d �Z4G d d � d �Z5dS )!z2
Tests for L{twisted.application.runner._runner}.
� N)�StringIO)�SIGTERM)�
TracebackType) �Any�Iterable�List�Optional�TextIO�Tuple�Type�Union�cast)�Factory�attrib�attrs)�
MemoryReactor)�FileLogObserver�FilteringLogObserver� ILogObserver� LogBeginner�LogLevel�LogLevelFilterPredicate� LogPublisher)�FilePath� )�_runner� )�
ExitStatus)� NonePIDFile�PIDFile)�Runnerc @ s� e Zd ZdZd)dee defdd�Zd*dd�Zd*d d
�Z d*d d �Z
d*d
d�Z d*dd�Z d*dd�Z
d*dd�Zd*dd�Zd*dd�Zd*dd�Zd*dd �Zd*d d �Zd*d d �Zd*d!d"�Zd*d#d$�Zd)d%ed&ee ddfd'd(�ZdS )+� RunnerTestsz
Tests for L{Runner}.
N�content�returnc C s" t | �� �}|d ur|�|� |S �N)r �mktemp�
setContent)�selfr" �filePath� r) �M/usr/lib/python3/dist-packages/twisted/application/runner/test/test_runner.pyr( ' s
zRunnerTests.filePathc C s� t � | _t� | _| �td| j� | �td| j� d| _| j� d��� | _t � | _
t � | _ t | j
| j �| _
t� | _t� | _t| j| j
j | j
| j�| _| �td| j � | �td| j� d S )N�exit�killi9 �
�stderr�globalLogBeginner)� DummyExitr+ � DummyKillr, �patchr �pid�encode�pidFileContentr �stdoutr. �DummyStandardIO�stdio�DummyWarningsModule�warningsr �globalLogPublisherr r/ �r' r) r) r* �setUp- s& �zRunnerTests.setUpc C s* t t� d�}|�� | �|jg d�� dS )zD
L{Runner.run} calls the expected methods in order.
��reactor)�killIfRequested� startLogging� startReactor�
reactorExitedN)� DummyRunnerr �run� assertEqual�
calledMethods�r' �runnerr) r) r* �test_runInOrderO s �zRunnerTests.test_runInOrderc C sP t � }tt� |d�}| �|j� | �|j� |�� | �|j� | �|j� dS )z;
L{Runner.run} uses the provided PID file.
�r? �pidFileN)� DummyPIDFiler r � assertFalse�entered�exitedrE �
assertTrue�r' rL rI r) r) r* �test_runUsesPIDFile` s z RunnerTests.test_runUsesPIDFilec C sV t | �| j��}dd� |_tt� |d�}|�� | �| jj t
j � | �| jj d� dS )z�
L{Runner.run} exits with L{ExitStatus.EX_USAGE} and the expected
message if a process is already running that corresponds to the given
PID file.
c S � dS �NTr) r) r) r) r* �<lambda>w � z4RunnerTests.test_runAlreadyRunning.<locals>.<lambda>rK zAlready running.N)
r r( r5 � isRunningr r rE rF r+ �statusr � EX_CONFIG�messagerR r) r) r* �test_runAlreadyRunningp s
z"RunnerTests.test_runAlreadyRunningc C s6 t t� d�}|�� | �| jjg � | �| jj� dS )z�
L{Runner.killIfRequested} when C{kill} is false doesn't exit and
doesn't indiscriminately murder anyone.
r> N) r r r@ rF r, �callsrN r+ rP rH r) r) r* �test_killNotRequested s z!RunnerTests.test_killNotRequestedc C sL t t� dd�}|�� | �| jjg � | �| jjtj � | �| jj
d� dS )z�
L{Runner.killIfRequested} when C{kill} is true but C{pidFile} is
L{nonePIDFile} exits with L{ExitStatus.EX_USAGE} and the expected
message; and also doesn't indiscriminately murder anyone.
T)r? r, zNo PID file specified.N) r r r@ rF r, r] r+ rY r �EX_USAGEr[ rH r) r) r* � test_killRequestedWithoutPIDFile� s
z,RunnerTests.test_killRequestedWithoutPIDFilec C sf t | �| j��}tt� d|d�}|�� | �| jj| j t
fg� | �| j j t
j� | �| j jd� dS )z�
L{Runner.killIfRequested} when C{kill} is true and given a C{pidFile}
performs a targeted killing of the appropriate process.
T�r? r, rL N)r r( r5 r r r@ rF r, r] r3 r r+ rY r �EX_OK�assertIdenticalr[ rR r) r) r* � test_killRequestedWithPIDFile� s z)RunnerTests.test_killRequestedWithPIDFilec C s` t | �d��}dtfdd�}||_tt� d|d�}|�� | �| jj t
j � | �| jj d� dS )z�
L{Runner.killIfRequested} when C{kill} is true and given a C{pidFile}
that it can't read exits with L{ExitStatus.EX_IOERR}.
Nr# c S s t tjd��)NzPermission denied)�OSError�errno�EACCESr) r) r) r* �read� s z?RunnerTests.test_killRequestedWithPIDFileCantRead.<locals>.readTra zUnable to read PID file.)
r r( �intrh r r r@ rF r+ rY r �EX_IOERRr[ )r' rL rh rI r) r) r* �%test_killRequestedWithPIDFileCantRead� s z1RunnerTests.test_killRequestedWithPIDFileCantReadc C �L t | �d��}tt� d|d�}|�� | �| jjtj � | �| jj
d� dS )z�
L{Runner.killIfRequested} when C{kill} is true and given a C{pidFile}
containing no value exits with L{ExitStatus.EX_DATAERR}.
� Tra �Invalid PID file.N� r r( r r r@ rF r+ rY r �
EX_DATAERRr[ rR r) r) r* �"test_killRequestedWithPIDFileEmpty� �
z.RunnerTests.test_killRequestedWithPIDFileEmptyc C rl )z�
L{Runner.killIfRequested} when C{kill} is true and given a C{pidFile}
containing a non-integer value exits with L{ExitStatus.EX_DATAERR}.
s ** totally not a number, dude **Tra rn Nro rR r) r) r* �%test_killRequestedWithPIDFileNotAnInt� rr z1RunnerTests.test_killRequestedWithPIDFileNotAnIntc s t � }G � fdd�d�� | �td� � � G �fdd�dt��| �td�� G �fdd�dt��tt� tj|�d �}|� � | �
t � j �d
� | �
� j d t� | �
t �j�d
� | �
�jd t� | ��jd jtj� t��j�}| �
|�� | �|j|� d S )
z�
L{Runner.startLogging} sets up a filtering observer with a log level
predicate set to the given log level that contains a file observer of
the given type which writes to the given file.
c s8 e Zd ZU g Zee ed< dee ddf� fdd� ZdS )z2RunnerTests.test_startLogging.<locals>.LogBeginner� observersr# Nc s t |�� _d S r$ )�listrt )r' rt �r r) r* �beginLoggingTo� � zARunnerTests.test_startLogging.<locals>.LogBeginner.beginLoggingTo) �__name__�
__module__� __qualname__rt r r �__annotations__r rw r) rv r) r* r � s
r r/ c sZ e Zd ZU dZee ed< g Zee ed< e
edd� �fdede e def� fdd�
Z dS ) z?RunnerTests.test_startLogging.<locals>.MockFilteringLogObserverN�observer�
predicatesc S s d S r$ r) )�eventr) r) r* rV � rW zHRunnerTests.test_startLogging.<locals>.MockFilteringLogObserver.<lambda>�negativeObserverc s$ |� _ t|�� _t�| |||� d S r$ )r} ru r~ r �__init__)r' r} r~ r� ��MockFilteringLogObserverr) r* r� � s
�zHRunnerTests.test_startLogging.<locals>.MockFilteringLogObserver.__init__)
ry rz r{ r} r r r| r~ r r r
r r� r) r� r) r* r� � s
����r� r c s4 e Zd ZU dZee ed< deddf� fdd� ZdS )z:RunnerTests.test_startLogging.<locals>.MockFileLogObserverN�outFiler# c s |� _ t�| |t� d S r$ )r� r r� �str)r' r� ��MockFileLogObserverr) r* r� � s zCRunnerTests.test_startLogging.<locals>.MockFileLogObserver.__init__)ry rz r{ r� r r r| r� r) r� r) r* r� � s
r� )r? �defaultLogLevel�logFile�fileLogObserverFactory� r N)r r2 r r r r r r �criticalrA rF �lenrt �assertIsInstancer~ r rc r� r
r} r� )r' r� rI r} r) )r r� r� r* �test_startLogging� s2 �
�� z RunnerTests.test_startLoggingc C s( t � }t|d�}|�� | �|j� dS )ze
L{Runner.startReactor} with the C{reactor} argument runs the given
reactor.
r> N)r r rB rQ �hasRun)r' r? rI r) r) r* � test_startReactorWithReactor s
z(RunnerTests.test_startReactorWithReactorc C s | � dd� dS )z�
L{Runner.startReactor} ensures that C{whenRunning} is called with
C{whenRunningArguments} when the reactor is running.
� whenRunningrB N�� _testHookr< r) r) r* � test_startReactorWhenRunning& s z(RunnerTests.test_startReactorWhenRunningc C � | � d� dS )zb
L{Runner.whenRunning} calls C{whenRunning} with
C{whenRunningArguments}.
r� Nr� r< r) r) r* � test_whenRunningWithArguments- � z)RunnerTests.test_whenRunningWithArgumentsc C r� )zf
L{Runner.whenRunning} calls C{reactorExited} with
C{reactorExitedArguments}.
rC Nr� r< r) r) r* � test_reactorExitedWithArguments4 r� z+RunnerTests.test_reactorExitedWithArguments�
methodName�
callerNamec s� |du r|}t t� t� t� d�}g � dtddf� fdd� }|||� d�|�� i}td dt� i|��}t||�}|� | �t� �d � | �� d
|� dS ) a�
Verify that the named hook is run with the expected arguments as
specified by the arguments used to create the L{Runner}, when the
specified caller is invoked.
@param methodName: The name of the hook to verify.
@param callerName: The name of the method that is expected to cause the
hook to be called.
If C{None}, use the L{Runner} method with the same name as the
hook.
N)�a�b�c� argumentsr# c s � � | � d S r$ )�append)r� ��
argumentsSeenr) r* �hookN rx z#RunnerTests._testHook.<locals>.hook� Argumentsr? r� r r) )�dict�object�copyr r �getattrrF r� )r' r� r� r� r� �runnerArgumentsrI �
hookCallerr) r� r* r� ; s"
���
zRunnerTests._testHookr$ �r# N)ry rz r{ �__doc__r �bytesr r( r= rJ rS r\ r^ r` rd rk rq rs r� r� r� r� r� r� r� r) r) r) r* r! " s&
"
M
r! T)�frozenc @ sL e Zd ZdZeee ee�d�Z d
dd�Z
d
dd�Z d
d d
�Z d
d d �Z
dS )rD zg
Stub for L{Runner}.
Keep track of calls to some methods without actually doing anything.
)�type�defaultr# Nc C � | j �d� d S )Nr@ �rG r� r< r) r) r* r@ j � zDummyRunner.killIfRequestedc C r� )NrA r� r< r) r) r* rA m r� zDummyRunner.startLoggingc C r� )NrB r� r< r) r) r* rB p r� zDummyRunner.startReactorc C r� )NrC r� r< r) r) r* rC s r� zDummyRunner.reactorExitedr� )ry rz r{ r� r r r� r ru rG r@ rA rB rC r) r) r) r* rD ` s
rD c @ sN e Zd ZdZd
dd�Zddd�Zdeee d ee d
ee ddfd d �Z
dS )rM z]
Stub for L{PIDFile}.
Tracks context manager entry/exit without doing anything.
r# Nc C s t �| � d| _d| _d S �NF)r r� rO rP r< r) r) r* r� ~ s
zDummyPIDFile.__init__c C s
d| _ | S rU )rO r< r) r) r* � __enter__� s zDummyPIDFile.__enter__�excType�excValue� tracebackc C �
d| _ d S rU �rP )r' r� r� r� r) r) r* �__exit__� s
zDummyPIDFile.__exit__r� )r# rM ) ry rz r{ r� r� r� r r �
BaseExceptionr r� r) r) r) r* rM w s
����rM c @ s@ e Zd ZdZd
dd�Z d deeef dee ddfdd �Z
dS ) r0 zy
Stub for L{_exit.exit} that remembers whether it's been called and, if it has,
what arguments it was given.
r# Nc C r� r� r� r< r) r) r* r� � �
zDummyExit.__init__rY r[ c C s | j rJ �|| _|| _d| _ d S rU )rP rY r[ )r' rY r[ r) r) r* �__call__� s
zDummyExit.__call__r� r$ ) ry rz r{ r� r� r ri r r r� r� r) r) r) r* r0 � s
�
���r0 c @ s0 e Zd ZdZd
dd�Zdededdfdd �ZdS ) r1 zv
Stub for L{os.kill} that remembers whether it's been called and, if it has,
what arguments it was given.
r# Nc C s
g | _ d S r$ )r] r< r) r) r* r� � r� zDummyKill.__init__r3 �sigc C s | j �||f� d S r$ )r] r� )r' r3 r� r) r) r* r� � s zDummyKill.__call__r� )ry rz r{ r� r� ri r� r) r) r) r* r1 � s
r1 c @ �& e Zd ZdZdededdfdd�ZdS )r7 zR
Stub for L{sys} which provides L{StringIO} streams as stdout and stderr.
r6 r. r# Nc C s || _ || _d S r$ )r6 r. )r' r6 r. r) r) r* r� � s
zDummyStandardIO.__init__)ry rz r{ r� r r� r) r) r) r* r7 � � r7 c @ r� )r9 zV
Stub for L{warnings} which provides a C{showwarning} method that is a no-op.
�args�kwargsr# Nc O rT )z\
Do nothing.
@param args: ignored.
@param kwargs: ignored.
Nr) )r� r� r) r) r* � showwarning� rW z DummyWarningsModule.showwarning)ry rz r{ r� r r� r) r) r) r* r9 � r� r9 )6r� rf �ior �signalr �typesr �typingr r r r r r
r r r
�attrr r r �twisted.trial.unittest�twisted�twisted.internet.testingr �twisted.loggerr r r r r r r �twisted.python.filepathr rI r �_exitr �_pidfiler r r �trial�unittest�TestCaser! rD rM r0 r1 r7 r9 r) r) r) r* �<module> s2 , $ @