כh$!VSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r \ r \rSSK J r SSKJr SSKJr SSKJr SSKJrJrJr SSKJrJrJr SS KJr SS KJr SS K J!r! SS K"J#r#J$r$ SS K%J&r& SSK'J(r( SSK)J*r*J+r+J,r, SSK-J.r. SSK/J0r0 SSK1J2r2 SSK3J*r4J5r5 SSK6J7r7 SSK8J9r9 SSK:J;r; SSKJ?r? SSK@JArA \7"S5rB\B(a SSKCJDrDJErEJFrF \7"S5rG\7"S5rH\7"S5rI\7"S5rJS rK"S!S"5rL"S#S$\R5rN"S%S&\=R5rP"S'S(\A5rQ\"\B(+S)5"S*S+\A55rR"S,S-\A5rS"S.S/5rT"S0S1\R5rV"S2S3\A5rW\"\B(+S)5"S4S5\A55rX\"\B(+S)5"S6S7\A55rY\"\B(+S)5"S8S9\A55rZ"S:S;5r[\"\#5"S<S=\[55r\"S>S?5r]"S@SA\A5r^SBr_SCr`"SDSE\A5ra\"\B(+S)5"SFSG\A55rb\"\B(+SH5"SISJ\A55rc\"\$5"SKSL\(55rd"SMSN\=R5reSOrf"SPSQ\A5rgg!\ a Sr SrGNf=f)RzE Tests for L{twisted.application.app} and L{twisted.scripts.twistd}. N)StringIO)skipIf) implementer) verifyObject)internetloggerplugin)appreactorsservice) IServiceMaker) ReactorBase)Deferred)IReactorDaemonize_ISupportsExitSignalCapturing)AlternateReactor) MemoryReactor) ILogObserverglobalLogBeginnerglobalLogPublisher)util) Componentized) UserDatabase)rtextFromEventDict) requireModule) platformType) UsageError)twistd)MockOS)TestCaseztwisted.scripts._twistd_unix)UnixApplicationRunner UnixAppLoggercheckPIDztwisted.python.syslogprofilepstatscProfilec ^^^[R[R"55n[R [R "55m[5nURXRUTURURUR5 UUU4SjnU"[SUR5 U"[SU5 U"[SUR5 g)a= 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>[T5nTXRTR5'TXRTR5'[ U5nTU0U$N)listindexgr_namegr_gidtuple)nameresultgidgrentgroups \C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/test/test_twistd.pygetgrnam#patchUserDatabase..getgrnamdsNe.3||EMM*+-0||ELL)*vvt$$getpwnamr5getpwuidN)pwdr9osgetuidgrpgetgrgidgetgidraddUser pw_passwdpw_gecospw_dirpw_shellr8) patchuseruidr3r1pwentdatabaser5r2s `` @r4patchUserDatabaserJCs2 LL %E LL %E~H  oosCu~~% #z8,,- #z8$ #z8,,-r7c"\rSrSrSrSrSrSrg)MockServiceMakerpzG A non-implementation of L{twisted.application.service.IServiceMaker}. ueoacZXl[R"5UlUR$)zM Take a L{usage.Options} instance and return a L{service.IService} provider. )optionsr ServiceselfrPs r4 makeServiceMockServiceMaker.makeServicews!  ( ||r7)rPr N)__name__ __module__ __qualname____firstlineno____doc__tapnamerT__static_attributes__r7r4rLrLpsGr7rLc\rSrSrSrSrSrg)CrippledAppLoggerz" @see: CrippledApplicationRunner. cgr)r]rS applications r4startCrippledAppLogger.start r7r]N)rVrWrXrYrZrdr\r]r7r4r_r_s  r7r_c(\rSrSrSr\rSrSrSr g)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. cgr)r]rSs r4preApplication(CrippledApplicationRunner.preApplicationrfr7cgr)r]rks r4postApplication)CrippledApplicationRunner.postApplicationrfr7r]N) rVrWrXrYrZr_ loggerFactoryrlror\r]r7r4rhrhs &M  r7rhc\rSrSrSrSrSrSrSrSr \ "\ (+S5S 5r \ "\ (+S5S 5r \ "\ (+S5S 5rS rS rSrSrSrg)ServerOptionsTestszL Non-platform-specific tests for the platform-specific ServerOptions class. c(^^ ^ ^^"SS5nU"S5m U"S5m U"S5mU"S5mU U UUU4Sjn[R"5nTRUR[R 5 X#lUR nT T TT/n[XE5HsupgUuppTRXR5 TRU 5 TRU "5UR54 TRXR5 Mu g) zP subCommands is built from IServiceMaker plugins, and is sorted alphabetically. c \rSrSrSrSrSrg)7ServerOptionsTests.test_subCommands..FakePluginc8XlSU-UlSU-Ulg)Nz options for description of )r[_options descriptionrSr/s r4__init__@ServerOptionsTests.test_subCommands..FakePlugin.__init__s # . 5 #4t#; r7cUR$r))r{rks r4rP?ServerOptionsTests.test_subCommands..FakePlugin.optionss }}$r7)r{r|r[N)rVrWrXrYr~rPr\r]r7r4 FakePluginrws  <  %r7rapplebananacoconutdonutc3Z># TRU[5 Tv Tv Tv Tv g7fr)) assertEqualr ) interfacerrrrrSs r4 getPlugins7ServerOptionsTests.test_subCommands..getPluginss*   Y 6MLKKs(+N) r ServerOptionsr _getPluginsr r subCommandszipr[ assertIsNoner{r|)rSrrconfigr expectedOrder subCommandexpectedCommandr/shortcut parserClass documentationrrrrs` @@@@r4test_subCommands#ServerOptionsTests.test_subCommandss  % %7#H%Y'7#  %%' ++V->->?'(( 7 +.{+J 'J9C 6DK   T#:#: ;   h '   []O,D,D E F   ],G,G H ,Kr7cd^^^^^ ^ ^ "SS5nU"S5mU"S5mU"S5mU"S5m UUUU 4Sjn[R"5nTRUR[R 5 X#l[ 5UlTR[URS/5 URR5m /m TTTT 4H/nU U U4S jnU"UR5 U"UR5 M1 TRT [T 5S RT 55 g ) z@ Reactor names are listed alphabetically by I{--help-reactors}. c\rSrSrSrSrg)GServerOptionsTests.test_sortedReactorHelp..FakeReactorInstallerc:SU-UlSU-UlSUlg)Nzname of rzztwisted.internet.default) shortNamer| moduleNamer}s r4r~PServerOptionsTests.test_sortedReactorHelp..FakeReactorInstaller.__init__s"!+d!2#4t#; "<r7)r|rrN)rVrWrXrYr~r\r]r7r4FakeReactorInstallerrs =r7rrrrrc3.># Tv Tv Tv Tv g7fr)r])rrrrsr4getReactorTypesBServerOptionsTests.test_sortedReactorHelp..getReactorTypessMLKKsz--help-reactorscj>TRUT5 TRTRU55 gr))assertInappendr+)s helpOutputindexesrSs r4getIndex;ServerOptionsTests.test_sortedReactorHelp..getIndexs( a,z//23r7z9reactor descriptions were not in alphabetical order: {!r}N)rrr_getReactorTypesr rr messageOutput assertRaises SystemExit parseOptionsgetvaluerr|sortedformat) rSrrrreactorrrrrrrrs ` @@@@@@r4test_sortedReactorHelp)ServerOptionsTests.test_sortedReactorHelps  = = %W-%h/&y1$W-   %%' 00(2J2JK"1'z *f&9&9.CheckPIDTests.test_notExists..|sr7znon-existent PID fileN)rEr;pathr#rks r4test_notExistsCheckPIDTests.test_notExistsxs! 277Ho6()r7cUR5n[US5nURS5 SSS5 UR[[ U5nUR SUR5 g!,(df  NF=f)z9 Non-numeric content in a PID file causes a system exit. wz non-numericNznon-numeric value)mktempopenwriterrr#rr)rSpidfilefrs r4test_nonNumericCheckPIDTests.test_nonNumerics\++- '3 1 GGM "   j(G < )1662 s A// A=c4UR5n[US5nURS5 SSS5 SnUR[SU5 UR [ [U5nURSUR5 g!,(df  N`=f)z5 Another running twistd server causes a system exit. r42Ncgr)r]pidsigs r4kill/CheckPIDTests.test_anotherRunning..kills r7rzAnother twistd server) rrr rEr;rrr#rrrSr r rrs r4test_anotherRunning!CheckPIDTests.test_anotherRunningsr++- '3 1 GGDM   2vt$   j(G < -qvv6 s B  BcvUR5n[US5nUR[[R "5S-55 SSS5 SnUR [SU5 [U5 UR[RRU55 g!,(df  Nb=f)z: Stale PID file is removed without causing a system exit. rNc6[[RS5eNfake)OSErrorerrnoESRCHrs r4r&CheckPIDTests.test_stale..kill%++v. .r7r) rrr rr;getpidrEr#rrr)rSr r rs r4 test_staleCheckPIDTests.test_stales~++- '3 1 GGC a( )  / 2vt$ 01 s 1B** B8cUR5n[US5nURS5 SSS5 SnUR[SU5 UR [ [U5nURURS5 URURSRS55 g!,(df  N=f)zx An unexpected L{OSError} when checking the validity of a PID in a C{pidfile} terminates the process via L{SystemExit}. r3581Nc6[[RS5errrEBADFrs r4r2CheckPIDTests.test_unexpectedOSError..killr"r7rrzCan't check status of PID) rrr rEr;rrr# assertIsNotrrrrrs r4test_unexpectedOSError$CheckPIDTests.test_unexpectedOSErrors ++- '3 1 GGFO  / 2vt$   j(G < & q ,,-HIJ s B66 Cr]N) rVrWrXrYrZrr rr$r-r\r]r7r4rrrs!*3 7 2Kr7rc$\rSrSrSrSrSrSrg) TapFileTestsizE Test twistd-related functionality that requires a tap file on disk. cUR5Ul[URS5n[R"[ R "S5U5 SSS5 g!,(df  g=f)z@ Create a trivial Application and put it in a tap file on disk. wbHi!N)rtapfilerpickledumpr Application)rSr s r4setUpTapFileTests.setUpsF{{} $,, % KK++E2A 6& % %s ,A!! A/c[R"5nURSUR/5 [ U5R 5nUR [R"U5RS5 g)zv Ensure that the createOrGetApplication call that 'twistd -f foo.tap' makes will load the Application out of foo.tap. z-fr3N) rrrr4rhcreateOrGetApplicationrr IServicer/)rSrrcs r4&test_createOrGetApplicationWithTapFile3TapFileTests.test_createOrGetApplicationWithTapFiles] %%'T4<<01/7NNP  ))+6;;UCr7)r4N)rVrWrXrYrZr8r=r\r]r7r4r0r0s7Dr7r0c*\rSrSrSrSrSrSrSrg)TestLoggerFactoryiz0 A logger factory for L{TestApplicationRunner}. cXlgr)runner)rSrCs r4r~TestLoggerFactory.__init__s r7cURRRS5 [URS5URlg)z3 Save the logging start on the C{runner} instance. logrcN)rCorderrhasattrhadApplicationLogObserverrbs r4rdTestLoggerFactory.starts3   '07 ]0S -r7cg)z Don't log anything. Nr]rks r4stopTestLoggerFactory.stopr7rBN) rVrWrXrYrZr~rdrLr\r]r7r4r@r@sT r7r@c*\rSrSrSrSrSrSrSrg)TestApplicationRunnerizT An ApplicationRunner which tracks the environment in which its methods are called. cp[RRX5 /Ul[ U5Ulgr))r ApplicationRunnerr~rGr@rrRs r4r~TestApplicationRunner.__init__s) &&t5 '- r7c\URRS5 [US5Ulg)Nprerc)rGrrHhadApplicationPreApplicationrks r4rl$TestApplicationRunner.preApplications# % ,3D-,H)r7c\URRS5 [US5Ulg)Npostrc)rGrrHhadApplicationPostApplicationrks r4ro%TestApplicationRunner.postApplications# &!-4T=-I*r7)rZrVrrGN) rVrWrXrYrZr~rlror\r]r7r4rPrPs . IJr7rPc\rSrSrSrSrSrSrSr\ "\ "\ SS5(+S 5S 5r \ "\ "\ SS5(+S 5S 5r S rS rSrSrSrg)ApplicationRunnerTestsizJ Non-platform-specific tests for the platform-specific ApplicationRunner. c[R"5n[5UlSUR0Ul[ 5UlSUlXlg)N test_command) rrrL serviceMaker loadedPluginsobject subOptionsrrrs r4r8ApplicationRunnerTests.setUpsE%%',. .0A0AB"H* r7ch[UR5nUR5 URURR URR S5 URURR[R"UR5RSS5 g)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.rzPServiceMaker.makeService's result needs to be set as a child of the Application.N) rhrrunrr`rPrcr r<rcservices)rSarunners r4,test_applicationRunnerGetsCorrectApplicationCApplicationRunnerTests.test_applicationRunnerGetsCorrectApplications ,DKK8     % % KK " " "    % %   W00 1 : :1 = " r7c,[UR5nUR5 URUR5 UR UR 5 UR UR5 URUR/SQ5 g)zn Test thet preApplication and postApplication methods are called by ApplicationRunner.run() when appropriate. )rUrFrYN) rPrrfrrVrrZrIrrG)rSrs r4test_preAndPostApplication1ApplicationRunnerTests.test_preAndPostApplicationsh "$++ .  778 778 334 "89r7c ^URRU5 /m"U4SjS[R5n[ [ R [ R5"U4SjS55nU"5n[[ R U5 [[ RU5 U"UR5nUR5 Xgl UR5 URTSSSSX#4S S /5 g ) z 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@>\rSrSrU4SjrU4SjrU4SjrSrSrg)\ApplicationRunnerTests._applicationStartsWithConfiguredID..FakeUnixApplicationRunneri7c(>TRS5 g)N environmentr)rSchrootrundirnodaemonrr eventss r4setupEnvironmentmApplicationRunnerTests._applicationStartsWithConfiguredID..FakeUnixApplicationRunner.setupEnvironment8s m,r7c.>TRSXU45 g)N privilegesrs)rSeuidrGr1rws r4shedPrivilegeskApplicationRunnerTests._applicationStartsWithConfiguredID..FakeUnixApplicationRunner.shedPrivileges;s |T<=r7c(>TRS5 g)Nrrs)rSr oldstdout oldstderrrws r4 startReactoriApplicationRunnerTests._applicationStartsWithConfiguredID..FakeUnixApplicationRunner.startReactor>s i(r7cgr)r])rSr s r4 removePIDfApplicationRunnerTests._applicationStartsWithConfiguredID..FakeUnixApplicationRunner.removePIDAr7r]N) rVrWrXrYrxr}rrr\rwsr4FakeUnixApplicationRunnerrp7s - > ) r7rc^>\rSrSrSrSrSrSrSrSr Sr Sr Sr U4Sjr U4SjrSrS rg) NApplicationRunnerTests._applicationStartsWithConfiguredID..FakeServiceiDNcgr)r]r}s r4setNameVApplicationRunnerTests._applicationStartsWithConfiguredID..FakeService.setNameMrr7cgr)r])rSparents r4setServiceParent_ApplicationRunnerTests._applicationStartsWithConfiguredID..FakeService.setServiceParentPrr7cgr)r]rks r4disownServiceParentbApplicationRunnerTests._applicationStartsWithConfiguredID..FakeService.disownServiceParentSrr7c(>TRS5 g)NprivilegedStartServicersrSrws r4reApplicationRunnerTests._applicationStartsWithConfiguredID..FakeService.privilegedStartServiceVs 67r7c(>TRS5 g)N startServicersrs r4r[ApplicationRunnerTests._applicationStartsWithConfiguredID..FakeService.startServiceYs n-r7cgr)r]rks r4 stopServiceZApplicationRunnerTests._applicationStartsWithConfiguredID..FakeService.stopService\rr7r])rVrWrXrYrrunningr/ processNamerGr1rrrrrrr\rsr4 FakeServicerDs?FGDKCC    8 . r7rrrrr{FrrN) rrr_SomeApplicationRunnerrr r<IProcessrrlrcror) rSargvrGr1rrrcrCrws @r4"_applicationStartsWithConfiguredID9ApplicationRunnerTests._applicationStartsWithConfiguredID*s   & (E(E  W%%w'7'7 8   9 4"m W%%{3W%%{3*4;;7(   (uc/   r7setuidNz5Platform does not support --uid/--gid twistd options.c\SnSnURS[U5S[U5/X5 g)z 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)rr)rSrGr1s r4.test_applicationStartsWithConfiguredNumericIDsEApplicationRunnerTests.test_applicationStartsWithConfiguredNumericIDsss2 // c#hS 2C r7cnSnSnSnSn[URXX45 URSUSU/X$5 g)z 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}. foorbarrrrN)rJrEr)rSrFrGr3r1s r4+test_applicationStartsWithConfiguredNameIDsBApplicationRunnerTests.test_applicationStartsWithConfiguredNameIDssD$**d< // dGU +S r7c[5n[R"SSSS.5nURUSS5 UR UR S5 g)z' L{startReactor} calls L{reactor.run}. Fr$r$rdebugNz'startReactor did not call reactor.run()) DummyReactorr rRrrcalledrSrrCs r4test_startReactorRunsTheReactor6ApplicationRunnerTests.test_startReactorRunsTheReactorsL.&&9u E  GT40 (QRr7c[5nUR[SU5 [R"SSSS.5nUR SSS5 UR UR5 g)z> L{ApplicationRunner} chooses a reactor if none is specified. rFr$rN)rrErr rRrrrrs r4*test_applicationRunnerChoosesReactorIfNoneAApplicationRunnerTests.test_applicationRunnerChoosesReactorIfNonesY. 8Y0&&9u E  D$- 'r7c"SS[5nU"5n[R"SSSS.5nURUSS5 UR SUR 5 g)zO If the reactor exits with a signal, the application runner caches the signal. c$\rSrSrSrSrSrSrg)[ApplicationRunnerTests.test_applicationRunnerCapturesSignal..DummyReactorWithSignalig A dummy reactor, providing a C{run} method, and setting the _exitSignal attribute to a nonzero value. cgz Dummy method, does nothing. Nr]rks r4 installWakerhApplicationRunnerTests.test_applicationRunnerCapturesSignal..DummyReactorWithSignal.installWakerrNr7cSUlg)z: A fake run method setting _exitSignal to a nonzero value N _exitSignalrks r4rf_ApplicationRunnerTests.test_applicationRunnerCapturesSignal..DummyReactorWithSignal.runs $% r7rNrVrWrXrYrZrrfr\r]r7r4DummyReactorWithSignalrs     %r7rFr$rNr)rr rRr assertEqualsr)rSrrrCs r4$test_applicationRunnerCapturesSignal;ApplicationRunnerTests.test_applicationRunnerCapturesSignals\  %[ %")*&&9u E  GT40 !V//0r7c"SS5nU"5n[R"SSSS.5nURUSS5 URSUR5 g)z The runner sets its _exitSignal instance attribute to None if the reactor does not implement L{_ISupportsExitSignalCapturing}. c$\rSrSrSrSrSrSrg)iApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal..DummyReactorWithExitSignalAttributeircgrr]rks r4rvApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal..DummyReactorWithExitSignalAttribute.installWakerrNr7cSUlg)zR A fake run method setting _exitSignal to a nonzero value that should be ignored. rNrrks r4rfmApplicationRunnerTests.test_applicationRunnerIgnoresNoSignal..DummyReactorWithExitSignalAttribute.runs $% r7rNrr]r7r4#DummyReactorWithExitSignalAttributers     %r7rFr$rN)r rRrrr)rSrrrCs r4%test_applicationRunnerIgnoresNoSignal[TSU5$)NrootsetattrrrSs r4rBUnixApplicationRunnerSetupEnvironmentTests.setUp.. sgdFD.Ir7chdirc>[TSU5$)Ncwdrrs r4rr sWT5$-Gr7rc>[TSU5$)Nmaskr)rrSs r4rr sWT64-Hr7)unsetrrrdaemonr;r#rrEr!rrrC daemonizerks`r4r80UnixApplicationRunnerSetupEnvironmentTests.setUpsJJ ::JJ  99; 2x!IJ 2w GH 2w HI+F,@,@,BC $ r7cJ^STlTR[SU4Sj5 g)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">TRS-$Nr)rrksr4rFUnixApplicationRunnerSetupEnvironmentTests.daemonize..s Ar7N)rrEr;rSrs` r4r4UnixApplicationRunnerSetupEnvironmentTests.daemonizes   2x!56r7czURRSSSSS5 URURS5 g)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)rCrxrrrks r4 test_chroot6UnixApplicationRunnerSetupEnvironmentTests.test_chroots2 $$ZdD$G J/r7cURRSSSSS5 URURUR5 g)z L{UnixApplicationRunner.setupEnvironment} does not change the root of the filesystem if passed L{None} for the C{chroot} parameter. NrT)rCrxrrrrks r4 test_noChroot8UnixApplicationRunnerSetupEnvironmentTests.test_noChroot!s4 $$T3dDA dii,r7czURRSSSSS5 URURS5 g)z L{UnixApplicationRunner.setupEnvironment} changes the working directory of the process to the path given for the C{rundir} parameter. NrT)rCrxrrrks r4test_changeWorkingDirectoryFUnixApplicationRunnerSetupEnvironmentTests.test_changeWorkingDirectory)s2 $$T:tT4H :.r7c[[55 URRSSSSS5 SSS5 UR UR 5 g!,(df  N*=f)zw L{UnixApplicationRunner.setupEnvironment} daemonizes the process if C{False} is passed for the C{nodaemon} parameter. NrF)rFakeDaemonizingReactorrCrxrrrks r4test_daemonize9UnixApplicationRunnerSetupEnvironmentTests.test_daemonize1sH 46 7 KK ( (sE4 F8  $8 7s A A&cxURRSSSSS5 URUR5 g)z~ L{UnixApplicationRunner.setupEnvironment} does not daemonize the process if C{True} is passed for the C{nodaemon} parameter. NrT)rCrxrrrks r4test_noDaemonize;UnixApplicationRunnerSetupEnvironmentTests.test_noDaemonize:s0 $$T3dDA %r7cUR5nURRSSSSU5 [US5n[ UR 55nSSS5 UR WUR5 g!,(df  N+=f)zw L{UnixApplicationRunner.setupEnvironment} writes the process's PID to the file specified by the C{pidfile} parameter. NrTrb)rrCrxrintreadrrrSr r rs r4test_nonDaemonPIDFile@UnixApplicationRunnerSetupEnvironmentTests.test_nonDaemonPIDFileBsf ++- $$T3dGD '4 Aaffh-C! dhh'! s A;; B cxUR5n[[55 URR SSSSU5 SSS5 [ US5n[ UR55nSSS5 URWURS-5 g!,(df  N\=f!,(df  N?=f)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}. NrFrr) rrrrCrxrr r rrr s r4test_daemonPIDFile=UnixApplicationRunnerSetupEnvironmentTests.test_daemonPIDFileMs ++- 46 7 KK ( (sE4 I8 '4 Aaffh-C! dhhl+ 8 7 s BB+ B(+ B9c[[55 URRSSSSS5 SSS5 UR UR S5 g!,(df  N+=f)zw L{UnixApplicationRunner.setupEnvironment} changes the process umask to the value specified by the C{umask} parameter. NrF{rrrCrxrrrks r4r5UnixApplicationRunnerSetupEnvironmentTests.test_umaskZsL 46 7 KK ( (sE3 E8 C(8 7 A A'cURRSSSSS5 URURUR5 g)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. NrT)rCrxrrrrks r4test_noDaemonizeNoUmaskBUnixApplicationRunnerSetupEnvironmentTests.test_noDaemonizeNoUmaskcs4 $$T3dDA dii,r7c[[55 URRSSSSS5 SSS5 UR UR S5 g!,(df  N+=f)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. NrF?rrks r4test_daemonizedNoUmaskAUnixApplicationRunnerSetupEnvironmentTests.test_daemonizedNoUmasklsL 46 7 KK ( (sE4 F8 E*8 7r)rrrrrrCN)rVrWrXrYrZrbrr8rrrrrrr rrrrr\r]r7r4rrsL( HE /70-/%& ( ,)-+r7rc<\rSrSrSrSrSrSrSrSr Sr S r g ) *UnixApplicationRunnerStartApplicationTestsiwz6 Tests for L{UnixApplicationRunner.startApplication}. c^[R"5nUR/SQ5 [R"S5n[ U5Ul/mU4Sjn[R"UR R5Rn[R"U5RnUR5nURS5 URXE5 UR[ SU5 UR[ SS5 UR[SS 5 UR R!U5 URT/S Q5 g ) z L{UnixApplicationRunner.startApplication} calls L{UnixApplicationRunner.setupEnvironment} with the chroot, rundir, nodaemon, umask, and pidfile parameters from the configuration it is constructed with. ) --nodaemonr0070z--chroot /foo/chrootz--rundir /foo/rundir --pidfile /foo/pidfiletest_setupEnvironmentc.>TRXX4U45 gr))extend)rSrtrurvrr rs r4fakeSetupEnvironment^UnixApplicationRunnerStartApplicationTests.test_setupEnvironment..fakeSetupEnvironments KK'B Cr7rSrxr}cgr)r]akws r4rRUnixApplicationRunnerStartApplicationTests.test_setupEnvironment..sTr7startApplicationcgr)r]r,s r4rr/sTr7)r"r#T8r%N)rrrr r7r!rCinspect signaturerx parameterscopypoprrEr r0)rSrPrcr)setupEnvironmentParametersfakeSetupEnvironmentParametersrs @r4r&@UnixApplicationRunnerStartApplicationTests.test_setupEnvironment}s&&(  ))*AB +G4  D&-%6%6 KK ( (& * #*1):): * * '*H)L)L)N&&**62 3T (*<>RS (*:TRUS5 TRUS5 TRUS5 g)N6#r)rGr1r|rSs r4 switchUIDPassUUnixApplicationRunnerStartApplicationTests.test_shedPrivileges..switchUIDPasss3   S# &   S" %   T2 &r7 switchUIDr?r=r>N)rErr!r})rSrArCs` r4test_shedPrivileges>UnixApplicationRunnerStartApplicationTests.test_shedPrivilegess6  ' <m<&r*b#r*r7cSn[05nUR[SU5 UR[UR SSS5nUR URS5 g)z An unexpected L{OSError} when calling L{twisted.scripts._twistd_unix.shedPrivileges} terminates the process via L{SystemExit}. c6[[RS5err))rGr1r|s r4 switchUIDFailZUnixApplicationRunnerStartApplicationTests.test_shedPrivilegesError..switchUIDFailr"r7rCr?r=Nr)r!rErrrr}rr)rSrHrCexcs r4test_shedPrivilegesErrorCUnixApplicationRunnerStartApplicationTests.test_shedPrivilegesErrorsU /'r* <m< F,A,A2sDQ 1%r7c^^^[TRUTUT5 UUU4SjnUU4SjnUU4SjnTR[SU5 TR[SU5 TR[SU5 [R "5n U R SS[T5S U/5 [R"S 5n [U 5Tl [U 5n U RU 5 g ) zR Common code for tests which try to pass the the UID to L{UnixApplicationRunner}. cN>TRUT5 TRUT5 gr)r@)rGr1rS wantedGid wantedUids r4 initgroupsFUnixApplicationRunnerStartApplicationTests._setUID..initgroupss#   S) ,   S) ,r7c*>TRUT5 gr)r@)rGrSrPs r4rBUnixApplicationRunnerStartApplicationTests._setUID..setuid   S) ,r7c*>TRUT5 gr)r@)r1rSrOs r4setgidBUnixApplicationRunnerStartApplicationTests._setUID..setgidrUr7rQrrWr rr$r&N) rJrErr;rrrrr r7r!rCr0) rS wantedUserrP wantedGrouprOpidFilerQrrWrPrcrCs ` ` ` r4_setUID2UnixApplicationRunnerStartApplicationTests._setUIDs $**j)[)T - - - 4z2 2x( 2x(&&( 7C NK I ))*AB +G4 &w/ ,r7cPURSSSSUR5S-5 g)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. ririz_test_setUidWithoutGid.pidN)r\rrks r4test_setUidWithoutGid@UnixApplicationRunnerStartApplicationTests.test_setUidWithoutGids' 4dkkm6R&R r7c[R"5nURSUSSS5 UR5nSR X5nUR X2SS5 UR S[ U5U5 g ) zb If the specified UID is the same as the current UID of the process, then a warning is displayed. morefoomorebariztest_setUidSameAsCurrentUid.pidz\tried to drop privileges and setuid {} but uid is already {}; should we be root? Continuing.rmessagerN)r;r<r\ flushWarningsrrlen)rS currentUid warningsShownexpectedWarnings r4test_setUidSameAsCurrentUidFUnixApplicationRunnerStartApplicationTests.test_setUidSameAsCurrentUids| YY[  z9d4U **,  --3VJ-K  *:9*EF C . >r7rBN) rVrWrXrYrZr&rDrKr\r_rjr\r]r7r4rrws'2Yh + &-< ?r7rc$\rSrSrSrSrSrSrg)#UnixApplicationRunnerRemovePIDTestsi z/ Tests for L{UnixApplicationRunner.removePID}. cX[05nUR5n[R"U5 [RR US5n[ US5R5 URU5 UR[RRU55 g)zX L{UnixApplicationRunner.removePID} deletes the file the name of which is passed to it. zfoo.pidrN) r!rr;makedirsrjoinrcloserrr)rSrCrr s r4test_removePID2UnixApplicationRunnerRemovePIDTests.test_removePIDsu 'r*{{} D'',,tY/ Wc  "! 01r7c [05nURS5 UR[5nUR [ U5S5 UR USR R[R5 g)zZ Calling L{UnixApplicationRunner.removePID} with a non-existent filename logs an OSError. fakepidrrN) r!rflushLoggedErrorsrrrfvaluerENOENT)rSrCerrorss r4test_removePIDErrors8UnixApplicationRunnerRemovePIDTests.test_removePIDErrorssb 'r*#''0 Va( .. =r7r]N)rVrWrXrYrZrrrzr\r]r7r4rmrm s 2 >r7rmc0\rSrSrSrSrSrSrSrSr g) FakeNonDaemonizingReactori)a{ 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 SUlSUlgr)_beforeDaemonizeCalled_afterDaemonizeCalledrks r4r~"FakeNonDaemonizingReactor.__init__5s&+#%*"r7cSUlgNT)rrks r4beforeDaemonize)FakeNonDaemonizingReactor.beforeDaemonize9s &*#r7cSUlgr)rrks r4afterDaemonize(FakeNonDaemonizingReactor.afterDaemonize<s %)"r7cg)z Skip event registration. Nr])rSrr.s r4addSystemEventTrigger/FakeNonDaemonizingReactor.addSystemEventTrigger?rNr7)rrN) rVrWrXrYrZr~rrrr\r]r7r4r}r})s ++* r7r}c\rSrSrSrSrg)riEz A dummy reactor, providing C{beforeDaemonize} and C{afterDaemonize} methods, announcing this, and logging whether the methods have been called. r]N)rVrWrXrYrZr\r]r7r4rrEsr7rc"\rSrSrSrSrSrSrg)riMz 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} FcJUR(a [S5eSUlg)zF A fake run method, checking that it's been called one and only time. zAlready calledTN)r RuntimeErrorrks r4rfDummyReactor.runXs ;;/0 0 r7)rN)rVrWrXrYrZrrfr\r]r7r4rrMsFr7rc\rSrSrSr\"\(+S5S5rSr\"\(+S5S5r Sr \"\(+S5S5r \"\ (+S 5S 5r \"\ (+S 5S 5rS rS rSrSrSrg)AppProfilingTestsiaz Tests for L{app.AppProfiler}. zprofile module not availablec[R"5nUR5US'SUS'[R"U5n[ 5nUR U5 URUR5 [US5nUR5nSSS5 URSW5 URSU5 g!,(df  N3=f)zt L{app.ProfileRunner.run} should call the C{run} method of the reactor and save profile data in the specified file. r$rNzDummyReactor.runfunction calls rrrr rrrfrrrr rrSrrrr datas r4 test_profileAppProfilingTests.test_profilefs %%' KKMy&z??6*. W ' &# $668D% ($/ &-% $ C Cc[5nUR[SU5nU"U5nUR5 UR 5 UR 5nUR SU5 UR SU5 g)Nrrz(run))rrEsys print_statsrestorerr)rS statsClassr$outrstatsrs r4 _testStatsAppProfilingTests._testStatszsgjC3/7# ||~ &- gt$r7cF[R"5nUR5US'SUS'SUS'[R"U5n[ 5nUR U5 URUR5 UR[RUS5 g)z With the C{savestats} option specified, L{app.ProfileRunner.run} should save the raw stats object instead of a summary output. r$rT savestatsN rrrr rrrfrrrr%StatsrSrrrs r4test_profileSaveStats'AppProfilingTests.test_profileSaveStatss~ %%' KKMy&z"{??6*. W '  fY&78r7c[RR5n[R"5nSUS'[ R "U5nS[RS'UR[URS5 [RR5 [RRU5 g![RR5 [RRU5 f=f)zn When the C{profile} module is not present, L{app.ProfilerRunner.run} should raise a C{SystemExit} exception. r$rN rmodulesr6rrr rrrrfclearupdaterS savedModulesrrs r4test_withoutProfile%AppProfilingTests.test_withoutProfiles {{'') %%'&z??6*!% I -   j(,, = KK    KK  | , KK    KK  | , #!C?Dc"SS[R5nUR[SU5 [R"5nUR 5US'SUS'[ R"U5n[5n[RnUR[URU5 UR[RU5 g)zm When an error happens during the print of the stats, C{sys.stdout} should be restored to its initial value. c\rSrSrSrSrg)GAppProfilingTests.test_profilePrintStatsError..ErroneousProfileic[S5e)NBoomrrks r4rSAppProfilingTests.test_profilePrintStatsError..ErroneousProfile.print_statss "6**r7r]N)rVrWrXrYrr\r]r7r4ErroneousProfilers +r7rProfiler$rN)r$rrErrrr rrrrrrrfr)rSrrrr oldStdouts r4test_profilePrintStatsError-AppProfilingTests.test_profilePrintStatsErrors +w + 7I'78%%' KKMy&z??6*.JJ  , g> cjj),r7zcProfile module not availablec[R"5nUR5US'SUS'[R"U5n[ 5nUR U5 URUR5 [US5nUR5nSSS5 URSW5 URSU5 g!,(df  N3=f)zu L{app.CProfileRunner.run} should call the C{run} method of the reactor and save profile data in the specified file. r$r&rNrfrrrs r4 test_cProfileAppProfilingTests.test_cProfiles %%' KKMy'z??6*. W ' &# $668D% eT" &-% $rcF[R"5nUR5US'SUS'SUS'[R"U5n[ 5nUR U5 URUR5 UR[RUS5 g)z With the C{savestats} option specified, L{app.CProfileRunner.run} should save the raw stats object instead of a summary output. r$r&rTrNrrs r4test_cProfileSaveStats(AppProfilingTests.test_cProfileSaveStatss~%%' KKMy'z"{??6*. W '  fY&78r7c[RR5nS[RS'[R"5nSUS'[ R "U5nUR[URS5 [RR5 [RRU5 g![RR5 [RRU5 f=f)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&rrrs r4test_withoutCProfile&AppProfilingTests.test_withoutCProfiles {{'') "& J%%''z??6* -   j(,, = KK    KK  | , KK    KK  | ,rc[R"5nUR5US'SUS'UR[[ R U5nUR[U5S5 g)zY Check that L{app.AppProfiler} raises L{SystemExit} when given an unknown profiler name. r$foobarrz!Unsupported profiler name: foobarN) rrrrrr rrr)rSrerrors r4test_unknownProfiler&AppProfilingTests.test_unknownProfilersY %%' KKMy%z!!*coovF U%HIr7ch[R"05nURURS5 g)zE L{app.Profiler} defaults to the cprofile profiler if not specified. cprofileNr rrrrSrs r4test_defaultProfiler&AppProfilingTests.test_defaultProfiler s(??2& **J7r7cl[R"SS05nURURS5 g)zM The case of the profiler name passed to L{app.AppProfiler} is not relevant. rCprOfilerNrrs r4test_profilerNameCaseInsentive0AppProfilingTests.test_profilerNameCaseInsentives- ??J #;< **J7r7r]N)rVrWrXrYrZrr$rrrrrr&rrrrrrr\r]r7r4rras K78.9.&%" K78999"-$ K78-9-, L9:.;.& L9:9;9$-$ J88r7rcX^^/m[RmUU4SjnU"[SU5 T$)z 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{TestCase.patch}). @return: the list that keeps track of the log files. @rtype: C{list} c>>TRU5 T"U/UQ70UD6$r)rs)logFilerkwargslogFilesoldFileLogObservers r4observer+_patchTextFileLogObserver..observer(s$ !';D;F;;r7textFileLogObserver)rr)rErrrs @@r4_patchTextFileLogObserverrs/H33< &'2 Or7cT^/m"U4SjS5nUR[SU5 T$)zi Make fake syslog, and return list to which prefix and then log messages will be appended if it is used. c.>\rSrSrU4SjrU4SjrSrg)(_setupSyslog..fakesyslogobserveri7c(>TRU5 gr)rs)rSprefix logMessagess r4r~1_setupSyslog..fakesyslogobserver.__init__8s   v &r7c(>TRU5 gr)rs)rS eventDictrs r4emit-_setupSyslog..fakesyslogobserver.emit;s   y )r7r]N)rVrWrXrYr~rr\)rsr4fakesyslogobserverr7s ' * *r7rSyslogObserver)rEsyslog)testCaserrs @r4 _setupSyslogr0s. K** NN6+-?@ r7c\rSrSrSrSrSrSrSrSr Sr 0\ R4S jr S rS rS rS r\"\(+S5\"\(+S5S55rSrSrSrSrSrSrSrg)AppLoggerTestsiBzv Tests for L{app.AppLogger}. @ivar observers: list of observers installed during the tests. @type observers: C{list} cN^/TlU4SjnTR[SU5 g)zp Override L{globaLogBeginner.beginLoggingTo} so that we can trace the observers installed in C{self.observers}. cz>UH4nTRRU5 [R"U5 M6 gr)) observersrr addObserver)rrrSs r4beginLoggingTo,AppLoggerTests.setUp..beginLoggingToQs-%%%h/"..x8&r7rN)rrEr)rSrs` r4r8AppLoggerTests.setUpJs%  9 $&6Gr7cVURHn[R"U5 M g)z! Remove all installed observers. N)rrremoveObserverrSrs r4tearDownAppLoggerTests.tearDownXs H  - -h 7'r7cH[[5"SS55nU"5$)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\rSrSr/rSrSrg)2AppLoggerTests._makeObserver..TestObserverigc:URRU5 gr))_logsr)rSevents r4__call__;AppLoggerTests._makeObserver..TestObserver.__call__ks !!%(r7r]N)rVrWrXrYrrr\r]r7r4 TestObserverrgs E )r7r )rr)rSr s r4 _makeObserverAppLoggerTests._makeObserver_s* \ " ) ) # ) ~r7cURURU/5 URSURSS5 URSURSS5 g)zw Ensure that initial C{twistd} logs are written to logs. @param observer: The observer made by L{self._makeObserver). starting upr log_formatz reactor classrN)rrrrrs r4_checkObserverAppLoggerTests._checkObserverpsR (4 mX^^A%6|%DE ox~~a'8'FGr7c^[R"05nUR5mU4SjUlUR"[ 55 UR T5 g)z| L{app.AppLogger.start} calls L{globalLogBeginner.addObserver}, and then writes some messages about twistd and the reactor. c>T$r)r]rsr4r+AppLoggerTests.test_start..sr7N)r AppLoggerr _getLogObserverrdrr)rSrrs @r4 test_startAppLoggerTests.test_startzsE r"%%'!1 ]_% H%r7c[5nUR5nUR[U5 [R "05nUR "U5 URU5 g)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)rr  setComponentrr rrdr)rSrcrrs r4$test_startUsesApplicationLogObserver3AppLoggerTests.test_startUsesApplicationLogObserversQ $o %%'  x8r" [! H%r7c^UR5mSU4Sj0nURU5 U"U5nUR"U5 T$)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. rc>T$r)r]rsr4r7AppLoggerTests._setupConfiguredLogger..sXr7)r rrd)rSrc extraLogArgs appLoggerlogArgsrrs @r4_setupConfiguredLogger%AppLoggerTests._setupConfiguredLoggersE"%%'-.|$7# [!r7cX[5nURURU55 g)z 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)rrr#rbs r4#test_startUsesConfiguredLogObserver2AppLoggerTests.test_startUsesConfiguredLogObservers$$o  D77 DEr7cUR5n[5nUR[U5 UR UR U55 UR UR/5 g)zS C{--logger} takes precedence over a L{ILogObserver} component set on Application. N)r rrrrr#rr)rSrrcs r4(test_configuredLogObserverBeatsComponent7AppLoggerTests.test_configuredLogObserverBeatsComponentsV %%'#o   x8 D77 DE ,r7c/n[5nUR[UR5 UR UR U55 UR U/5 g)zY C{--logger} takes precedence over a L{LegacyILogObserver} component set on Application. N)rrLegacyILogObserverrrr#r)rSnonlogsrcs r4.test_configuredLogObserverBeatsLegacyComponent=AppLoggerTests.test_configuredLogObserverBeatsLegacyComponentsN #o   !3W^^D D77 DE "%r7c>/nUR5n[5nUR[U5 UR[UR 5 [ R"05nUR"U5 URU5 URU/5 g)z_ A L{ILogObserver} takes precedence over a L{LegacyILogObserver} component set on Application. N) r rrrr,rr rrdrr)rSr-rrcrs r4.test_loggerComponentBeatsLegacyLoggerComponent=AppLoggerTests.test_loggerComponentBeatsLegacyLoggerComponents{ %%'#o   x8  !3W^^Dr" [! H% "%r7rzsyslog not availablec[U5n[5nURURUSS0[55 UR U/5 g)zH C{--logger} takes precedence over a C{--syslog} command line argument. rTN)rrrr#r"r)rSlogsrcs r4%test_configuredLogObserverBeatsSyslog4AppLoggerTests.test_configuredLogObserverBeatsSyslogsLD!#o    ' ' h5E} U  r"r7c[5nUR5nURURUSS055 UR [ R RU55 g)zI C{--logger} takes precedence over a C{--logfile} command line argument. logfilerN)rrrr#rr;rr)rSrcrs r4&test_configuredLogObserverBeatsLogfile5AppLoggerTests.test_configuredLogObserverBeatsLogfilesV $o {{}   ' ' i5H I  -.r7c[R"SS05n[UR5nUR"5 UR [ U5S5 URUS[R5 [R"SS05nUR"5 UR [ U5S5 URUS[R5 g)zz When logfile is empty or set to C{-}, L{app.AppLogger._getLogObserver} returns a log observer pointing at C{sys.stdout}. r8-rrrN) r rrrErrrfrrr)rSrrs r4test_getLogObserverStdout(AppLoggerTests.test_getLogObserverStdouts  3/0,TZZ8  X* hqk3::. 2/  X* hqk3::.r7c[UR5nUR5n[R"SU05nUR 5nUR URR5 UR[U5S5 URUSR[RRU55 g)z} When passing the C{logfile} option, L{app.AppLogger._getLogObserver} returns a log observer pointing at the specified path. r8rrN)rrErr rr addCleanup_outFilerqrrfrr;abspath)rSrfilenamesutrs r4test_getLogObserverFile&AppLoggerTests.test_getLogObserverFiles -TZZ8;;=mmY12&&( ))//0 X* !))277??8+DEr7cV^/m[5nU4SjnUR[SU5 [R"05nXlUR "5 URTU/5 UR "5 URTU/5 URUR 5 g)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(>TRU5 gr)rs)rremoveds r4remove(AppLoggerTests.test_stop..remove s NN8 $r7rN) rbrErr r _observerrLrr)rSrrKrrJs @r4 test_stopAppLoggerTests.test_stops 8 % %'7@r"#  8*-  8*- &**+r7cl^^/m[R"05n[[5"U4SjS55mU4SjUlUR "[ 55 URS[TS55 URUR/5nUR[U5SU5 g)z\ L{app.AppLogger} using a legacy logger observer still works, wrapping it in a compat shim. c&>\rSrSrSrU4SjrSrg);AppLoggerTests.test_legacyObservers..LoggerObserveri4z@ An observer which implements the legacy L{LegacyILogObserver}. c(>TRU5 g)z Add C{x} to the logs list. Nrs)rSxr4s r4rDAppLoggerTests.test_legacyObservers..LoggerObserver.__call__:s Ar7r]N)rVrWrXrYrZrr\r4sr4LoggerObserverrR4s   r7rWc>T"5$r)r])rWsr4r5AppLoggerTests.test_legacyObservers..@s.*:r7r rN) r rrr,_observerFactoryrdrrrretest_legacyObserversrrf)rSrwarningsrWr4s @@r4r[#AppLoggerTests.test_legacyObservers,s r" ' (   ) #; ]_% m%6tAw%?@%%t'@'@&AB X84r7c\^/m[R"05nU4SjUlUR"[ 55 UR S[ TS55 URUR/5nURUSSS5 UR[U5SU5 g)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>TR$r)rsrVsr4rAAppLoggerTests.test_unmarkedObserversDeprecated..Os r7r rrdaZPassing 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.rN) r rrrdrrrre test_unmarkedObserversDeprecatedrrf)rSrr\r4s @r4ra/AppLoggerTests.test_unmarkedObserversDeprecatedGs r"!4 ]_% m%6tAw%?@%%t'L'L&MN  QK "0  X84r7)rN)rVrWrXrYrZr8rr rrrr rr#r&r)r.r1rrrr5r9r>rFrNr[rar\r]r7r4rrBs H8"H & &)+cmm0F - &&" 9: J./ #0; # //& F,*565r7rcd\rSrSrSrSrSrSrSrSr Sr \ "\ (+S 5S 5r S rg ) UnixAppLoggerTestsiezg Tests for L{UnixAppLogger}. @ivar signals: list of signal handlers installed. @type signals: C{list} cN^/TlU4SjnTR[SU5 g)z[ Fake C{signal.signal} for not installing the handlers but saving them in C{self.signals}. c>>TRRX45 gr))signalsr)rr rSs r4 fakeSignal,UnixAppLoggerTests.setUp..fakeSignalus LL   )r7signalN)rgrErj)rSrhs` r4r8UnixAppLoggerTests.setUpns#   * 68Z0r7c[UR5n[SSS.5nUR"5 UR [ U5S5 UR US[R5 [SSS.5nUR"5 UR [ U5S5 UR US[R5 g) 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<Tr8rvrrr=rN) rrEr"rrrfrrr)rSrrs r4r>,UnixAppLoggerTests.test_getLogObserverStdoutzs -TZZ83DAB  X* hqk3::.24@A  X* hqk3::.r7c[SSS.5nUR[UR5nUR [ U5S5 g)zg When daemonized and C{logfile} is set to C{-}, L{UnixAppLogger._getLogObserver} raises C{SystemExit}. r<Frmz&Daemons cannot log to stdout, exiting!N)r"rrrrr)rSrrs r4test_getLogObserverStdoutDaemon2UnixAppLoggerTests.test_getLogObserverStdoutDaemons@ 3EBC!!*f.D.DE U%MNr7c^[UR5nUR5n[SU05nUR 5nUR UR R5 UR[U5S5 URUSR[RRU55 UR[UR5S5 URURSS[R5 [!5mU4SjnXQSlURSSnU"SS5 T$)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. r8rrc(>TRS5 gr))callback)dsr4rotate:UnixAppLoggerTests.test_getLogObserverFile..rotates JJt r7N)rrErr"rrArBrqrrfrr;rCrgrjSIGUSR1rrv)rSrrDrErrv rotateLogrus @r4rF*UnixAppLoggerTests.test_getLogObserverFiles -TZZ8;;=Y12&&( ))//0 X* !))277??8+DE T\\*A. a+V^^< J $ LLOA& $r7c^U4SjnTR[SU5 TR5n[SU05nUR 5nTR UR R5 TRTR/5 g)za If a signal handler is already installed, L{UnixAppLogger._getLogObserver} doesn't override it. cX>TRU[R5 [5$r))rrjrxrb)rrSs r4 fakeGetSignalVUnixAppLoggerTests.test_getLogObserverDontOverrideSignalHandler..fakeGetSignals   S&.. 18Or7 getsignalr8N) rErjrr"rrArBrqrrg)rSr}rDrErs` r4,test_getLogObserverDontOverrideSignalHandler?UnixAppLoggerTests.test_getLogObserverDontOverrideSignalHandlersn   6; 6;;=Y12&&( ))//0 r*r7cd[UR5n[SSS.5nUR"5nUR UR R 5 UR[U5S5 URUSR[RRS55 g)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=Frmrrz twistd.logN) rrEr"rrArBrqrrfrr;rC)rSrrrs r4test_getLogObserverDefaultFile1UnixAppLoggerTests.test_getLogObserverDefaultFiles -TZZ825AB))+ ))//0 X* !))277??<+HIr7rc[U5n[SSS.5nUR"5nURUS/5 U"SS05 URUSSS0/5 g)zz If C{syslog} is set to C{True}, L{UnixAppLogger._getLogObserver} starts a L{syslog.SyslogObserver} with given C{prefix}. Tz test-prefix)rrr-bN)rr"rr)rSr4rrs r4test_getLogObserverSyslog,UnixAppLoggerTests.test_getLogObserverSyslogsb D!$-HI))+  /#s  Sz:;r7)rgN)rVrWrXrYrZr8r>rprFrrrrrr\r]r7r4rdrdesF 1/$O<+& J 9: <; .sr7)rmockosrrrrErr!rCr r7rcrrrstderrrrrks r4r8DaemonizeTests.setUpsh **,  <t{{3"88E ")"5"5e"<  #   #  #5  r7c2[[55 URR5 SSS5 UR UR R /SQ5 UR UR RSS/5 g!,(df  N_=f)z_ When double fork succeeded in C{daemonize}, the child process writes B{0} to the status pipe. N)rrrrforkTsetsidr)r 0unlinkz twistd.pidr)rrrCrorractionsclosedrks r4 test_successDaemonizeTests.test_successsn 46 7 KK ' ' )8  KK     ++b"X68 7s B BcSURlSURl[[ 55 UR [ URR5 SSS5 URURR/SQ5 URURRS/5 g!,(df  N^=f)zp The parent process initiating the C{daemonize} call reads data from the status pipe and then exit the process. FrN)rrrr dexitrrr) rchildreadDatarrr SystemErrorrCrorrrrks r4test_successInParent#DaemonizeTests.test_successInParents " #  46 7   k4;;+F+F G8  KK     ++bT28 7s +B99 Cc^/mU4SjnXRl[[55 URR 5 SSS5 UR URR/SQ5 UR URRSS/5 UR SS/T5 g!,(df  Ns=f)zj If the C{os.write} call to the status pipe raises an B{EINTR} error, the process child retries to write. cz>TRX45 [T5S:Xa[[R5egrrrfrrEINTR)fdrwrittens r4 raisingWrite6DaemonizeTests.test_successEINTR..raisingWrite$s1 NNB: &7|q ekk**!r7N)rrrrrrrr)rr) rr rrrCrorrr)rSrrs @r4test_successEINTR DaemonizeTests.test_successEINTRs  + )  46 7 KK ' ' )8  KK     ++b"X6 *j17;8 7s B55 Cc^/mU4SjnXRlSURl[[ 55 UR [ URR5 SSS5 URURR/SQ5 URURRS/5 URSS/T5 g!,(df  Nr=f)zg If the C{os.read} call on the status pipe raises an B{EINTR} error, the parent child retries to read. cz>TRX45 [T5S:Xa[[R5eg)Nrrr)rsizer s r4 raisingRead=DaemonizeTests.test_successInParentEINTR..raisingReadAs. KK #4yA~ekk**r7FN)rrrrrr)rr) rr rrrrrrCrorrr)rSrr s @r4test_successInParentEINTR(DaemonizeTests.test_successInParentEINTR:s   ' !  46 7   k4;;+F+F G8  KK     ++bT2 )Y/68 7s +C C#c ^"U4SjS[R5nU"5nURURR5 [ [ 55 UR[URR5 SSS5 URURRSSSSSSS U4S /5 URURRS S /5 g!,(df  Ng=f) z Assert L{UnixApplicationRunner.postApplication} writes C{reported} to its status pipe if the service raises an exception whose message is C{raised}. c">\rSrSrU4SjrSrg)6DaemonizeTests.assertErrorWritten..FakeServicei_c>[T5er)r)rSraiseds r4rCDaemonizeTests.assertErrorWritten..FakeService.startService`s"6**r7r]N)rVrWrXrYrr\)rsr4rr_s  + +r7rNrrrrr rrr)r rQrrCrcrrrrrorrrr)rSrreportedr errorServices ` r4assertErrorWritten!DaemonizeTests.assertErrorWrittenXs +'// +#} %%dkk&=&=> 46 7   lDKK,G,G H8  KK   "h'(   ++b"X68 7s +C)) C7c$URSSS9 g)zl If an error happens during daemonization, the child process writes the exception error to the status pipe. zSomething is wrongs"1 RuntimeError: Something is wrongrrNrrks r4 test_errorDaemonizeTests.test_errorvs '2W  r7c$URSSS9 g)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•s1 RuntimeError: \u2022rNrrks r4test_unicodeError DaemonizeTests.test_unicodeErrors x:TUr7cSURlXRl[5nUR [ SU5 [ [55 UR[URR5 SSS5 URUR5U5 URURRU5 URURRS/5 g!,(df  N|=f)z 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__Nr)rrrrrErrrrrrCrorrrr)rSr errorMessage mockOSActionserrorIOs r4assertErrorInParentBehavior*DaemonizeTests.assertErrorInParentBehaviors" ' * 3 g. 46 7   k4;;+F+F G8 ))+\: ,,m< ++bT2 8 7s +C77 Dc*URSS/SQS9 g)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. rrrr)rrrrrrNrrks r4test_errorInParent!DaemonizeTests.test_errorInParents% ((8B ) r7c*URSS/SQS9 g)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. s1 Exception: zXAn error has occurred: b'Exception: \xff' Please look at log file for more information. rrNrrks r4test_nonASCIIErrorInParent)DaemonizeTests.test_nonASCIIErrorInParents% (()B ) r7cnSnSRS5nURUSRU5/SQS9 g)z 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. d1 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. rrN)rr)rStruncatedMessagereportedMessages r4&test_errorInParentWithTruncatedUnicode5DaemonizeTests.test_errorInParentWithTruncatedUnicodesLA066G ((%BBH&#C ) r7c$URSSS9 g)zc If an error occurs during daemonization and its message is too long, it's truncated by the child. xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxsd1 RuntimeError: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxrNrrks r4test_errorMessageTruncated)DaemonizeTests.test_errorMessageTruncateds 'F  r7c$URSSS9 g)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••••••••••••••••••••••••••••••rrNrrks r4!test_unicodeErrorMessageTruncated0DaemonizeTests.test_unicodeErrorMessageTruncateds  :  r7c[5nURRU5 URUR5 URUR 5 g)z C{daemonize} indeed calls L{IReactorDaemonize.beforeDaemonize} and L{IReactorDaemonize.afterDaemonize} if the reactor implements L{IReactorDaemonize}. N)rrCrrrrrs r4test_hooksCalledDaemonizeTests.test_hooksCalledsB )* g& 667 556r7c[5nURRU5 URUR5 URUR 5 g)z C{daemonize} does NOT call L{IReactorDaemonize.beforeDaemonize} or L{IReactorDaemonize.afterDaemonize} if the reactor does NOT implement L{IReactorDaemonize}. N)r}rCrrrrrs r4test_hooksNotCalled"DaemonizeTests.test_hooksNotCalledsF ,- g& 778 667r7)rrrCN)rVrWrXrYrZr8rrrrrrrrrrrrrrrr\r]r7r4rrsX67*3,<:7<7< V3" , , :    7 8r7rcL\rSrSrSr\S5r\RS5rSrg)SignalCapturingMemoryReactori z} MemoryReactor that implements the _ISupportsExitSignalCapturing interface, all other operations identical to MemoryReactor. cUR$r)_valrks r4r(SignalCapturingMemoryReactor._exitSignals yyr7cXlgr)r)rSvals r4rrs r7rN) rVrWrXrYrZpropertyrsetterr\r]r7r4rr s5 r7rc<^\rSrSrSr\rU4SjrSrSr Sr U=r $)StubApplicationRunnerWithSignaliz 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. c2>[TU]U5 SUlgr))superr~ _signalValue)rSr __class__s r4r~(StubApplicationRunnerWithSignal.__init__'s   r7cg)z Does nothing. Nr]rks r4rl.StubApplicationRunnerWithSignal.preApplication+rNr7c[5nURUlURU[R [R 5 g)zH Instantiate a SignalCapturingMemoryReactor and start it in the runner. N)rrrrrrrrs r4ro/StubApplicationRunnerWithSignal.postApplication0s4 /0"// '3::szz:r7)r) rVrWrXrYrZr_rqr~rlror\ __classcell__)rs@r4rrs#&M! ;;r7rc^U4SjnU$)a) 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,>[U5nTUlU$)aw 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 )rr)rrCsignums r4stubApplicationRunnerFactoryIstubApplicationRunnerFactoryCreator..stubApplicationRunnerFactoryGs18$ r7r])r r s` r4#stubApplicationRunnerFactoryCreatorr :s ('r7c0\rSrSrSrSrSrSrSrSr g) ExitWithSignalTestsiZz7 Tests for L{twisted.application.app._exitWithSignal}. c^[R"5TlS[50TRl[ 5TRlSTRlSS/TlU4SjnTR[SU5 g)z= Set up the server options and a fake for use by test cases. r_NcB>UTRS'UTRS'g)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. rrN) fakeKillArgs)rrrSs r4fakeKill+ExitWithSignalTests.setUp..fakeKilljs%$'D  a #&D  a r7r) rrrrLrarbrcrrrEr;)rSrs` r4r8ExitWithSignalTests.setUp`sg**, %35E5G$H !!' !/ !4L ' 2vx(r7c^SS/mU4SjnUR[SU5 [R"[R5 UR TS[R5 UR TS[R 5 UR URS[R"55 UR URS[R5 g)z exitWithSignal replaces the existing signal handler with the default handler and sends the replaced signal to the current process. Nc>UTS'UTS'g)Nrrr])rhandlerfakeSignalArgss r4 fake_signal.fake_signals #N1  'N1 r7rjrr) rErjr _exitWithSignalSIGINTrSIG_DFLrr;r#)rSrrs @r4test_exitWithSignal'ExitWithSignalTests.test_exitWithSignalws  ( 68[1 FMM* .+V]]; .+V^^< $++A. < $++A. >r7cUR[S[S55 [R"UR5 UR UR S5 UR UR S5 g)zJ _exitWithSignal is not called if the runner does not exit with a signal. rNrr)rErr runApprrrrks r4test_normalExit#ExitWithSignalTests.test_normalExitsc ,.QRV.W   dkk" $++A./ $++A./r7c^UR[S[[R55 [R "UR 5 URURS[R"55 URURS[R5 g)z@ _exitWithSignal is called when the runner exits with a signal. rrrN) rErr rjrr!rrrr;r#rks r4test_runnerExitsWithSignal.ExitWithSignalTests.test_runnerExitsWithSignalst  $ / >  dkk" $++A. < $++A. >r7)rrN) rVrWrXrYrZr8rr"r%r\r]r7r4rrZs).?( 0 ?r7r)hrZrr3r;r5rjrr=_grpr:_pwd ImportErroriorunittestrzope.interfacerzope.interface.verifyrrrrr twisted.applicationr r r twisted.application.servicer twisted.internet.basertwisted.internet.deferrtwisted.internet.interfacesrr#twisted.internet.test.modulehelpersrtwisted.internet.testingrtwisted.loggerrrrtwisted.pythonrtwisted.python.componentsrtwisted.python.fakepwdrtwisted.python.logr,rtwisted.python.reflectrtwisted.python.runtimertwisted.python.usagertwisted.scriptsrtwisted.test.test_processrtwisted.trial.unittestr rtwisted.scripts._twistd_unixr!r"r#rr$r%r&rJrLrr_rrhrsrr0r@rRrPr]rrrmr}rrrrrrrdrrrr rr]r7r4rAs    C C&.,,665-+X@2NN3/T0/+",+;<  . /  " x   $*.Z"      = =  UJUJpL56CKHCK7CKLD8D0  *JC11J(p4Xp4fL56F+F+7F+RL56O?O?7O?dL56>(>7><  8 6 (w8w8t*$`5X`5F L56y<y<7yf8Xf8?f8R  *+ = , ;f&C&C;<(@H?(H?OB C CsJ J('J(