U  W[@%ã@sþdZddlmZmZddlmZddlmZddlm Z m Z ddl m Z dZ zddlmZdd lmZWnek r€d Z YnXdd lmZdd lmZGd d„de ƒZGdd„deƒZGdd„deƒZGdd„de ƒZGdd„deƒZGdd„deƒZdS)z> Tests for L{twisted.internet.posixbase} and supporting code. é)ÚdivisionÚabsolute_import)ÚTestCase)ÚDeferred)ÚPosixReactorBaseÚ_Waker)Ú ServerFactoryN)Úunix)Ú ClientProtoz)Platform does not support AF_UNIX sockets)ÚPort©Úreactorc@s4eZdZdd„Zdd„Zdd„Zdd„Zd d „Zd S) ÚTrivialReactorcCsi|_i|_t |¡dS©N)Ú_readersÚ_writersrÚ__init__©Úself©rúF/usr/lib/python3/dist-packages/twisted/internet/test/test_posixbase.pyrszTrivialReactor.__init__cCsd|j|<dS©NT©r©rÚreaderrrrÚ addReader#szTrivialReactor.addReadercCs |j|=dSrrrrrrÚ removeReader'szTrivialReactor.removeReadercCsd|j|<dSr©r©rÚwriterrrrÚ addWriter+szTrivialReactor.addWritercCs |j|=dSrrrrrrÚ removeWriter/szTrivialReactor.removeWriterN)Ú__name__Ú __module__Ú __qualname__rrrr r!rrrrrs rc@s0eZdZdZdd„Zdd„Zdd„Zdd „Zd S) ÚPosixReactorBaseTestsz( Tests for L{PosixReactorBase}. cCs2| |jt¡| |j|j¡| |j|j¡dSr)ZassertIsInstanceZwakerrÚassertInÚ_internalReadersr©rr rrrÚ _checkWaker9sz!PosixReactorBaseTests._checkWakercCstƒ}| |¡dS)z When L{PosixReactorBase} is instantiated, it creates a waker and adds it to its internal readers set. N)rr)r(rrrÚtest_wakerIsInternalReader?sz0PosixReactorBaseTests.test_wakerIsInternalReadercCs\tƒ}tƒ}|j |¡| |¡| |j|j¡| |¡|  ||j¡|  ||j¡dS)z‹ Any L{IReadDescriptors} in L{PosixReactorBase._internalReaders} are left alone by L{PosixReactorBase._removeAll}. N) rÚobjectr'ÚaddrÚ _removeAllrrr)r&)rr ZextrarrrÚ"test_removeAllSkipsInternalReadersHs   z8PosixReactorBaseTests.test_removeAllSkipsInternalReaderscCsntƒ}tƒ}tƒ}| |¡| |¡| |j|j¡}| t|ƒt||gƒ¡|  ||j¡|  ||j¡dS)z† L{PosixReactorBase._removeAll} returns a list of removed L{IReadDescriptor} and L{IWriteDescriptor} objects. N) rr+rr r-rrÚ assertEqualÚsetZ assertNotIn)rr rrZremovedrrrÚ'test_removeAllReturnsRemovedDescriptorsWs  ÿz=PosixReactorBaseTests.test_removeAllReturnsRemovedDescriptorsN)r"r#r$Ú__doc__r)r*r.r1rrrrr%4s  r%c@s&eZdZdZeeeƒsdZdd„ZdS)Ú TCPPortTestsz1 Tests for L{twisted.internet.tcp.Port}. zNon-posixbase reactorcCs,tdtƒƒ}d|_dd„|_| | ¡t¡S)zƒ L{Port.stopListening} returns a L{Deferred} which errbacks if L{Port.connectionLost} raises an exception. i90TcSsddS)Nérr)ÚreasonrrrÚxóz8TCPPortTests.test_connectionLostFailed..)r rZ connectedZconnectionLostZ assertFailureÚ stopListeningÚZeroDivisionError)rÚportrrrÚtest_connectionLostFailedqs  z&TCPPortTests.test_connectionLostFailedN) r"r#r$r2Ú isinstancer rÚskipr;rrrrr3is r3c@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd S) Ú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)Néd)rrrÚiterationTimeoutÚnowrrrrrƒs zTimeoutReportReactor.__init__cCsdS)z— Ignore the reader. This is necessary because the waker will be added. However, we won't actually monitor it for any events. Nrrrrrr‰szTimeoutReportReactor.addReadercCsgS)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. )rArrrrÚseconds™szTimeoutReportReactor.secondscCs"|j}|dk rd|_| |¡dSr)r@Úcallback)rÚtimeoutÚdrrrÚ doIteration¡sz TimeoutReportReactor.doIterationN) r"r#r$r2rrrBrCrGrrrrr>}s  r>c@sPeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dS)ÚIterationTimeoutTestsz Tests for the timeout argument L{PosixReactorBase.run} calls L{PosixReactorBase.doIteration} with in the presence of various delayed calls. cs6g}ˆj |j¡ˆj ‡fdd„¡ˆ ¡|dS)Ncsˆ ¡Sr)Ústop)Zignoredr rrr6²r7z>IterationTimeoutTests._checkIterationTimeout..r)r@Z addCallbackÚappendÚrun©rr rErr rÚ_checkIterationTimeout¯s z,IterationTimeoutTests._checkIterationTimeoutcCstƒ}| |¡}| |¡dS)zl If there are no delayed calls, C{doIteration} is called with a timeout of L{None}. N)r>rMÚ assertIsNonerLrrrÚ test_noCalls·s z"IterationTimeoutTests.test_noCallscCs0tƒ}| ddd„¡| |¡}| |d¡dS)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. r?cSsdSrrrrrrr6Èr7z8IterationTimeoutTests.test_delayedCall..N©r>Ú callLaterrMr/rLrrrÚtest_delayedCallÁs z&IterationTimeoutTests.test_delayedCallcCs>tƒ}| ddd„¡|jd7_| |¡}| |d¡dS)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. r?cSsdSrrrrrrr6Ôr7z7IterationTimeoutTests.test_timePasses..ééKN)r>rQrArMr/rLrrrÚtest_timePassesÍs  z%IterationTimeoutTests.test_timePassescCsPtƒ}| ddd„¡| ddd„¡| ddd„¡| |¡}| |d¡dS) 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. é2cSsdSrrrrrrr6ár7zAIterationTimeoutTests.test_multipleDelayedCalls..é cSsdSrrrrrrr6âr7r?cSsdSrrrrrrr6ãr7NrPrLrrrÚtest_multipleDelayedCallsÚs  z/IterationTimeoutTests.test_multipleDelayedCallscCsHtƒ}| ddd„¡}|jd7_| d¡| |¡}| |d¡dS)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. rVcSsdSrrrrrrr6ïr7z=IterationTimeoutTests.test_resetDelayedCall..rSéN)r>rQrAÚresetrMr/©rr ÚcallrErrrÚtest_resetDelayedCallès   z+IterationTimeoutTests.test_resetDelayedCallcCsHtƒ}| ddd„¡}|jd7_| d¡| |¡}| |d¡dS)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. rVcSsdSrrrrrrr6þr7z=IterationTimeoutTests.test_delayDelayedCall..rWéé<N)r>rQrAZdelayrMr/r[rrrÚtest_delayDelayedCallös   z+IterationTimeoutTests.test_delayDelayedCallcCs6tƒ}| ddd„¡}| ¡| |¡}| |¡dS)zp If the only delayed call is canceled, L{None} is the timeout passed to C{doIteration}. rVcSsdSrrrrrrr6 r7z>IterationTimeoutTests.test_cancelDelayedCall..N)r>rQZcancelrMrNr[rrrÚtest_cancelDelayedCalls  z,IterationTimeoutTests.test_cancelDelayedCallN) r"r#r$r2rMrOrRrUrXr]r`rarrrrrH©s   rHc@s,eZdZdZedk reZdd„Zdd„ZdS)ÚConnectedDatagramPortTestsz/ Test connected datagram UNIX sockets. Ncs.‡fdd„}t dtƒ¡}||_| d¡dS)z L{ConnectedDatagramPort} does not call the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. csˆ d¡dS)z€ Dummy C{loseConnection} method. C{loseConnection} is deprecated and should not get called. z7loseConnection is deprecated and should not get called.N)ZfailrrrrÚloseConnectionsz`ConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection..loseConnectionNÚgoodbye)r ÚConnectedDatagramPortr rcÚconnectionFailed)rrcr:rrrÚ-test_connectionFailedDoesntCallLoseConnections zHConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnectioncs@dˆ_‡fdd„}t dtƒ¡}||_| d¡ˆ ˆj¡dS)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)Úcalledrrrrr83szYConnectedDatagramPortTests.test_connectionFailedCallsStopListening..stopListeningNrd)rhr rer r8rfZ assertTrue)rr8r:rrrÚ'test_connectionFailedCallsStopListening+s   zBConnectedDatagramPortTests.test_connectionFailedCallsStopListening)r"r#r$r2Ú skipSocketsr=rgrirrrrrbs rb)r2Z __future__rrZtwisted.trial.unittestrZtwisted.internet.deferrZtwisted.internet.posixbaserrZtwisted.internet.protocolrrjZtwisted.internetr Ztwisted.test.test_unixr Ú ImportErrorZtwisted.internet.tcpr r rr%r3r>rHrbrrrrÚs&       5,i