YfddZddlZddlmZmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZmZdd lmZGd d ZGd d e eZGddejZGddejZdS)z& Tests for L{twisted.runner.procmon}. N) ProcessDoneProcessExitedAlreadyProcessTerminated)Clock) MemoryReactor)globalLogPublisher)Failure)LoggingProtocolProcessMonitor)unittestc:eZdZdZdZdZdZ ddZdZdZ 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 Nrc ||_||_||_||_||_||_||_||_| |_| |_ dSN) proto_reactor _executable_args _environment_path_uid_gid_usePTY _childFDs) selfreactor executableargs environmentpathruidgidusePTYchildFDss R/var/www/html/env/lib/python3.11/site-packages/twisted/runner/test/test_procmon.py__init__zDummyProcess.__init__ sP  % '    !c|jdfdd}|jt||vr3||\}}|j||j||_dSdS)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} rrr)TERMKILLN)_terminationDelaypidrr callLater processEnded_signalHandler)rsignalIDparamsdelaystatuss r& signalProcesszDummyProcess.signalProcess9sx 115vFF 8 &(( ( v  "8,ME6"&-"9"9t(&##D     r(cd|_ttd}|jt |||dS)zC Deliver the process ended event to C{self.proto}. Nr*)r.rrrr0r )rr5 statusMaps r&r0zDummyProcess.processEndedPsS    (9 &(9&(A(A B BCCCCCr()NNrN) __name__ __module__ __qualname____doc__r.rr-r'r6r0r(r&rrsu C E  """"2. D D D D Dr(rc.eZdZdZdZdidddddfdZdS)DummyProcessReactorz @ivar spawnedProcesses: a list that keeps track of the fake process instances built by C{spawnProcess}. @type spawnedProcesses: C{list} cdtj|tj|g|_dSr)rr'rspawnedProcessesrs r&r'zDummyProcessReactor.__init__cs1t$$$ t "r(r=Nrc t|||||||||| } || |j| | S)zz Fake L{reactor.spawnProcess}, that logs all the process arguments and returns a L{DummyProcess}. )rmakeConnectionrAappend) rprocessProtocolrrenvr!r"r#r$r%procs r& spawnProcessz DummyProcessReactor.spawnProcessisc"              &&t,,, $$T*** r()r9r:r;r<r'rIr=r(r&r?r?\sX ###    r(r?ceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"S)# ProcmonTestsz& Tests for L{ProcessMonitor}. ct|_t|j|_d|j_d|j_d|j_dS)zL Create an L{ProcessMonitor} wrapped around a fake reactor. r N)r?rr pmminRestartDelaymaxRestartDelay thresholdrBs r&setUpzProcmonTests.setUpsI+,,  666"#"$r(c|jdddgddit|j}|d||d||d|d S) z+ Repr includes all details fooarg1arg2rrNr"r#rG12N)rP addProcessreprassertInrrepresentations r&test_reprLooksGoodzProcmonTests.test_reprLooksGoodsy 566"2qbIIIdg e^,,, c>*** c>*****r(c|jdddgit|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. rVrWrX)rG()N)rPr\r] assertNotInr_s r&test_simpleReprLooksGoodz%ProcmonTests.test_simpleReprLooksGoodse 566"2;;;dg n--- n-----r(c|jdddgddi||jddddgddifidS) zW The list of monitored processes must be included in the pickle state. rVrWrXrrNrY processesN)rPr\ assertEqual __getstate__rBs r&test_getStateIncludesProcessesz+ProcmonTests.test_getStateIncludesProcessessx 566"2qbIII  G " "; /%66:JAqRT9U1V     r(c`|d|jdS)z~ The private L{ProcessMonitor._reactor} instance variable should not be included in the pickle state. rN)rerPrjrBs r&test_getStateExcludesReactorz)ProcmonTests.test_getStateExcludesReactors. TW%9%9%;%;<<<<??? #f++q)))1Io. 8$Qiay  )%LMMM &(+++ #u%%% $/////r(c\g}|tj|jtj|j|jddg|j|j d| d|jj |j |jj |jj d d|t|d|dd}|dd}|dd}|dd}||d ||d ||d||d d S) zS Getting a complete output line on stderr generates a log message. rVrrrrrrrrstderrrN)rrrrErrPr\rprrqr^rorS errReceivedrrrs r&!test_ouputReceivedCompleteErrLinez.ProcmonTests.test_ouputReceivedCompleteErrLinerr(cVg}|tj|jtj|j|jddg|j|j d| d|jj |j |jj |jj d d|t|d|d}|d}|d}|d}|d}||d ||d ||d||t!d d S) zN Getting invalid UTF-8 results in the repr of the raw message rVrshello world! rrrrrrrs hello world!N)rrrrErrPr\rprrqr^rorSrrrr])rrmessagerrroutputs r&*test_outputReceivedCompleteLineInvalidUTF8z7ProcmonTests.test_outputReceivedCompleteLineInvalidUTF8s *96=III&v}555 55'***  Q eTW./// TW./// % ,,-BCCC #f++q))))O, "en )%LMMM &(+++ #u%%% &$':";";<<<<rs WWWWWWWWWW''''''222222------******BBBBBBBB""""""GDGDGDGDGDGDGDGDT,,,,,-,,,^v0v0v0v0v08$v0v0v0r6C6C6C6C6Cx36C6C6C6C6Cr(