U 2ܟj=.@s.dZddlZddlmZddlmZddlmZmZddl m Z ddl m Z ddl mZdZzdd lmZdd lmZWnek rd ZYnXdd lmZdd lmZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZdS)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 socketsreactor)Portcs,eZdZdZfddZfddZZS)WarningCheckerTestCasezg A test case that will make sure that no warnings are left unchecked at the end of a test run. cs4ttjdddkr0tr0|dS)NCItrue) supersetUposenvirongetlowerr isWindows flushWarningsself __class__H/tmp/pip-unpacked-wheel-4b529toj/twisted/internet/test/test_posixbase.pyr s zWarningCheckerTestCase.setUpc s`dzt W5|}tjdddkr@tr@dS|t|dd|XdS)Nrrrrz'Warnings found at the end of the test: ) rrrrrrr assertEquallenrtearDown)rwarningsrrrr"+szWarningCheckerTestCase.tearDown)__name__ __module__ __qualname____doc__rr" __classcell__rrrrrs rc@s4eZdZddZddZddZddZd d Zd S) TrivialReactorcCsi|_i|_t|dSN)_readers_writersr__init__rrrrr->szTrivialReactor.__init__cCsd|j|<dSNTr+rreaderrrr addReaderCszTrivialReactor.addReadercCs |j|=dSr*r/r0rrr removeReaderFszTrivialReactor.removeReadercCsd|j|<dSr.r,rwriterrrr addWriterIszTrivialReactor.addWritercCs |j|=dSr*r4r5rrr removeWriterLszTrivialReactor.removeWriterN)r$r%r&r-r2r3r7r8rrrrr)=s r)c@s0eZdZdZddZddZddZdd Zd S) PosixReactorBaseTestsz( Tests for L{PosixReactorBase}. cCs2||jt||j|j||j|jdSr*)ZassertIsInstancewakerrassertIn_internalReadersr+rr rrr _checkWakerUsz!PosixReactorBaseTests._checkWakercCst}||dS)z When L{PosixReactorBase} is instantiated, it creates a waker and adds it to its internal readers set. N)r)r>r=rrrtest_wakerIsInternalReaderZsz0PosixReactorBaseTests.test_wakerIsInternalReadercCs\t}t}|j|||||j|j||| ||j| ||jdS)z Any L{IReadDescriptor}s in L{PosixReactorBase._internalReaders} are left alone by L{PosixReactorBase._removeAll}. N) r)objectr<addr2 _removeAllr+r,r>r;)rr extrarrr"test_removeAllSkipsInternalReadersbs   z8PosixReactorBaseTests.test_removeAllSkipsInternalReaderscCsjt}t}t}||||||j|j}|t|||h| ||j| ||jdS)z L{PosixReactorBase._removeAll} returns a list of removed L{IReadDescriptor} and L{IWriteDescriptor} objects. N) r)r@r2r7rBr+r,r setZ assertNotIn)rr r1r6removedrrr'test_removeAllReturnsRemovedDescriptorsps  z=PosixReactorBaseTests.test_removeAllReturnsRemovedDescriptorsN)r$r%r&r'r>r?rDrGrrrrr9Ps r9c@s&eZdZdZeeesdZddZdS) TCPPortTestsz1 Tests for L{twisted.internet.tcp.Port}. zNon-posixbase reactorcCs,tdt}d|_dd|_||tS)z L{Port.stopListening} returns a L{Deferred} which errbacks if L{Port.connectionLost} raises an exception. i90TcSsddS)Nrr)reasonrrrz8TCPPortTests.test_connectionLostFailed..)r r connectedconnectionLostZ assertFailure stopListeningZeroDivisionError)rportrrrtest_connectionLostFaileds  z&TCPPortTests.test_connectionLostFailedN) r$r%r&r' isinstancer rskiprRrrrrrHs rHc@sPeZdZdZddZeddddZedddd Zd d Zd d Z ddZ dS)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. cCst|t|_d|_dS)Nd)rr-riterationTimeoutnowrrrrr-s zTimeoutReportReactor.__init__N)r1returncCsdS)z Ignore the reader. This is necessary because the waker will be added. However, we won't actually monitor it for any events. Nrr0rrrr2szTimeoutReportReactor.addReadercCsdS)z# See L{addReader}. Nrr0rrrr3sz!TimeoutReportReactor.removeReadercCsgS)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. rrrrr removeAllszTimeoutReportReactor.removeAllcCs|jS)zx Override the real clock with a deterministic one that can be easily controlled in a unit test. )rXrrrrsecondsszTimeoutReportReactor.secondscCs"|j}|dk rd|_||dSr*)rWcallback)rtimeoutdrrr doIterationsz TimeoutReportReactor.doIteration) r$r%r&r'r-rr2r3rZr[r_rrrrrUsrUc@sPeZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ dS)IterationTimeoutTestsz Tests for the timeout argument L{PosixReactorBase.run} calls L{PosixReactorBase.doIteration} with in the presence of various delayed calls. cs6g}j|jjfdd|dS)NcsSr*)stop)Zignoredr rrrKrLz>IterationTimeoutTests._checkIterationTimeout..r)rWZ addCallbackappendrunrr r]rr r_checkIterationTimeouts z,IterationTimeoutTests._checkIterationTimeoutcCst}||}||dS)zl If there are no delayed calls, C{doIteration} is called with a timeout of L{None}. N)rUre assertIsNonerdrrr test_noCallss z"IterationTimeoutTests.test_noCallscCs0t}|ddd||}||ddS)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. rVcSsdSr*rrrrrrKrLz8IterationTimeoutTests.test_delayedCall..NrU callLaterrer rdrrrtest_delayedCalls z&IterationTimeoutTests.test_delayedCallcCs>t}|ddd|jd7_||}||ddS)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. rVcSsdSr*rrrrrrKrLz7IterationTimeoutTests.test_timePasses..KN)rUrirXrer rdrrrtest_timePassess  z%IterationTimeoutTests.test_timePassescCsPt}|ddd|ddd|ddd||}||ddS) 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. 2cSsdSr*rrrrrrKrLzAIterationTimeoutTests.test_multipleDelayedCalls.. cSsdSr*rrrrrrKrLrVcSsdSr*rrrrrrKrLNrhrdrrrtest_multipleDelayedCallss  z/IterationTimeoutTests.test_multipleDelayedCallscCsHt}|ddd}|jd7_|d||}||ddS)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. rncSsdSr*rrrrrrKrLz=IterationTimeoutTests.test_resetDelayedCall..rkN)rUrirXresetrer rr callr]rrrtest_resetDelayedCalls   z+IterationTimeoutTests.test_resetDelayedCallcCsHt}|ddd}|jd7_|d||}||ddS)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. rncSsdSr*rrrrrrKrLz=IterationTimeoutTests.test_delayDelayedCall..ro<N)rUrirXdelayrer rsrrrtest_delayDelayedCalls   z+IterationTimeoutTests.test_delayDelayedCallcCs6t}|ddd}|||}||dS)zp If the only delayed call is canceled, L{None} is the timeout passed to C{doIteration}. rncSsdSr*rrrrrrKrLz>IterationTimeoutTests.test_cancelDelayedCall..N)rUricancelrerfrsrrrtest_cancelDelayedCalls  z,IterationTimeoutTests.test_cancelDelayedCallN) r$r%r&r'rergrjrmrpruryr{rrrrr`s     r`c@s,eZdZdZedk reZddZddZdS)ConnectedDatagramPortTestsz/ Test connected datagram UNIX sockets. Ncs.fdd}tdt}||_|ddS)z L{ConnectedDatagramPort} does not call the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. csddS)z Dummy C{loseConnection} method. C{loseConnection} is deprecated and should not get called. z7loseConnection is deprecated and should not get called.N)ZfailrrrrloseConnection0sz`ConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection..loseConnectionNgoodbye)r ConnectedDatagramPortr r}connectionFailed)rr}rQrrr-test_connectionFailedDoesntCallLoseConnection*s zHConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnectioncs@d_fdd}tdt}||_|djdS)z L{ConnectedDatagramPort} calls L{ConnectedDatagramPort.stopListening} instead of the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. Fcs d_dS)z8 Dummy C{stopListening} method. TN)calledrrrrrOCszYConnectedDatagramPortTests.test_connectionFailedCallsStopListening..stopListeningNr~)rr rr rOr assertTrue)rrOrQrrr'test_connectionFailedCallsStopListening;s   zBConnectedDatagramPortTests.test_connectionFailedCallsStopListening)r$r%r&r' skipSocketsrTrrrrrrr|"s r|c@seZdZddZdS) WakerTestscCsHt}|}|t|d||d|}|t|d|dS)zH No warnings are generated when constructing the waker. rN)rrr r!rN)rr:r#rrr test_noWakerConstructionWarningsPs  z+WakerTests.test_noWakerConstructionWarningsN)r$r%r&rrrrrrOsr) r'rZtwisted.internet.deferrZtwisted.internet.interfacesrZtwisted.internet.posixbaserrZtwisted.internet.protocolrZtwisted.python.runtimerZtwisted.trial.unittestrrZtwisted.internetr Ztwisted.test.test_unixr ImportErrorr Ztwisted.internet.tcpr rr)r9rHrUr`r|rrrrrs.         "0-b-