+ Dfj4DRt^RIt^RIt^RIt^RIHt^RIHt^RIH t ^RI H t ^RI H t Ht^RIHtHt^RIHt^R IHt^R IHtHt]'d]tM]tR t!R R ]]4t] !]4!RR44t]!4P?]PA44R#)z0 Tests for implementations of L{IReactorFDSet}. N) TYPE_CHECKING)skipIf) implementer)FileDescriptor) IReactorFDSetIReadDescriptor) EINPROGRESS EWOULDBLOCK)ReactorBuilder)platform)SkipTestSynchronousTestCasec>\P!4pVPR4VP^4\P!4pVPR4VP RVP 4^,34VP4wr4TP4Y3# \ d.pTP^,\\39dhRp?LYRp?ii;i \dTP4hi;i TP4i;i) 127.0.0.1FN)r) socketbindlisten setblockingconnect getsocknameOSErrorargsrr accept BaseExceptionclose) serverSocketclienteserveraddrs B/usr/lib/python3/dist-packages/twisted/internet/test/test_fdset.py socketpairr"s==?L&'    u %  \-E-E-G-JKL(..0LFD  > 66!9[+$>>?   LLN   sGD C*!(B/ C*/ C':#C"C*"C''C**DD Dca]tRt^4toRt].tRtRtRt Rt Rt Rt Rt R tR tR tR tR t]!]P*!4R4R4tRtRtVtR#)ReactorFDSetTestsBuilderz6 Builder defining tests relating to L{IReactorFDSet}. c \4wrVPVP4VPVP4W3#)z< Return the two sockets which make up a new TCP connection. )r" addCleanuprselfrrs& r!_connectedPair'ReactorFDSetTestsBuilder._connectedPair;s5$  %  %~cVP4pVP4wr#\V4pVPVnWV3#N) buildReactorr)rfileno)r(reactorrrfds& r! _simpleSetup%ReactorFDSetTestsBuilder._simpleSetupDs@##%,,. G $MM F""r+c aaVP4woopVV3RlpVSnSPS4VPR4VP S4R#)z C{reactor.addReader()} accepts an L{IReadDescriptor} provider and calls its C{doRead} method when there may be data available on its C{fileno}. cJ<SPS4SP4R#r-) removeReaderstopr1r0sr! removeAndStop>ReactorFDSetTestsBuilder.test_addReader..removeAndStopU   $ LLNr+xN)r2doRead addReadersendall runReactorr(rr9r1r0s& @@r!test_addReader'ReactorFDSetTestsBuilder.test_addReaderNsP #//1V " "t  r+c aSP4wrpV3RlpWBnVPV4VPV4VP R4VP ^VP ^VP 4SPV4R#)z L{reactor.removeReader()} accepts an L{IReadDescriptor} provider previously passed to C{reactor.addReader()} and causes it to no longer be monitored for input events. c*<SPR4R#)doRead should not be calledNfailr(sr!rH8ReactorFDSetTestsBuilder.test_removeReader..failis II3 4r+r<N)r2r=r>r6r? callLaterr7r@r(r0r1rrHsf r!test_removeReader*ReactorFDSetTestsBuilder.test_removeReaderasx #//1V 5 "R t !W..7<<@  r+c aaVP4woopVV3RlpVSnSPS4VPS4R#)z C{reactor.addWriter()} accepts an L{IWriteDescriptor} provider and calls its C{doWrite} method when it may be possible to write to its C{fileno}. cJ<SPS4SP4R#r-) removeWriterr7r8sr!r9>ReactorFDSetTestsBuilder.test_addWriter..removeAndStopr;r+N)r2doWrite addWriterr@rAs& @@r!test_addWriter'ReactorFDSetTestsBuilder.test_addWriterysB #//1V # "  r+c VP4p\VRV,R,4p\VRV,4p\VRV,4pVP4wrgVPWc!44VPWs!44V!V4VP Wc!44VPWs!44V!V4VPWc!44VPWs!44R#)z- Helper for getReaders and getWriters tests. getsaddremoveN)r.getattrr) assertNotInassertIn)r(kindr0rXrZr[rrs&& r! _getFDTest#ReactorFDSetTestsBuilder._getFDTests##%gut|c12gut|,(T/2,,. ' ' F  fce$ 'v ' 'r+c (VPR4R#)z L{IReactorFDSet.getReaders} reflects the additions and removals made with L{IReactorFDSet.addReader} and L{IReactorFDSet.removeReader}. ReaderNr`rIs&r!test_getReaders(ReactorFDSetTestsBuilder.test_getReaders !r+c aSP4wrpV3RlpWBnVPV4VPV4VP ^VP^VP 4SP V4R#)z L{reactor.removeWriter()} accepts an L{IWriteDescriptor} provider previously passed to C{reactor.addWriter()} and causes it to no longer be monitored for outputability. c*<SPR4R#)doWrite should not be calledNrGrIsr!rH8ReactorFDSetTestsBuilder.test_removeWriter..fails II4 5r+N)r2rSrTrQrKr7r@rLsf r!test_removeWriter*ReactorFDSetTestsBuilder.test_removeWritersl #//1V 6 "R  !W..7<<@  r+c (VPR4R#)z L{IReactorFDSet.getWriters} reflects the additions and removals made with L{IReactorFDSet.addWriter} and L{IReactorFDSet.removeWriter}. WriterNrdrIs&r!test_getWriters(ReactorFDSetTestsBuilder.test_getWritersrgr+c aSP4pSP4wrpV3RlVnV3RlVnVP R4VP V4VP V4VP4pVP^VP^VP4SPV4SPWB.4R#)z C{reactor.removeAll()} removes all registered L{IReadDescriptor} providers and all registered L{IWriteDescriptor} providers and returns them. c&<SPR4#)rFrGrIsr!9ReactorFDSetTestsBuilder.test_removeAll..sDII&CDr+c&<SPR4#)rjrGrIsr!rtrusTYY'EFr+r<N) r.r2r=rSr?r>rT removeAllrKr7r@ assertEqual)r(r0r1rremovedsf r!test_removeAll'ReactorFDSetTestsBuilder.test_removeAlls ##%"//1VD F t""##% !W..7<<@   $'r+c VP4p\V4pVPVP4VP V4VP VP .4R#)zn A descriptor's C{fileno} method should not be called after the descriptor has been removed from the reactor. N)r.RemovingDescriptorcallWhenRunningstartr@rxcalls)r(r0 descriptors& r!test_removedFromReactor0ReactorFDSetTestsBuilder.test_removedFromReactorsR ##%'0  0 01   ))2.r+c (aaaVP4oVP4woo!VVV3RlR\4pV!S4pSPV4SP R4VP S4VP VPR4R#)zX If L{FileDescriptor.fileno} returns C{-1}, the descriptor is removed from the reactor. ch<a]tRt^toZP 4tRtRtVV3RltV3RltRt Vt R#)WReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptorr+cVP#r-_filenorIs&r!r/^ReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptor.filenos ||#r+c<RVnV;PSP^4, unSPR4R#)yN)r _receivedrecvsendr's&r!r=^ReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptor.doReads,! &++a.0 D!r+c(<SP4R#r-r7r(reasonr0s&&r!connectionLostfReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptor.connectionLosts  r+rN) __name__ __module__ __qualname____firstlineno__r/rrr=r__static_attributes____classdictcell__) __classdict__rr0rs@r!DisappearingDescriptorrs)mmoGI $ "   r+rr<N)r.r)rr>rr@rxr)r(rrrr0rs& @@@r!test_negativeOneFileDescriptor7ReactorFDSetTestsBuilder.test_negativeOneFileDescriptors~ ##%,,.  ^  ,G4 *% D   --t4r+z*Cannot duplicate socket filenos on Windowsc aaaSP4oSPPpVR9d\V: R24hSP 4wpo!VV3RlR\ 4pSP V!44VV3RlpSP^V4SPS4SP\P4R#)a The file descriptor underlying a FileDescriptor may be closed and replaced by another at some point. Bytes which arrive on the new descriptor must not be delivered to the FileDescriptor which was originally registered with the original descriptor of the same number. Practically speaking, this is difficult or impossible to detect. The implementation relies on C{fileno} raising an exception if the original descriptor has gone away. If C{fileno} continues to return the original file descriptor value, the reactor may deliver events from that descriptor. This is a best effort attempt to ease certain debugging situations. Applications should not rely on it intentionally. z$ cannot detect lost file descriptorscD<a]tRtRtoRtV3RltRtV3RltRtVt R#)@ReactorFDSetTestsBuilder.test_lostFileDescriptor..Victimi-aB This L{FileDescriptor} will have its socket closed out from under it and another socket will take its place. It will raise a socket.error from C{fileno} after this happens (because socket objects remember whether they have been closed), so as long as the reactor calls the C{fileno} method the problem will be detected. c$<SP4#r-)r/)r(rs&r!r/GReactorFDSetTestsBuilder.test_lostFileDescriptor..Victim.fileno6s}}&r+c\R4h)z$Victim.doRead should never be called) ExceptionrIs&r!r=GReactorFDSetTestsBuilder.test_lostFileDescriptor..Victim.doRead9s FGGr+c (<SP4R#)z When the problem is detected, the reactor should disconnect this file descriptor. When that happens, stop the reactor so the test ends. Nrrs&&r!rOReactorFDSetTestsBuilder.test_lostFileDescriptor..Victim.connectionLost<s  r+N) rrrr__doc__r/r=rrr)rr0rs@r!Victimr-s  ' H  r+rc<SP4wrSP4pSP4\P!VP4V4VP R4R#)r<N)r)r/rosdup2r)newCnewSr/r(rs r!messItUpBReactorFDSetTestsBuilder.test_lostFileDescriptor..messItUpKsF,,.JD]]_F LLN GGDKKM6 * IIdOr+N) EPollReactor KQueueReactor CFReactorAsyncioSelectorReactor) r. __class__rr r)rr>rKr@flushLoggedErrorsrerror)r(namerrrr0rsf @@r!test_lostFileDescriptor0ReactorFDSetTestsBuilder.test_lostFileDescriptor s##%  ))   dX%IJK K,,.  ^ . &(#  !X&   v||,r+c VP4p!RR\4pVP4wr4V!V4pVPVnV!V4pVPVnVP V4VP V4VP VP4VPV4VPVP4VPVP4R#)zo Any file descriptors added to the reactor have their C{connectionLost} called when C{reactor.stop} is called. c,a]tRtRtoRtRtRtVtR#)SReactorFDSetTestsBuilder.test_connectionLostOnShutdown..DoNothingDescriptoriacR#r-rrIs&r!r=ZReactorFDSetTestsBuilder.test_connectionLostOnShutdown..DoNothingDescriptor.doReadbr+cR#r-rrIs&r!rS[ReactorFDSetTestsBuilder.test_connectionLostOnShutdown..DoNothingDescriptor.doWriteerr+rN)rrrrr=rSrrrs@r!DoNothingDescriptorras   r+rN) r.rr)r/r>rTr~r7r@ assertTrue disconnected)r(r0rrrfd1fd2s& r!test_connectionLostOnShutdown6ReactorFDSetTestsBuilder.test_connectionLostOnShutdownZs ##% . ,,.!'*]] !'*]] ## -   (() (()r+rN)rrrrrrrequiredInterfacesr)r2rBrMrUr`rerlrprzrrrr isWindowsrrrrrs@r!r$r$4s(#!&!0!$(,"!."(: /5> H   "NOJ-PJ-X**r+r$cHa]tRtRtoRtRtRtRtRtRt Rt R t Vt R #) r}iwax A read descriptor which removes itself from the reactor as soon as it gets a chance to do a read and keeps track of when its own C{fileno} method is called. @ivar insideReactor: A flag which is true as long as the reactor has this descriptor as a reader. @ivar calls: A list of the bottom of the call stack for any call to C{fileno} when C{insideReactor} is false. c\WnRVn.Vn\4wVnVnR#FN)r0 insideReactorrr"readwrite)r(r0s&&r!__init__RemovingDescriptor.__init__s& " *  4:r+cRVnVPPV4VPP R4R#)TaN)rr0r>rrrIs&r!rRemovingDescriptor.starts,! t$ r+cR#)foorrIs&r! logPrefixRemovingDescriptor.logPrefixsr+cVPPV4RVnVPP4VPP 4VP P 4R#r)r0r6rr7rrrrIs&r!r=RemovingDescriptor.doReadsJ !!$'"   r+cVP'g4VPP\P!^R7RR4VP P 4#))limitNr)rrappend traceback extract_stackrr/rIs&r!r/RemovingDescriptor.filenosE!!! JJ  i55A>sC Dyy!!r+cR#r-r)r(rs&&r!r!RemovingDescriptor.connectionLosts r+)rrr0rrN) rrrrrrrrr=r/rrrrs@r!r}r}ws- -  "   r+r})!rrrrtypingrunittestrzope.interfacertwisted.internet.abstractrtwisted.internet.interfacesrrtwisted.internet.tcprr #twisted.internet.test.reactormixinsr twisted.python.runtimer twisted.trial.unittestr r PretendTestCaseobjectr"r$r}globalsupdatemakeTestCaseClassesrr+r!rs  &4F9>+@)OO.@*~@*F  _+ + + \ )==?@r+