֛hnkZSrSSKJr SSKrSSKrSSKrSSKJrJrJ r J r J r SSK J r SSKJrJrJr SSKJrJr SSKJr SS KJr SS KJr SS KJr SS KJrJr SS K J!r! \ "\5"SS55r""SS\\5r#"SS\!RH5r%"SS\!RL5r'g)z& Tests for L{twisted.runner.procmon}. ) annotationsN)AnyStrMappingOptionalSequenceUnion) implementer) ProcessDoneProcessExitedAlreadyProcessTerminated)IProcessProtocolIProcessTransport)Clock) MemoryReactor)globalLogPublisher)Failure)LoggingProtocolProcessMonitor)unittestcB\rSrSrSrSrSrSrS SjrSr Sr Sr g) 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 Nc |X`lXlX lX0lX@lXPlXplXlXlXl gN) proto_reactor _executable_args _environment_path_uid_gid_usePTY _childFDs) selfreactor executableargs environmentpathruidgidusePTYchildFDss dC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/runner/test/test_procmon.py__init__DummyProcess.__init__)s8  % '    !cURS4SS.nURc [5eX;a2X!up4URR X0R U5Ulgg)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)_terminationDelaypidr r callLater processEnded_signalHandler)r&signalIDparamsdelaystatuss r0 signalProcessDummyProcess.signalProcessBsc 1115vF 88 &( (  ",ME"&--"9"9((&#D  r3cSUl[[S.nURR [ X!"U555 g)z3 Deliver the process ended event to C{self.proto}. Nr5)r9r r rr;r)r&r@ statusMaps r0r;DummyProcess.processEndedYs9    (9&(A BCr3) rr%r rr#r!rr<r"r$r9r)NNrN) __name__ __module__ __qualname____firstlineno____doc__r9rr8r1rAr;__static_attributes__r3r0rrs7 C E  "2. Dr3rcx\rSrSr%SrS\S'S\S'S SjrS S S jjrS rg)DummyProcessReactorez @ivar spawnedProcesses: a list that keeps track of the fake process instances built by C{spawnProcess}. @ivar spawnProcessException: An exception which spawnProcess() will raise. zlist[DummyProcess]spawnedProcesseszException | NonespawnProcessExceptioncx[R"U5 [R"U5 /UlSUlgr)rr1rrPrQr&s r0r1DummyProcessReactor.__init__ps,t$ t "%)"r3Nc URb URe[UUUUUUUUUU 5 n URU 5 URR U 5 U $)zb Fake L{reactor.spawnProcess}, that logs all the process arguments and returns a L{DummyProcess}. )rQrmakeConnectionrPappend) r&processProtocolr(r)envr+r,r-r.r/procs r0 spawnProcess DummyProcessReactor.spawnProcessvsm  % % 1,, ,             &&t, $$T* r3)rQrPreturnNone)NNNNFN)rXr r(zUnion[bytes, str]r)zSequence[Union[bytes, str]]rYz!Optional[Mapping[AnyStr, AnyStr]]r+zUnion[None, bytes, str]r, Optional[int]r-r`r.boolr/z'Optional[Mapping[int, Union[int, str]]]r^r) rFrGrHrIrJ__annotations__r1r[rKrLr3r0rNrNes)(++*26(,!!<@!)!&!* ! / ! & !!!!:! !!r3rNc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrS'SjrS'SjrSrSrSrSrSrSrSrSrSrSrSrSr Sr!S r"S!r#S"r$S#r%S$r&S%r'g&)( ProcmonTestsz Tests for L{ProcessMonitor}. c[5Ul[URS9UlSURlSURlSURlg)z< Create an L{ProcessMonitor} wrapped around a fake reactor. r' N)rNr'rpmminRestartDelaymaxRestartDelay thresholdrSs r0setUpProcmonTests.setUpsB+,  6"#"$r3cURRSSS/SS0S9 [UR5nURSU5 URSU5 URSU5 g ) z Repr includes all details fooarg1arg2rrhr,r-rY12N)rj addProcessreprassertInr&representations r0test_reprLooksGoodProcmonTests.test_reprLooksGoods] 566"2qbIdgg e^, c>* c>*r3cURRSSS/0S9 [UR5nURSU5 URSU5 g)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. rqrrrs)rY()N)rjrwrx assertNotInrzs r0test_simpleReprLooksGood%ProcmonTests.test_simpleReprLooksGoodsO 566"2;dgg n- n-r3cURRSSS/SS0S9 URURR5SSSS/SS0405 g) zG The list of monitored processes must be included in the pickle state. rqrrrsrrhrt processesN)rjrw assertEqual __getstate__rSs r0test_getStateIncludesProcesses+ProcmonTests.test_getStateIncludesProcessess_ 566"2qbI  GG "; /%66:JAqRT9U1V r3cXURSURR55 g)zf The private L{ProcessMonitor._reactor} instance variable should not be included in the pickle state. rN)rrjrrSs r0test_getStateExcludesReactor)ProcmonTests.test_getStateExcludesReactors! TWW%9%9%;Br3c[S5URlURR SS/5 UR [URR S5 g)za L{IReactorProcess.spawnProcess} might raise C{OSError}, ensure other exceptions are not caught. zJust another exceptionrqN) SystemErrorr'rQrjrwrrrSs r0'test_startProcessSpawnUncaughtException4ProcmonTests.test_startProcessSpawnUncaughtException9sH .99Q-R * 55'* +tww';';UCr3cURR5 URRSS/5 URSURR5 S=oRRSR lURRURR5 URRS5 URRU5 URRS5 URURR5URRS5 g)zU L{ProcessMonitor.stopProcess} immediately sends a TERM signal to the named process. rqrrN)rjrrwryr transportr8r'rrm stopProcessrsecondsr)r& timeToDies r0"test_stopProcessNaturalTermination/ProcmonTests.test_stopProcessNaturalTerminationBs  55'* eTWW../LML GG%%e,66H TWW../ E" Y' Q --/1D1DU1KLr3c|URR5 URRSS/5 URSURR5 UR R URR5 URRSRnURRS-Ul URRS5 UR R URRS- 5 URSURRS5 UR R S5 UR RSS/5 URUR R5URRS5 g)z} L{ProcessMonitor.stopProcess} kills a process which fails to terminate naturally within L{ProcessMonitor.killTime} seconds. rqrgrN)rjrrwryrr'rrmrkillTimer8rrrpumpr)r&rZs r0test_stopProcessForcedKill'ProcmonTests.test_stopProcessForcedKill`s9  55'* eTWW../ TWW../ww  '11!%!1!1A!5 E" TWW--12 dgg11%89 Q 1a&! --/1D1DU1KLr3cZUR[URRS5 g)z` L{ProcessMonitor.stopProcess} raises a C{KeyError} if the given process name isn't recognised. rqN)rrrjrrSs r0test_stopProcessUnknownKeyError,ProcmonTests.test_stopProcessUnknownKeyError}s (DGG$7$7?r3cURRSS/5 URURRS55 g)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. rqN)rjrwrrrSs r0test_stopProcessAlreadyStopped+ProcmonTests.test_stopProcessAlreadyStoppeds7 55'* $''--e45r3c@/nUR[RUR5 [R"UR5 UR R SS/5 UR R5 URRS5 URSUR R5 URRUR R5 UR RSRS5 UR[U5S5 USSnUSSnUSSnUSSnURUS 5 URUS 5 URUS5 URUS 5 g ) zC Getting a complete output line on stdout generates a log message. rqr hello world! r log_namespacestreamtagline%twisted.runner.procmon.ProcessMonitorstdout hello world!N) addCleanuprremoveObserverrW addObserverrjrwrr'rryrrm outReceivedrrr&events namespacerrrs r0test_outputReceivedCompleteLine,ProcmonTests.test_outputReceivedCompleteLineK *996==I&&v}}5 55'*  Q eTWW../ TWW../ % ,,->? #f+q)1Io. 8$Qiay  )%LM &(+ #u% $/r3c@/nUR[RUR5 [R"UR5 UR R SS/5 UR R5 URRS5 URSUR R5 URRUR R5 UR RSRS5 UR[U5S5 USSnUSSnUSSnUSSnURUS 5 URUS 5 URUS5 URUS 5 g ) zC Getting a complete output line on stderr generates a log message. rqrrrrrrrrstderrrN)rrrrWrrjrwrr'rryrrm errReceivedrrrs r0!test_ouputReceivedCompleteErrLine.ProcmonTests.test_ouputReceivedCompleteErrLinerr3cD/nUR[RUR5 [R"UR5 UR R SS/5 UR R5 URRS5 URSUR R5 URRUR R5 UR RSRS5 UR[U5S5 USnUSnUSnUSnUSnURUS 5 URUS 5 URUS5 URU[!S 55 g ) z> Getting invalid UTF-8 results in the repr of the raw message rqrshello world! rrrrrrrs hello world!N)rrrrWrrjrwrr'rryrrmrrrrx)r&rmessagerrroutputs r0*test_outputReceivedCompleteLineInvalidUTF87ProcmonTests.test_outputReceivedCompleteLineInvalidUTF8sH *996==I&&v}}5 55'*  Q eTWW../ TWW../ % ,,-BC #f+q))O, "en )%LM &(+ #u% &$':";rNs# ==&WWK'2-*B" GDGD GDT2-2jO08$$O0d5Cx335Cr3