֛h=.^SrSSKrSSKJr SSKJr SSKJrJr SSK J r SSK J r SSK Jr SrSS KJr SS KJr SS KJr SS KJr "SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5rg!\a S rNof=f)z> Tests for L{twisted.internet.posixbase} and supporting code. N)Deferred)IReadDescriptor)PosixReactorBase_Waker) ServerFactory)platform)TestCase)unix) ClientProtoz)Platform does not support AF_UNIX sockets)reactor)Portc8^\rSrSrSrU4SjrU4SjrSrU=r$)WarningCheckerTestCasez_ A test case that will make sure that no warnings are left unchecked at the end of a test run. c>[TU]5 [RR SS5R 5S:Xa,[ R"5(aUR5 ggg)NCItrue) supersetUposenvirongetlowerr isWindows flushWarnings)self __class__s hC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_posixbase.pyrWarningCheckerTestCase.setUp sQ   ::>>$ # ) ) +v 5(:L:L:N:N    ;O 5c">[TU]5 UR5n[RR SS5R 5S:Xa[R"5(agUR[U5SSU35 g!UR5n[RR SS5R 5S:Xa[R"5(a gUR[U5SSU35 f=f)Nrrrrz'Warnings found at the end of the test: ) rtearDownrrrrrrr assertEquallen)rwarningsrs rr#WarningCheckerTestCase.tearDown+s  G  ))+Hzz~~dB'--/69h>P>P>R>R   H q$LXJ"W ))+Hzz~~dB'--/69h>P>P>R>R   H q$LXJ"W sBAD. D) __name__ __module__ __qualname____firstlineno____doc__rr#__static_attributes__ __classcell__)rs@rrrs !r!rc2\rSrSrSrSrSrSrSrSr g) TrivialReactor=cL0Ul0Ul[R"U5 gN)_readers_writersr__init__rs rr7TrivialReactor.__init__>s  !!$'r!c"SURU'gNTr5rreaders r addReaderTrivialReactor.addReaderC $ fr!cURU gr4r<r=s r removeReaderTrivialReactor.removeReaderF MM& !r!c"SURU'gr;r6rwriters r addWriterTrivialReactor.addWriterIrAr!cURU gr4rGrHs r removeWriterTrivialReactor.removeWriterLrEr!)r5r6N) r)r*r+r,r7r?rCrJrMr.r(r!rr1r1=s( %"%"r!r1c0\rSrSrSrSrSrSrSrSr g) PosixReactorBaseTestsPz Tests for L{PosixReactorBase}. cURUR[5 URURUR5 URURUR 5 gr4)assertIsInstancewakerrassertIn_internalReadersr5rr s r _checkWaker!PosixReactorBaseTests._checkWakerUsF gmmV4 gmmW%=%=> gmmW%5%56r!c:[5nURU5 g)zg When L{PosixReactorBase} is instantiated, it creates a waker and adds it to its internal readers set. N)r1rXrWs rtest_wakerIsInternalReader0PosixReactorBaseTests.test_wakerIsInternalReaderZs !" !r!cb[5n[5nURRU5 UR"U5 UR "UR UR5 URU5 URX!R5 URX!R 5 g)zs Any L{IReadDescriptor}s in L{PosixReactorBase._internalReaders} are left alone by L{PosixReactorBase._removeAll}. N) r1objectrVaddr? _removeAllr5r6rXrU)rr extras r"test_removeAllSkipsInternalReaders8PosixReactorBaseTests.test_removeAllSkipsInternalReadersbs !"  $$U+% 7++W-=-=> ! e556 e--.r!cz[5n[5n[5nUR"U5 UR"U5 UR"UR UR 5nUR[U5X#15 URX!R 5 URX1R 5 g)zn L{PosixReactorBase._removeAll} returns a list of removed L{IReadDescriptor} and L{IWriteDescriptor} objects. N) r1r^r?rJr`r5r6r$set assertNotIn)rr r>rIremoveds r'test_removeAllReturnsRemovedDescriptors=PosixReactorBaseTests.test_removeAllReturnsRemovedDescriptorsps !"&!&!$$W%5%5w7G7GH W'78 !1!12 !1!12r!r(N) r)r*r+r,r-rXr[rbrhr.r(r!rrPrPPs7 " / 3r!rPc>\rSrSrSr\"\\5(dSrSr Sr g) TCPPortTestsz) Tests for L{twisted.internet.tcp.Port}. zNon-posixbase reactorc[S[55nSUlSUlUR UR 5[ 5$)zk L{Port.stopListening} returns a L{Deferred} which errbacks if L{Port.connectionLost} raises an exception. i90Tc SS-$)Nrr()reasons r8TCPPortTests.test_connectionLostFailed..sQ!Vr!)r r connectedconnectionLost assertFailure stopListeningZeroDivisionError)rports rtest_connectionLostFailed&TCPPortTests.test_connectionLostFaileds> E=?+3!!$"4"4"68IJJr!r(N) r)r*r+r,r- isinstancer rskipryr.r(r!rrkrks" g/ 0 0&Kr!rkcT\rSrSrSrSrS\SS4SjrS\SS4SjrS r S r S r S r g) TimeoutReportReactorz A reactor which is just barely runnable and which cannot monitor any readers or writers, and which fires a L{Deferred} with the timeout passed to its C{doIteration} method as soon as that method is invoked. c\[R"U5 [5UlSUlg)Nd)rr7riterationTimeoutnowr8s rr7TimeoutReportReactor.__init__s!!!$' ( r!r>returnNcg)z Ignore the reader. This is necessary because the waker will be added. However, we won't actually monitor it for any events. Nr(r=s rr?TimeoutReportReactor.addReaderr!cg)z See L{addReader}. Nr(r=s rrC!TimeoutReportReactor.removeReaderrr!c/$)z There are no readers or writers, so there is nothing to remove. This will be called when the reactor stops, though, so it must be implemented. r(r8s r removeAllTimeoutReportReactor.removeAlls  r!cUR$)z` Override the real clock with a deterministic one that can be easily controlled in a unit test. )rr8s rsecondsTimeoutReportReactor.secondss xxr!cTURnUbSUlURU5 ggr4)rcallback)rtimeoutds r doIteration TimeoutReportReactor.doIterations+  ! ! =$(D ! JJw  r!)rr) r)r*r+r,r-r7rr?rCrrrr.r(r!rr~r~sA    D  ? t  r!r~cH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) IterationTimeoutTestsz Tests for the timeout argument L{PosixReactorBase.run} calls L{PosixReactorBase.doIteration} with in the presence of various delayed calls. c^/nTRRUR5 TRRU4Sj5 TR"5 US$)Nc&>TR"5$r4)stop)ignoredr s rrq>IterationTimeoutTests._checkIterationTimeout..s W\\^r!r)r addCallbackappendrunrr rs ` r_checkIterationTimeout,IterationTimeoutTests._checkIterationTimeoutsH  ,,W^^<  ,,-KL qzr!c\[5nURU5nURU5 g)zT If there are no delayed calls, C{doIteration} is called with a timeout of L{None}. N)r~r assertIsNoners r test_noCalls"IterationTimeoutTests.test_noCallss* '(--g6 '"r!c[5nUR"SS5 URU5nURUS5 g)z If there is a delayed call, C{doIteration} is called with a timeout which is the difference between the current time and the time at which that call is to run. rcgr4r(r(r!rrq8IterationTimeoutTests.test_delayedCall..tr!Nr~ callLaterrr$rs rtest_delayedCall&IterationTimeoutTests.test_delayedCalls< '(#|,--g6 #&r!c[5nUR"SS5 U=RS- slURU5nUR US5 g)z If a delayed call is scheduled and then some time passes, the timeout passed to C{doIteration} is reduced by the amount of time which passed. rcgr4r(r(r!rrq7IterationTimeoutTests.test_timePasses..rr!KN)r~rrrr$rs rtest_timePasses%IterationTimeoutTests.test_timePassessJ '(#|, r --g6 "%r!c[5nUR"SS5 UR"SS5 UR"SS5 URU5nURUS5 g)z If there are several delayed calls, C{doIteration} is called with a timeout which is the difference between the current time and the time at which the earlier of the two calls is to run. 2cgr4r(r(r!rrqAIterationTimeoutTests.test_multipleDelayedCalls..dr! cgr4r(r(r!rrqrrr!rcgr4r(r(r!rrqrrr!Nrrs rtest_multipleDelayedCalls/IterationTimeoutTests.test_multipleDelayedCallss\ '("l+"l+#|,--g6 "%r!c[5nUR"SS5nU=RS- slURS5 UR U5nUR US5 g)z If a delayed call is reset, the timeout passed to C{doIteration} is based on the interval between the time when reset is called and the new delay of the call. rcgr4r(r(r!rrq=IterationTimeoutTests.test_resetDelayedCall..Tr!rN)r~rrresetrr$rr callrs rtest_resetDelayedCall+IterationTimeoutTests.test_resetDelayedCallsW '(  \2 r  2--g6 "%r!c[5nUR"SS5nU=RS- slURS5 UR U5nUR US5 g)z If a delayed call is re-delayed, the timeout passed to C{doIteration} is based on the remaining time before the call would have been made and the additional amount of time passed to the delay method. rcgr4r(r(r!rrq=IterationTimeoutTests.test_delayDelayedCall..rr!r<N)r~rrdelayrr$rs rtest_delayDelayedCall+IterationTimeoutTests.test_delayDelayedCallsW'(  \2 r  2--g6 "%r!c[5nUR"SS5nUR5 URU5nUR U5 g)zX If the only delayed call is canceled, L{None} is the timeout passed to C{doIteration}. rcgr4r(r(r!rrq>IterationTimeoutTests.test_cancelDelayedCall..rr!N)r~rcancelrrrs rtest_cancelDelayedCall,IterationTimeoutTests.test_cancelDelayedCallsE '(  \2 --g6 '"r!r(N)r)r*r+r,r-rrrrrrrrr.r(r!rrrs/ # ' & & & & #r!rc.\rSrSrSr\b\rSrSrSr g)ConnectedDatagramPortTestsi"z' Test connected datagram UNIX sockets. Nc~^U4Sjn[R"S[55nXlUR S5 g)zw L{ConnectedDatagramPort} does not call the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. c(>TRS5 g)z\ Dummy C{loseConnection} method. C{loseConnection} is deprecated and should not get called. z7loseConnection is deprecated and should not get called.N)failr8srloseConnection`ConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection..loseConnection0s IIO Pr!Ngoodbye)r ConnectedDatagramPortr rconnectionFailed)rrrxs` r-test_connectionFailedDoesntCallLoseConnectionHConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection*s3  Q))$ >, i(r!c^STlU4Sjn[R"S[55nXlUR S5 TR TR5 g)z L{ConnectedDatagramPort} calls L{ConnectedDatagramPort.stopListening} instead of the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. Fc>STlg)z Dummy C{stopListening} method. TNcalledr8srrvYConnectedDatagramPortTests.test_connectionFailedCallsStopListening..stopListeningCs DKr!Nr)rr rr rvr assertTrue)rrvrxs` r'test_connectionFailedCallsStopListeningBConnectedDatagramPortTests.test_connectionFailedCallsStopListening;sK    ))$ >* i(  $r!r) r)r*r+r,r- skipSocketsr|rrr.r(r!rrr"s)"%r!rc\rSrSrSrSrg) WakerTestsiOc[5nUR5nUR[U5SU5 UR S5 UR5nUR[U5SU5 g)z8 No warnings are generated when constructing the waker. rN)rrr$r%rt)rrTr&s r test_noWakerConstructionWarnings+WakerTests.test_noWakerConstructionWarningsPsc%%' X84 T"%%' X84r!r(N)r)r*r+r,rr.r(r!rrrOs 5r!r) r-rtwisted.internet.deferrtwisted.internet.interfacesrtwisted.internet.posixbaserrtwisted.internet.protocolrtwisted.python.runtimertwisted.trial.unittestr rtwisted.internetr twisted.test.test_unixr ImportErrorr twisted.internet.tcpr rr1rPrkr~rrrr(r!rrs +7?3++ >%2%%XD"%"&-32-3`K)K&* +* Z_#2_#D*%!7*%Z 5' 5w >=K>s B!!B,+B,