֛h4@SrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSK J r SSK J r Jr SSKJrJr SS KJr SS KJr SS KJrJr \(a\rO\rS r"S S\\5r\ "\5"SS55r\"5R?\RA55 g)z0 Tests for implementations of L{IReactorFDSet}. N) TYPE_CHECKING)skipIf) implementer)FileDescriptor) IReactorFDSetIReadDescriptor) EINPROGRESS EWOULDBLOCK)ReactorBuilder)platform)SkipTestSynchronousTestCasec([R"5nURS5 URS5 [R"5nURS5 UR SUR 5S45 UR5up4UR5 X4$![ a(nURS[[4;aeSnANSSnAff=f![a UR5 ef=f!UR5 f=f)N) 127.0.0.1rFrr) socketbindlisten setblockingconnect getsocknameOSErrorargsr r accept BaseExceptionclose) serverSocketclienteserveraddrs dC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_fdset.py socketpairr#s==?L&'    u %  \-E-E-G-JKL(..0LFD  > 66!9[+$>>?   LLN   sGC?C !$B+C + C5CC CC C<<C??Dc\rSrSrSr\/rSrSrSr Sr Sr Sr S r S rS rS rS rSr\"\R*"5S5S5rSrSrg)ReactorFDSetTestsBuilder4z6 Builder defining tests relating to L{IReactorFDSet}. c[5upURUR5 URUR5 X4$)z< Return the two sockets which make up a new TCP connection. )r# addCleanuprselfrr s r"_connectedPair'ReactorFDSetTestsBuilder._connectedPair;s5$  %  %~cUR5nUR5up#[U5nURUlXU4$N) buildReactorr+rfileno)r*reactorrr fds r" _simpleSetup%ReactorFDSetTestsBuilder._simpleSetupDs@##%,,. G $MM F""r-c^^UR5ummnUU4SjnUTlTRT5 URS5 UR T5 g)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}. cH>TRT5 TR5 gr/) removeReaderstopr3r2sr" removeAndStop>ReactorFDSetTestsBuilder.test_addReader..removeAndStopU   $ LLNr-xN)r4doRead addReadersendall runReactorr*r r;r3r2s @@r"test_addReader'ReactorFDSetTestsBuilder.test_addReaderNsP #//1V " "t  r-c^TR5upnU4SjnXBlURU5 URU5 UR S5 UR SUR SUR 5 TRU5 g)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(>TRS5 gNzdoRead should not be calledfailr*sr"rJ8ReactorFDSetTestsBuilder.test_removeReader..failis II3 4r-r>rN)r4r?r@r8rA callLaterr9rBr*r2r3r rJs` r"test_removeReader*ReactorFDSetTestsBuilder.test_removeReaderasx #//1V 5 "R t !W..7<<@  r-c^^UR5ummnUU4SjnUTlTRT5 URT5 g)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}. cH>TRT5 TR5 gr/) removeWriterr9r:sr"r;>ReactorFDSetTestsBuilder.test_addWriter..removeAndStopr=r-N)r4doWrite addWriterrBrCs @@r"test_addWriter'ReactorFDSetTestsBuilder.test_addWriterysB #//1V # "  r-cUR5n[USU-S-5n[USU-5n[USU-5nUR5upgURXc"55 URXs"55 U"U5 UR Xc"55 URXs"55 U"U5 URXc"55 URXs"55 g)z- Helper for getReaders and getWriters tests. getsaddremoveN)r0getattrr+ assertNotInassertIn)r*kindr2rZr\r]rr s r" _getFDTest#ReactorFDSetTestsBuilder._getFDTests##%gut|c12gut|,(T/2,,. ' ' F  fce$ 'v ' 'r-c&URS5 g)z L{IReactorFDSet.getReaders} reflects the additions and removals made with L{IReactorFDSet.addReader} and L{IReactorFDSet.removeReader}. ReaderNrbrKs r"test_getReaders(ReactorFDSetTestsBuilder.test_getReaders !r-c^TR5upnU4SjnXBlURU5 URU5 UR SURSUR 5 TR U5 g)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(>TRS5 gNzdoWrite should not be calledrIrKsr"rJ8ReactorFDSetTestsBuilder.test_removeWriter..fails II4 5r-rN)r4rUrVrSrMr9rBrNs` r"test_removeWriter*ReactorFDSetTestsBuilder.test_removeWritersl #//1V 6 "R  !W..7<<@  r-c&URS5 g)z L{IReactorFDSet.getWriters} reflects the additions and removals made with L{IReactorFDSet.addWriter} and L{IReactorFDSet.removeWriter}. WriterNrfrKs r"test_getWriters(ReactorFDSetTestsBuilder.test_getWritersrir-c^TR5nTR5upnU4SjUlU4SjUlUR S5 UR U5 UR U5 UR5nURSURSUR5 TRU5 TRXB/5 g)z C{reactor.removeAll()} removes all registered L{IReadDescriptor} providers and all registered L{IWriteDescriptor} providers and returns them. c&>TRS5$rHrIrKsr"9ReactorFDSetTestsBuilder.test_removeAll..sDII&CDr-c&>TRS5$rlrIrKsr"rvrwsTYY'EFr-r>rN) r0r4r?rUrAr@rV removeAllrMr9rB assertEqual)r*r2r3r removeds` r"test_removeAll'ReactorFDSetTestsBuilder.test_removeAlls ##%"//1VD F t""##% !W..7<<@   $'r-cUR5n[U5nURUR5 UR U5 UR UR /5 g)zn A descriptor's C{fileno} method should not be called after the descriptor has been removed from the reactor. N)r0RemovingDescriptorcallWhenRunningstartrBrzcalls)r*r2 descriptors r"test_removedFromReactor0ReactorFDSetTestsBuilder.test_removedFromReactorsR ##%'0  0 01   ))2.r-c&^^^UR5mUR5umm"UUU4SjS[5nU"T5nTRU5 TR S5 UR T5 UR URS5 g)zX If L{FileDescriptor.fileno} returns C{-1}, the descriptor is removed from the reactor. c\>\rSrSrYR 5rSrSrUU4SjrU4SjrSr g)WReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptorr-cUR$r/_filenorKs r"r1^ReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptor.filenos ||#r-c~>SUlU=RTRS5- slTRS5 g)Nry)r _receivedrecvsendr)s r"r?^ReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptor.doReads,! &++a.0 D!r-c&>TR5 gr/r9r*reasonr2s r"connectionLostfReactorFDSetTestsBuilder.test_negativeOneFileDescriptor..DisappearingDescriptor.connectionLosts  r-rN) __name__ __module__ __qualname____firstlineno__r1rrr?r__static_attributes__)rr2r sr"DisappearingDescriptorrs'mmoGI $ "   r-rr>N)r0r+rr@rrBrzr)r*rrrr2r s @@@r"test_negativeOneFileDescriptor7ReactorFDSetTestsBuilder.test_negativeOneFileDescriptors~ ##%,,.  ^  ,G4 *% D   --t4r-z*Cannot duplicate socket filenos on Windowsc^^^TR5mTRRnUS;a[U<S35eTR 5unm"UU4SjS[ 5nTR U"55 UU4SjnTRSU5 TRT5 TR[R5 g)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. ) EPollReactor KQueueReactor CFReactorAsyncioSelectorReactorz$ cannot detect lost file descriptorsc8>\rSrSrSrU4SjrSrU4SjrSrg)@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$>TR5$r/)r1)r*r s r"r1GReactorFDSetTestsBuilder.test_lostFileDescriptor..Victim.fileno6s}}&r-c[S5e)Nz$Victim.doRead should never be called) ExceptionrKs r"r?GReactorFDSetTestsBuilder.test_lostFileDescriptor..Victim.doRead9s FGGr-c&>TR5 g)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__r1r?rr)r2r sr"Victimr-s  ' H  r-rc>TR5upTR5nTR5 [R"UR5U5 UR S5 g)Nr>)r+r1rosdup2r)newCnewSr1r*r s r"messItUpBReactorFDSetTestsBuilder.test_lostFileDescriptor..messItUpKsF,,.JD]]_F LLN GGDKKM6 * IIdOr-rN) r0 __class__rr r+rr@rMrBflushLoggedErrorsrerror)r*namerrrr2r s` @@r"test_lostFileDescriptor0ReactorFDSetTestsBuilder.test_lostFileDescriptor s##%  ))   dX%IJK K,,.  ^ . &(#  !X&   v||,r-cUR5n"SS[5nUR5up4U"U5nURUlU"U5nURUlUR U5 UR U5 UR UR5 URU5 URUR5 URUR5 g)zo Any file descriptors added to the reactor have their C{connectionLost} called when C{reactor.stop} is called. c \rSrSrSrSrSrg)SReactorFDSetTestsBuilder.test_connectionLostOnShutdown..DoNothingDescriptoriacgr/rrKs r"r?ZReactorFDSetTestsBuilder.test_connectionLostOnShutdown..DoNothingDescriptor.doReadbr-cgr/rrKs r"rU[ReactorFDSetTestsBuilder.test_connectionLostOnShutdown..DoNothingDescriptor.doWriteerr-rN)rrrrr?rUrrr-r"DoNothingDescriptorras   r-rN) r0rr+r1r@rVrr9rB assertTrue disconnected)r*r2rrr fd1fd2s r"test_connectionLostOnShutdown6ReactorFDSetTestsBuilder.test_connectionLostOnShutdownZs ##% . ,,.!'*]] !'*]] ## -   (() (()r-rN)rrrrrrrequiredInterfacesr+r4rDrOrWrbrgrnrrr|rrrr isWindowsrrrrr-r"r%r%4s{(#!&!0!$(,"!."(: /5> H   "NOJ-PJ-X*r-r%c<\rSrSrSrSrSrSrSrSr Sr S r g ) riwax 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. cZXlSUl/Ul[5uUlUlgNF)r2 insideReactorrr#readwrite)r*r2s r"__init__RemovingDescriptor.__init__s& " *  4:r-c~SUlURRU5 URR S5 g)NTa)rr2r@rrrKs r"rRemovingDescriptor.starts,! t$ r-cg)NfoorrKs r" logPrefixRemovingDescriptor.logPrefixsr-cURRU5 SUlURR5 URR 5 UR R 5 gr)r2r8rr9rrrrKs r"r?RemovingDescriptor.doReadsJ !!$'"   r-cUR(d0URR[R"SS9SS5 UR R 5$)N)limitr)rrappend traceback extract_stackrr1rKs r"r1RemovingDescriptor.filenosB!! JJ  i55A>sC Dyy!!r-cgr/r)r*rs r"r!RemovingDescriptor.connectionLosts r-)rrr2rrN) rrrrrrrrr?r1rrrr-r"rrws% -  "  r-r)!rrrrtypingrunittestrzope.interfacertwisted.internet.abstractrtwisted.internet.interfacesrrtwisted.internet.tcpr r #twisted.internet.test.reactormixinsr twisted.python.runtimer twisted.trial.unittestr rPretendTestCaseobjectr#r%rglobalsupdatemakeTestCaseClassesrr-r"rs  &4F9>+@)OO.@*~@*F  _+ + + \ )==?@r-