+ j+aRt0tRt^RIt^RIt^RIt^RIHt]^k^RIt^RIH t Rt ^RI H t !RR4t!RR 4t!R R ] 4t!R R ] 4tR# ] dRt L=i;i)z; Tests for POSIX-based L{IReactorProcess} implementations. N)Optional)processznon-POSIX platform)TestCasec<a]tRt^toRtRtRtRtRtRt Vt R#)FakeFilez6 A dummy file object which records when it is closed. cWnW nR#N)testcasefd)selfr r s&&&I/usr/lib/python3/dist-packages/twisted/internet/test/test_posixprocess.py__init__FakeFile.__init__ s  cdVPPPVP4R#r)r _filesremover r s&r closeFakeFile.close$s ##DGG,rcV#rrs&r __enter__FakeFile.__enter__'s rc&VP4R#r)r)r exc_type exc_value tracebacks&&&&r __exit__FakeFile.__exit__*s  r)r r N) __name__ __module__ __qualname____firstlineno____doc__r rrr__static_attributes____classdictcell__ __classdict__s@r rrs#-rrc4a]tRt^.toRt^tRtRtRtVt R#)FakeResourceModulez Fake version of L{resource} which hard-codes a particular rlimit for maximum open files. @ivar _limit: The value to return for the hard limit of number of open files. cWnR#r_limitr limits&&r r FakeResourceModule.__init__8s rc FWP8Xd^VP.#^{R.#)zH A fake of L{resource.getrlimit} which returns a pre-determined result. i) RLIMIT_NOFILEr-)r nos&&r getrlimitFakeResourceModule.getrlimit;s) ## #t{{# #Szrr,N) r r!r"r#r$r2r r4r%r&r's@r r*r*.s Mrr*ca]tRt^DtoRt]tRtRtRt Rt Rt Rt Rt RtRtR tR tR tR tR tRtRtRtRtVtR#)FDDetectorTestsa Tests for _FDDetector class in twisted.internet.process, which detects which function to drop in place for the _listOpenFDs method. @ivar devfs: A flag indicating whether the filesystem fake will indicate that /dev/fd exists. @ivar accurateDevFDResults: A flag indicating whether the /dev/fd fake returns accurate open file information. @ivar procfs: A flag indicating whether the filesystem fake will indicate that /proc//fd exists. Fc ^{#)z. Fake os.getpid, always return the same thing rrs&r getpidFDDetectorTests.getpidZsrc \\VP4pVP'd VRVP 43,8XdV#VP 'd VR8XdVP 'dV#.RO#\4h)zl Fake os.listdir, depending on what mode we're in to simulate behaviour. @param arg: the directory to list z /proc/%d/fdz/dev/fd)012)mapstrrprocfsr9devfsaccurateDevFDResultsOSError)r argaccurates&& r listdirFDDetectorTests.listdir`se sDKK( ;;;3=DKKM3C#CDO :::#*(((" "irc  \V\\\R44\VP4, 44pVPP VP 4V#)a This is a mock for L{open}. It keeps track of opened files so extra descriptors can be returned from the mock for L{os.listdir} when used on one of the list-of-filedescriptors directories. A L{FakeFile} is returned which can be closed to remove the new descriptor from the open list. )rminsetrangerappendr )r fnamemodefs&&& r openfileFDDetectorTests.openfileosG T3s5;/#dkk2BBC D 144 rc ,R\PR&R#)zX Make the L{resource} module unimportable for the remainder of the current test method. Nresource)sysmodulesrs&r hideResourceModule"FDDetectorTests.hideResourceModule}s #' Jrc >\V4\PR&R#)z Make a L{FakeResourceModule} instance importable at the L{resource} name. @param limit: The value which will be returned for the hard limit of number of open files by the fake resource module's C{getrlimit} function. rUN)r*rVrWr.s&&r revealResourceModule$FDDetectorTests.revealResourceModules#5U"; Jrc Vf\PRR#V\PR&R# \dR#i;i)z9 Restore the original resource module to L{sys.modules}. NrU)rVrWKeyError)r values&&r replaceResourceModule%FDDetectorTests.replaceResourceModules> = KK +',CKK #  s . ==c `\P!4VnVPVPnVPVPnVP VPn.ROVnVPVP\PPR44R#)z Set up the tests, giving ourselves a detector object to play with and setting up its testable knobs to refer to our mocked versions. rUN) r _FDDetectordetectorrGr9rRr addCleanupr`rVrWgetrs&r setUpFDDetectorTests.setUpsl  ++- $  #{{ !%   22CKKOOJ4OPrc aRpRpV3RlpVVV.SPnSPVSPP44R#)z L{FDDetector._getImplementation} returns the first method from its C{_implementations} list which returns results which reflect a newly opened file descriptor. c\R4h)zThis does not work) ValueErrorrrr failWithExceptionBFDDetectorTests.test_selectFirstWorking..failWithExceptions12 2rc .RO#rdrcrrrr failWithWrongResultsEFDDetectorTests.test_selectFirstWorking..failWithWrongResults rc*<SPR,#):NNN)rrsr correct8FDDetectorTests.test_selectFirstWorking..corrects;;q> !rNrh_implementationsassertIs_getImplementation)r rprtrxsf r test_selectFirstWorking'FDDetectorTests.test_selectFirstWorkingsH 3  "  *  & gt}}??ABrc RpRpVV.VPnVPW PP44R#)z L{FDDetector._getImplementation} returns the last method from its C{_implementations} list if none of the implementations manage to return results which reflect a newly opened file descriptor. c .RO#))r rrrr rt=FDDetectorTests.test_selectLast..failWithWrongResultsrvrc .RO#rsrrrr failWithOtherWrongResultsBFDDetectorTests.test_selectLast..failWithOtherWrongResultsrvrNrz)r rtrs& r test_selectLastFDDetectorTests.test_selectLasts>   ! %*  & /1Q1Q1STrc 8\P!4pVPPpVP4VPPpVP4VPPpVP W#4VP W44R#)z Check that the identity of _listOpenFDs changes after running _listOpenFDs the first time, but not after the second time it's run. In other words, check that the monkey patching actually works. N)rrg _listOpenFDsr assertNotEqual assertEqual)r rhfirstsecondthirds& r !test_identityOfListOpenFDsChanges1FDDetectorTests.test_identityOfListOpenFDsChangessy&&(%%..&&//%%.. E* 'rc RVnVP\VPP4RVnRVnVP .ROVPP 44R#)z L{_FDDetector._devFDImplementation} raises L{OSError} if there is no I{/dev/fd} directory, otherwise it returns the basenames of its children interpreted as integers. FTNrc)rB assertRaisesrDrh_devFDImplementationrCrrs&r test_devFDImplementation(FDDetectorTests.test_devFDImplementationsQ   '4==#E#EF $)! DMM$F$F$HIrc RVnVP\VPP4RVnVP .ROVPP 44R#)z L{_FDDetector._procFDImplementation} raises L{OSError} if there is no I{/proc//fd} directory, otherwise it returns the basenames of its children interpreted as integers. FTNrc)rArrDrh_procFDImplementationrrs&r test_procFDImplementation)FDDetectorTests.test_procFDImplementationsI   '4==#F#FG  DMM$G$G$IJrc ^VPR4VP\\R44\VPP 444VPR4VP\\R44\VPP 444R#)z L{_FDDetector._fallbackFDImplementation} uses the L{resource} module if it is available, returning a range of integers from 0 to the minimum of C{1024} and the hard I{NOFILE} limit. iirJN)r[rlistrMrh_fallbackFDImplementationrs&r test_resourceFDImplementation-FDDetectorTests.test_resourceFDImplementations~ !!#&  s d4==#J#J#LM !!$'  t tDMM$K$K$MN rc VP4VP\\R44\VPP 444R#)z L{_FDDetector._fallbackFDImplementation}, the implementation of last resort, succeeds with a fixed range of integers from 0 to 1024 when the L{resource} module is not importable. rJN)rXrrrMrhrrs&r test_fallbackFDImplementation-FDDetectorTests.test_fallbackFDImplementations> !  t tDMM$K$K$MN r)rrCrhrBrAN)r r!r"r#r$ platformSkipskiprBrCrAr9rGrRrXr[r`rkr~rrrrrrr%r&r's@r r7r7Dsq  D E  F  ' < , QC0U((& J K $   rr7c4a]tRtRtoRt]tRtRtRt Vt R#)FileDescriptorTestsiz4 Tests for L{twisted.internet.process._listOpenFDs} c  6\P!4F)p\P!V\P4K+ R# \dIpTP \ PTP RYP 3,4Rp?K}Rp?ii;i)z File descriptors returned by L{_listOpenFDs} are mostly open. This test assumes that zero-legth writes fail with EBADF on closed file descriptors. z2fcntl(%d, F_GETFL) failed with unexpected errno %dN)rrfcntlF_GETFLrDrerrnoEBADF)r r errs& r test_openFDs FileDescriptorTests.test_openFDs"sr&&(B  B .)   KKIIH99o& s%A B=BBc F\\P4p\P!4pVP VP 4V4\P!VP 44pVPW1P 48R4VP4VP V\P!44\P!V4VPV\P!44R# \P!T4i;i)z2 L{_listOpenFDs} lists expected file descriptors. z>Expected duplicate file descriptor to be greater than originalN) openosdevnullrrassertInfilenodup assertTruer assertNotIn)r rQopenfdsr s& r test_expectedFDs$FileDescriptorTests.test_expectedFDs4s  &&( ahhj'*VVAHHJ   O L   GGI MM"g224 5 HHRL W1134 HHRLs 5DD rN) r r!r"r#r$rrrrr%r&r's@r rrs  D$)5)5rrcVV^8dQh/^\9d\\,;R&#)rfr)__conditional_annotations__rr@)formats"r __annotate__rs"hsmr)rr$rrrVtypingrrtwisted.internetrr ImportErrortwisted.trial.unittestrrr*r7rr)rs@r rsy  )L+&,T hT nB5(B5U('L(sA A*)A*