+ j=.bRt^RIt^RIHt^RIHt^RIHtHt^RI H t ^RI H t ^RI HtRt^RIHt^R IHt^R IHt^R IHt!R R]4t!RR]4t!RR]4t!RR]4t!RR]4t!RR]4t!RR]4t!RR]4tR# ]dR tLqi;i)z> Tests for L{twisted.internet.posixbase} and supporting code. N)DeferredIReadDescriptor)PosixReactorBase_Waker) ServerFactory)platform)TestCase)unix) ClientProtoz)Platform does not support AF_UNIX sockets)reactor)PortcBaa]tRt^toRtV3RltV3RltRtVtV;t #)WarningCheckerTestCasez_ A test case that will make sure that no warnings are left unchecked at the end of a test run. c<\SV`4\PP RR4P 4R8Xd0\ P!4'dVP4R#R#R#)CItrueN) supersetUposenvirongetlowerr isWindows flushWarnings)self __class__s&F/usr/lib/python3/dist-packages/twisted/internet/test/test_posixbase.pyrWarningCheckerTestCase.setUp sQ   ::>>$ # ) ) +v 5(:L:L:N:N    ;O 5c0<\SV`4VP4p\PP RR4P 4R8Xd\P!4'dR#VP\V4^RV 24R# TP4p\PP RR4P 4R8Xd \P!4'dR#TP\T4^RT 24i;i)rrrNz'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 sBAD1D5 D) __name__ __module__ __qualname____firstlineno____doc__rr"__static_attributes____classdictcell__ __classcell__)r __classdict__s@@rrrs !r rc>a]tRt^=toRtRtRtRtRtRt Vt R#)TrivialReactorcN/Vn/Vn\P!V4R#N)_readers_writersr__init__rs&rr7TrivialReactor.__init__>s  !!$'r c$RVPV&R#TNr5rreaders&&r addReaderTrivialReactor.addReaderC $ fr c VPVR#r4r<r=s&&r removeReaderTrivialReactor.removeReaderF MM& !r c$RVPV&R#r;r6rwriters&&r addWriterTrivialReactor.addWriterIrAr c VPVR#r4rGrHs&&r removeWriterTrivialReactor.removeWriterLrEr )r5r6N) r(r)r*r+r7r?rCrJrMr-r.r0s@rr2r2=s#( %"%""r r2c<a]tRt^PtoRtRtRtRtRtRt Vt R#)PosixReactorBaseTestsz Tests for L{PosixReactorBase}. cVPVP\4VPVPVP4VPVPVP 4R#r4)assertIsInstancewakerrassertIn_internalReadersr5rr s&&r _checkWaker!PosixReactorBaseTests._checkWakerUsF gmmV4 gmmW%=%=> gmmW%5%56r c <\4pVPV4R#)zg When L{PosixReactorBase} is instantiated, it creates a waker and adds it to its internal readers set. N)r2rXrWs& rtest_wakerIsInternalReader0PosixReactorBaseTests.test_wakerIsInternalReaderZs !" !r c d\4p\4pVPPV4VP!V4VP !VP VP4VPV4VPW!P4VPW!P 4R#)zs Any L{IReadDescriptor}s in L{PosixReactorBase._internalReaders} are left alone by L{PosixReactorBase._removeAll}. N) r2objectrVaddr? _removeAllr5r6rXrU)rr extras& r"test_removeAllSkipsInternalReaders8PosixReactorBaseTests.test_removeAllSkipsInternalReadersbs !"  $$U+% 7++W-=-=> ! e556 e--.r c |\4p\4p\4pVP!V4VP!V4VP!VP VP 4pVP\V4W#04VPW!P 4VPW1P 4R#)zn L{PosixReactorBase._removeAll} returns a list of removed L{IReadDescriptor} and L{IWriteDescriptor} objects. N) r2r^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.rOs@rrQrQPs#7 " / 3 3r rQcLa]tRt^toRt]!]]4'gRtRt Rt Vt R#) TCPPortTestsz) Tests for L{twisted.internet.tcp.Port}. zNon-posixbase reactorc \R\44pRVnRVnVP VP 4\ 4#)zk L{Port.stopListening} returns a L{Deferred} which errbacks if L{Port.connectionLost} raises an exception. i90Tc^^,#)r')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 rskiprxr-r.rOs@rrkrks+ g/ 0 0&KKr rkc`a]tRt^toRtRtV3RlRltV3RlRltRtRt R t R t Vt R #) 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^\P!V4\4Vn^dVnR#)dN)rr7riterationTimeoutnowr8s&rr7TimeoutReportReactor.__init__s!!!$' ( r c$<V^8dQhRS[RR/#r>returnNr)formatr0s"r __annotate__!TimeoutReportReactor.__annotate__s   D r c R#)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 c$<V^8dQhRS[RR/#rr)rr0s"rrrs  ? t r c R#)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 c VP#)z` Override the real clock with a deterministic one that can be easily controlled in a unit test. )rr8s&rsecondsTimeoutReportReactor.secondss xxr cZVPpVeRVnVPV4R#R#r4)rcallback)rtimeoutds&& r doIteration TimeoutReportReactor.doIterations+  ! ! =$(D ! JJw  r )rrN) r(r)r*r+r,r7r?rCrrrr-r.rOs@rr}r}s7        r r}cTa]tRt^toRtRtRtRtRtRt Rt Rt R t R t VtR #) IterationTimeoutTestsz Tests for the timeout argument L{PosixReactorBase.run} calls L{PosixReactorBase.doIteration} with in the presence of various delayed calls. ca.pSPPVP4SPPV3Rl4SP!4V^,#)c&<SP!4#r4)stop)ignoredr s&rrp>IterationTimeoutTests._checkIterationTimeout..s W\\^r )r addCallbackappendrunrr rs&f r_checkIterationTimeout,IterationTimeoutTests._checkIterationTimeoutsH  ,,W^^<  ,,-KL qzr c ^\4pVPV4pVPV4R#)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 \4pVP!^dR4VPV4pVPV^d4R#)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. cR#r4r'r'r rrp8IterationTimeoutTests.test_delayedCall..tr Nr} callLaterrr#rs& rtest_delayedCall&IterationTimeoutTests.test_delayedCalls< '(#|,--g6 #&r c \4pVP!^dR4V;P^, unVPV4pVP V^K4R#)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. cR#r4r'r'r rrp7IterationTimeoutTests.test_timePasses..rr N)r}rrrr#rs& rtest_timePasses%IterationTimeoutTests.test_timePassessJ '(#|, r --g6 "%r c \4pVP!^2R4VP!^ R4VP!^dR4VPV4pVPV^ 4R#)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. cR#r4r'r'r rrpAIterationTimeoutTests.test_multipleDelayedCalls..dr cR#r4r'r'r rrprrr cR#r4r'r'r rrprrr Nrrs& rtest_multipleDelayedCalls/IterationTimeoutTests.test_multipleDelayedCallss\ '("l+"l+#|,--g6 "%r c \4pVP!^2R4pV;P^, unVP^4VP V4pVP V^4R#)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. cR#r4r'r'r rrp=IterationTimeoutTests.test_resetDelayedCall..Tr N)r}rrresetrr#rr callrs& rtest_resetDelayedCall+IterationTimeoutTests.test_resetDelayedCallsW '(  \2 r  2--g6 "%r c \4pVP!^2R4pV;P^ , unVP^4VP V4pVP V^<4R#)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. cR#r4r'r'r rrp=IterationTimeoutTests.test_delayDelayedCall..rr N)r}rrdelayrr#rs& rtest_delayDelayedCall+IterationTimeoutTests.test_delayDelayedCallsW'(  \2 r  2--g6 "%r c \4pVP!^2R4pVP4VPV4pVP V4R#)zX If the only delayed call is canceled, L{None} is the timeout passed to C{doIteration}. cR#r4r'r'r rrp>IterationTimeoutTests.test_cancelDelayedCall..rr N)r}rcancelrrrs& rtest_cancelDelayedCall,IterationTimeoutTests.test_cancelDelayedCallsE '(  \2 --g6 '"r r'N)r(r)r*r+r,rrrrrrrrr-r.rOs@rrrs7 # ' & & & & # #r rc<a]tRtRtoRt]e]tRtRtRt Vt R#)ConnectedDatagramPortTestsi"z' Test connected datagram UNIX sockets. Nc aV3Rlp\P!R\44pWnVP R4R#)zw L{ConnectedDatagramPort} does not call the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. c*<SPR4R#)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)rrrwsf r-test_connectionFailedDoesntCallLoseConnectionHConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection*s3  Q))$ >, i(r c aRSnV3Rlp\P!R\44pWnVP R4SP SP4R#)z L{ConnectedDatagramPort} calls L{ConnectedDatagramPort.stopListening} instead of the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. Fc<RSnR#)z Dummy C{stopListening} method. TNcalledr8srruYConnectedDatagramPortTests.test_connectionFailedCallsStopListening..stopListeningCs DKr Nr)rr rr rur assertTrue)rrurwsf r'test_connectionFailedCallsStopListeningBConnectedDatagramPortTests.test_connectionFailedCallsStopListening;sK    ))$ >* i(  $r r) r(r)r*r+r, skipSocketsr{rrr-r.rOs@rrr"s&)"%%r rc&a]tRtRtoRtRtVtR#) WakerTestsiOc \4pVP4pVP\V4^V4VP R4VP4pVP\V4^V4R#)z8 No warnings are generated when constructing the waker. N)rrr#r$rs)rrTr%s& r test_noWakerConstructionWarnings+WakerTests.test_noWakerConstructionWarningsPsc%%' X84 T"%%' X84r r'N)r(r)r*r+rr-r.rOs@rrrOs 5 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 rr2rQrkr}rrrr'r rrs +7?3++ >%2%%XD"%"&-32-3`K)K&* +* Z_#2_#D*%!7*%Z 5' 5w >=K>s B"" B.-B.