Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/runner/test/__pycache__/test_procmon.cpython-39.pyc
Ðазад
a k�h�a � @ s� d Z ddlZddlmZmZmZ ddlmZ ddlm Z ddl m Z ddl m Z mZ ddlmZ dd lmZ G d d � d �ZG d d � d ee�ZG dd� dej�ZG dd� dej�ZdS )z& Tests for L{twisted.runner.procmon}. � N)� ProcessDone�ProcessExitedAlready�ProcessTerminated)�Clock)�globalLogPublisher)�Failure)�LoggingProtocol�ProcessMonitor)� MemoryReactor)�unittestc @ s6 e Zd ZdZdZdZdZd dd�Zdd� Zd d � Z dS ) � DummyProcessa An incomplete and fake L{IProcessTransport} implementation for testing how L{ProcessMonitor} behaves when its monitored processes exit. @ivar _terminationDelay: the delay in seconds after which the DummyProcess will appear to exit when it receives a TERM signal � Nr c C s@ || _ || _|| _|| _|| _|| _|| _|| _| | _| | _ d S �N) �proto�_reactor� _executable�_args� _environment�_pathZ_uidZ_gidZ_usePTYZ _childFDs) �self�reactor� executable�args� environment�pathr �uid�gid�usePTY�childFDs� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/runner/test/test_procmon.py�__init__ s zDummyProcess.__init__c C sL | j dfdd�}| jdu r t� �||v rH|| \}}| j�|| j|�| _dS )a� A partial implementation of signalProcess which can only handle TERM and KILL signals. - When a TERM signal is given, the dummy process will appear to exit after L{DummyProcess._terminationDelay} seconds with exit code 0 - When a KILL signal is given, the dummy process will appear to exit immediately with exit code 1. @param signalID: The signal name or number to be issued to the process. @type signalID: C{str} r �r r )�TERM�KILLN)�_terminationDelay�pidr r Z callLater� processEndedZ_signalHandler)r ZsignalID�params�delay�statusr r r � signalProcess: s �zDummyProcess.signalProcessc C s, d| _ ttd�}| j�t|| |��� dS )zC Deliver the process ended event to C{self.proto}. Nr" )r& r r r r' r )r r* Z statusMapr r r r' Q s �zDummyProcess.processEnded)NNr N) �__name__� __module__� __qualname__�__doc__r& r r% r! r+ r' r r r r r s � r c @ s0 e Zd ZdZdd� Zdi dddddfdd�ZdS ) �DummyProcessReactorz� @ivar spawnedProcesses: a list that keeps track of the fake process instances built by C{spawnProcess}. @type spawnedProcesses: C{list} c C s t �| � t�| � g | _d S r )r r! r �spawnedProcesses�r r r r r! d s z DummyProcessReactor.__init__r Nr c C s4 t | ||||||||| � } |�| � | j�| � | S )zz Fake L{reactor.spawnProcess}, that logs all the process arguments and returns a L{DummyProcess}. )r ZmakeConnectionr1 �append) r ZprocessProtocolr r �envr r r r r �procr r r � spawnProcessj s � z DummyProcessReactor.spawnProcess)r, r- r. r/ r! r6 r r r r r0 ] s �r0 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"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z!d>d?� Z"d@dA� Z#dBS )C� ProcmonTestsz& Tests for L{ProcessMonitor}. c C s2 t � | _t| jd�| _d| j_d| j_d| j_dS )zL Create an L{ProcessMonitor} wrapped around a fake reactor. �r � � N)r0 r r �pm�minRestartDelay�maxRestartDelay� thresholdr2 r r r �setUp� s zProcmonTests.setUpc C sL | j jdddgddi d� t| j �}| �d|� | �d|� | �d|� d S ) z+ Repr includes all details �foo�arg1�arg2r r9 �r r r4 �1�2N)r; � addProcess�repr�assertIn�r Zrepresentationr r r �test_reprLooksGood� s z ProcmonTests.test_reprLooksGoodc C s< | j jdddgi d� t| j �}| �d|� | �d|� dS )z� Repr does not include unneeded details. Values of attributes that just mean "inherit from launching process" do not appear in the repr of a process. r@ rA rB )r4 �(�)N)r; rF rG � assertNotInrI r r r �test_simpleReprLooksGood� s z%ProcmonTests.test_simpleReprLooksGoodc C sD | j jdddgddi d� | �| j �� d dddgddi fi� dS ) zW The list of monitored processes must be included in the pickle state. r@ rA rB r r9 rC � processesN)r; rF � assertEqual� __getstate__r2 r r r � test_getStateIncludesProcesses� s �z+ProcmonTests.test_getStateIncludesProcessesc C s | � d| j�� � dS )z~ The private L{ProcessMonitor._reactor} instance variable should not be included in the pickle state. r N)rM r; rQ r2 r r r � test_getStateExcludesReactor� s z)ProcmonTests.test_getStateExcludesReactorc C s~ | j jdddgddi d� | �| j ji � | �| j jdddgddi fi� | j �� | j�d� | �t| j j� � �dg� dS ) z� L{ProcessMonitor.addProcess} only starts the named program if L{ProcessMonitor.startService} has been called. r@ rA rB r r9 rC r N) r; rF rP � protocolsrO � startServicer �advance�list�keysr2 r r r �test_addProcess� s z ProcmonTests.test_addProcessc C s> | j jdddgddi d� | jt| j jdddgddi d� dS )z| L{ProcessMonitor.addProcess} raises a C{KeyError} if a process with the given name already exists. r@ rA rB r r9 rC N)r; rF � assertRaises�KeyErrorr2 r r r � test_addProcessDuplicateKeyError� s �z-ProcmonTests.test_addProcessDuplicateKeyErrorc C sP ddi}| j �� | j jddgdd|d� | j�d� | �| jjd j|� dS ) z� L{ProcessMonitor.addProcess} takes an C{env} parameter that is passed to L{IReactorProcess.spawnProcess}. ZKEY�valuer@ r r9 rC r N)r; rU rF r rV rP r1 r )r ZfakeEnvr r r �test_addProcessEnv� s z ProcmonTests.test_addProcessEnvc C sD | j �� | j jddgdd� | j�d� | �| jjd jd� dS )z� L{ProcessMonitor.addProcess} takes an C{cwd} parameter that is passed to L{IReactorProcess.spawnProcess}. r@ z /mnt/lala)�cwdr N)r; rU rF r rV rP r1 r r2 r r r �test_addProcessCwd� s z ProcmonTests.test_addProcessCwdc C sR | j �� | j �ddg� | �t| j j�d� | j �d� | �t| j j�d� dS )zm L{ProcessMonitor.removeProcess} removes the process from the public processes list. r@ r r N)r; rU rF rP �lenrO � removeProcessr2 r r r �test_removeProcess� s z ProcmonTests.test_removeProcessc C s | j �� | �t| j jd� dS )zz L{ProcessMonitor.removeProcess} raises a C{KeyError} if the given process name isn't recognised. r@ N)r; rU rZ r[ rb r2 r r r �!test_removeProcessUnknownKeyError� s z.ProcmonTests.test_removeProcessUnknownKeyErrorc C sH | j �ddg� | j �d� | �| j jd t� | �d| j j�� � dS )a When a process has been started, an instance of L{LoggingProtocol} will be added to the L{ProcessMonitor.protocols} dict and the start time of the process will be recorded in the L{ProcessMonitor.timeStarted} dictionary. r@ N) r; rF � startProcessZassertIsInstancerT r rH � timeStartedrX r2 r r r �test_startProcess� s z ProcmonTests.test_startProcessc C s2 | j �ddg� | j �d� | �| j �d�� dS )zr L{ProcessMonitor.startProcess} silently returns if the named process is already started. r@ N)r; rF re � assertIsNoner2 r r r � test_startProcessAlreadyStarted s z,ProcmonTests.test_startProcessAlreadyStartedc C s | � t| jjd� dS )zy L{ProcessMonitor.startProcess} raises a C{KeyError} if the given process name isn't recognised. r@ N)rZ r[ r; re r2 r r r � test_startProcessUnknownKeyError s z-ProcmonTests.test_startProcessUnknownKeyErrorc C s� | j �� | j �ddg� | �d| j j� d }| j jd j_| j�| j j � | j � d� | j�|� | � | j� � | j j d � dS )zm L{ProcessMonitor.stopProcess} immediately sends a TERM signal to the named process. r@ r N)r; rU rF rH rT � transportr% r rV r> � stopProcessrP �secondsrf )r Z timeToDier r r �"test_stopProcessNaturalTermination s z/ProcmonTests.test_stopProcessNaturalTerminationc C s� | j �� | j �ddg� | �d| j j� | j�| j j� | j jd j}| j j d |_ | j � d� | j�| j j d � | � d| j j d � | j�d� | � | j�� | j j d � dS )z� L{ProcessMonitor.stopProcess} kills a process which fails to terminate naturally within L{ProcessMonitor.killTime} seconds. r@ r g N)r; rU rF rH rT r rV r> rk �killTimer% rl rP rf rm )r r5 r r r �test_stopProcessForcedKill4 s z'ProcmonTests.test_stopProcessForcedKillc C s | � t| jjd� dS )zx L{ProcessMonitor.stopProcess} raises a C{KeyError} if the given process name isn't recognised. r@ N)rZ r[ r; rl r2 r r r � test_stopProcessUnknownKeyErrorJ s z,ProcmonTests.test_stopProcessUnknownKeyErrorc C s& | j �ddg� | �| j �d�� dS )z� L{ProcessMonitor.stopProcess} silently returns if the named process is already stopped. eg Process has crashed and a restart has been rescheduled, but in the meantime, the service is stopped. r@ N)r; rF rh rl r2 r r r � test_stopProcessAlreadyStoppedQ s z+ProcmonTests.test_stopProcessAlreadyStoppedc C s� g }| � tj|j� t�|j� | j�ddg� | j�� | j� d� | � d| jj � | j� | jj � | jj d � d� | �t|�d� |d d }|d d }|d d }|d d }| �|d � | �|d � | �|d� | �|d � d S ) zS Getting a complete output line on stdout generates a log message. r@ r � hello world! r � log_namespace�stream�tag�line�%twisted.runner.procmon.ProcessMonitor�stdout� hello world!N)� addCleanupr �removeObserverr3 � addObserverr; rF rU r rV rH rT r> � outReceived� assertEqualsra �r �events� namespaceru rv rw r r r � test_outputReceivedCompleteLineZ s$ z,ProcmonTests.test_outputReceivedCompleteLinec C s� g }| � tj|j� t�|j� | j�ddg� | j�� | j� d� | � d| jj � | j� | jj � | jj d � d� | �t|�d� |d d }|d d }|d d }|d d }| �|d � | �|d � | �|d� | �|d � d S ) zS Getting a complete output line on stderr generates a log message. r@ r rs r rt ru rv rw rx �stderrrz N)r{ r r| r3 r} r; rF rU r rV rH rT r> Z errReceivedr ra r� r r r �!test_ouputReceivedCompleteErrLineu s$ z.ProcmonTests.test_ouputReceivedCompleteErrLinec C s� g }| � tj|j� t�|j� | j�ddg� | j�� | j� d� | � d| jj � | j� | jj � | jj d � d� | �t|�d� |d }|d }|d }|d }|d }| �|d � | �|d � | �|d� | �|td �� d S ) zN Getting invalid UTF-8 results in the repr of the raw message r@ r s �hello world! r rt ru rv rw rx ry s �hello world!N)r{ r r| r3 r} r; rF rU r rV rH rT r> r~ r ra rG )r r� �messager� ru rv �outputr r r �*test_outputReceivedCompleteLineInvalidUTF8� s& z7ProcmonTests.test_outputReceivedCompleteLineInvalidUTF8c C s g }| � tj|j� t�|j� | j�ddg� | j�� | j� d� | � d| jj � | j� | jj � | jj d � d� | �t|�d� | jj d �ttd��� | �t|�d� |d d }|d d }|d d }|d d }| �|d � | �|d � | �|d� | �|d � d S ) zM Getting partial line results in no events until process end r@ r s hello world!r rt ru rv rw rx ry rz N)r{ r r| r3 r} r; rF rU r rV rH rT r> r~ r ra r' r r r� r r r � test_outputReceivedPartialLine� s( z+ProcmonTests.test_outputReceivedPartialLinec C s� | j �ddg� | j �� | j�d� | �d| j j� | j�| j j� | j jd �t t d��� | � d| j j� | j�d� | �d| j j� dS )z� L{ProcessMonitor.connectionLost} should immediately restart a process if it has been running longer than L{ProcessMonitor.threshold} seconds. r@ r N) r; rF rU r rV rH rT r> r' r r rM r2 r r r �#test_connectionLostLongLivedProcess� s z0ProcmonTests.test_connectionLostLongLivedProcessc C s� | j �ddg� | j �� | j�d� | j �d� | �d| j j� | j jd }| �|� � � | j�| j j d j j � | � |� � � | �d| j j� dS )z� L{ProcessMonitor.connectionLost} cancels a scheduled process killer and deletes the DelayedCall from the L{ProcessMonitor.murder} list. r@ r N)r; rF rU r rV rl rH Zmurder� assertTrue�activerT rk r% � assertFalserM )r Z delayedCallr r r � test_connectionLostMurderCancel� s z,ProcmonTests.test_connectionLostMurderCancelc C sj | j �� | j �ddg� | �d| j j� | j jd j�d� | j�| j jd jj � | � d| j j� dS )z� L{ProcessMonitor.connectionLost} removes the corresponding ProcessProtocol instance from the L{ProcessMonitor.protocols} list. r@ r$ N) r; rU rF rH rT rk r+ r rV r% rM r2 r r r �#test_connectionLostProtocolDeletion� s z0ProcmonTests.test_connectionLostProtocolDeletionc C s� d| j _d| j _| j �� | j �ddg� | �| j jd | j j� | j�| j j d � | j j d � t t d��� | �| j jd | j j� dS )z} L{ProcessMonitor.connectionLost} will wait at least minRestartDelay s and at most maxRestartDelay s r9 � r@ r r N)r; r< r= rU rF rP r) r rV r> rT r' r r r2 r r r �%test_connectionLostMinMaxRestartDelay� s z2ProcmonTests.test_connectionLostMinMaxRestartDelayc C s� | j �� | j �ddg� | j�| j jd � | �d| j j� | �| j j d | j j � | j jd � t t d��� | �| j j d | j j d � dS )z| L{ProcessMonitor.connectionLost} doubles the restart delay each time the process dies too quickly. r@ r r r9 N)r; rU rF r rV r> rH rT rP r) r< r' r r r2 r r r �&test_connectionLostBackoffDelayDoubles s z3ProcmonTests.test_connectionLostBackoffDelayDoublesc C s: | j �ddg� | j �� | j�d� | �d| j j� dS )zP L{ProcessMonitor.startService} starts all monitored processes. r@ r N)r; rF rU r rV rH rT r2 r r r �test_startService s z ProcmonTests.test_startServicec C s� | j �ddg� | j �ddg� | j �� | j�| j j� | �d| j j� | �d| j j� | j�d� | j �� | j�| j j d � | � i | j j� dS )zT L{ProcessMonitor.stopService} should stop all monitored processes. r@ �barr N) r; rF rU r rV r> rH rT � stopServicero rP r2 r r r �test_stopService' s z ProcmonTests.test_stopServicec C sl | j �ddg� | j �� | j�d� | j �� | j�d� t| jj�}|�� }| � |g � | � |j � dS )zR L{ProcessMonitor.restartAll} succeeds when there is one process. r@ r N) r; rF rU r rV Z restartAllrW r1 �popr rh r& )r rO Z myProcessr r r �!test_restartAllRestartsOneProcess= s z.ProcmonTests.test_restartAllRestartsOneProcessc C s� | j �ddg� | j �� | j�| j j� | �d| j j� | j�d� | j jd �t t d��� | � | j j d � � � | j �� | �| j j d � � � dS )ze L{ProcessMonitor.stopService} should cancel any scheduled process restarts. r@ r r N)r; rF rU r rV r> rH rT r' r r r� Zrestartr� r� r� r2 r r r � test_stopServiceCancelRestartsM s z+ProcmonTests.test_stopServiceCancelRestartsc C sx d| j _d| j _| j �� | j �ddg� | j�d� | j �d� | j�d� | j �� | j�d� | � | j j i � dS )ze L{ProcessMonitor.stopService} should cancel all scheduled process restarts. � r@ r � N) r; r> r< rU rF r rV rl r� rP rT r2 r r r �(test_stopServiceCleanupScheduledRestartsa s z5ProcmonTests.test_stopServiceCleanupScheduledRestartsN)$r, r- r. r/ r? rJ rN rR rS rY r\ r^ r` rc rd rg ri rj rn rp rq rr r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r7 � sB r7 c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �DeprecationTestszQ Tests that check functionality that should be deprecated is deprecated. c C s t � | _t| jd�| _dS )z5 Create reactor and process monitor. r8 N)r0 r r r; r2 r r r r? s zDeprecationTests.setUpc C sx | j �ddg� | j j}| �t|�d� | �� }d}|D ]$}| �|d t� d|d v r8d}q8| �|dt |�� �� d S ) a _Process.toTuple is deprecated. When getting the deprecated processes property, the actual data (kept in the class _Process) is converted to a tuple -- which produces a DeprecationWarning per process so converted. r@ r F�categoryZtoTupler� Tzno tuple deprecation found:N) r; rF rO r ra � flushWarnings�assertIs�DeprecationWarningr� rG )r Z myprocesses�warningsZ foundToTuple�warningr r r � test_toTuple� s z DeprecationTests.test_toTuplec C sF | j j}| �|i � | �� }|�d�}| �|d t� | �|g � dS )a Accessing L{ProcessMonitor.processes} results in deprecation warning Even when there are no processes, and thus no process is converted to a tuple, accessing the L{ProcessMonitor.processes} property should generate its own DeprecationWarning. r r� N)r; rO r r� r� r� r� )r Z myProcessesr� �firstr r r �test_processes� s z DeprecationTests.test_processesc C s2 t �| j� | �� }|D ]}| �|d t� qdS )zO Pickling an L{ProcessMonitor} results in deprecation warnings r� N)�pickle�dumpsr; r� r� r� )r r� r� r r r � test_getstate� s z DeprecationTests.test_getstateN)r, r- r. r/ r? r� r� r� r r r r r� y s r� )r/ r� Ztwisted.internet.errorr r r Ztwisted.internet.taskr Ztwisted.loggerr Ztwisted.python.failurer Ztwisted.runner.procmonr r Ztwisted.test.proto_helpersr Z twisted.trialr r r0 ZTestCaser7 ZSynchronousTestCaser� r r r r �<module> s K/ p
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка