Yf9dZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZmZmZdd lmZdd lmZdd lmZmZmZdd lmZddlmZddlmZm Z  ddl!Z"e"Z!n #e#$rdZ!YnwxYwe dZ$e eeGddZ%Gdde Z&dZ'GddZ(Gdde(e Z)Gdde(e Z*GddeZ+ee! dGdd e Z,dS)!z% Tests for L{twisted.internet.base}. N)Queue)Callable)skipIf) implementer) ParamSpec) FirstOneWins) DelayedCall ReactorBaseThreadedResolver)Deferred)DNSLookupError)IReactorThreads IReactorTimeIResolverSimple)Clock) ThreadPool)SkipTestTestCase_PceZdZdZdZdeeefdejdej ddfdZ d Z d Z d Z defd Zdeeefdejdej ddfd ZdZdS) FakeReactorzl A fake reactor implementation which just supports enough reactor APIs for L{ThreadedResolver}. ct_jj_t_jfd_t_dS)NcjSN) _threadpoolselfsQ/var/www/html/env/lib/python3.11/site-packages/twisted/internet/test/test_base.pyz&FakeReactor.__init__..1s T%5) r_clock callLaterrrstart getThreadPoolr _threadCallsrs`r__init__zFakeReactor.__init__+s^gg .%<<    5555!GGr callableargskwargsreturnNc@|j|||fdSr)r%putrr'r(r)s rcallFromThreadzFakeReactor.callFromThread5s( xv677777r cP|j\}}}||i|dSr)r%get)rfr(r)s r_runThreadCallszFakeReactor._runThreadCalls:s7+//114 46r c8|jdSr)rstoprs r_stopzFakeReactor._stop>s r cdSrrs rgetDelayedCallszFakeReactor.getDelayedCallsA r cdSrr7rs rsecondszFakeReactor.secondsEr9r cdSrr7r-s r callInThreadzFakeReactor.callInThreadIs  r cdSrr7)rsizes rsuggestThreadPoolSizez!FakeReactor.suggestThreadPoolSizeOr9r )__name__ __module__ __qualname____doc__r&rrobjectr(r)r.r2r5r8floatr;r=r@r7r rrr$s $$$8 V,857W8HJ 8 8888              V, 57W HJ           r rc*eZdZdZdZdZdZdZdS)ThreadedResolverTestsz( Tests for L{ThreadedResolver}. c0 dd}d}t}||jg g} fd}|td|t |}|||f}||j| | |g| |g|j |dz| |j j gdS)z L{ThreadedResolver.getHostByName} returns a L{Deferred} which fires with the value returned by the call to L{socket.gethostbyname} in the threadpool of the reactor passed to L{ThreadedResolver.__init__}. z 10.0.0.17zfoo.bar.example.comc2|Sr)append)nameiplookedUps rfakeGetHostByNamez=ThreadedResolverTests.test_success..fakeGetHostByNameis OOD ! ! !Ir gethostbynameN)r addCleanupr5patchsocketr getHostByName addCallbackrLr2 assertEqualr!advancecalls) rrMtimeoutreactor resolvedTorPresolverdrNrOs @@r test_successz"ThreadedResolverTests.test_successYs+ $--  &&&        6?,=>>>#G,,  " "4' 4 4 j'(((!!! D6*** bT*** w{+++ -r22222r c:d}t}||jd}|td|g}t |}|d|f}||t| |j | | t|d|j|dz| |jjgdS)z L{ThreadedResolver.getHostByName} returns a L{Deferred} which fires a L{Failure} if the call to L{socket.gethostbyname} raises an exception. rJc td)NzENOBUFS (this is a funny joke))OSError)rMs rrPz=ThreadedResolverTests.test_failure..fakeGetHostByNames:;; ;r rQ some.namerRN)rrSr5rTrUr rV assertFailurer rWrLr2rXlenr!rYrZ)rr[r\rP failedWithr^r_s r test_failurez"ThreadedResolverTests.test_failure|s  --  &&& < < < 6?,=>>> #G,,  " "; ; ; 1n--- j'(((!!! Z!,,, w{+++ -r22222r cd}t}||jtfd}|t d|g}t |}|d|f}||t| |j |j |dz ||g|j d|t|dt#ddS)z If L{socket.gethostbyname} does not complete before the specified timeout elapsed, the L{Deferred} returned by L{ThreadedResolver.getHostByName} fails with L{DNSLookupError}. c,r)r0)rMresults rrPz=ThreadedResolverTests.test_timeout..fakeGetHostByNames**,, r rQrdrRzThe I/O was errorfulN)rrSr5rrTrUr rVrer rWrLr!rYrXrfr,IOError)rr[r\rPrgr^r_rls @r test_timeoutz"ThreadedResolverTests.test_timeouts; --  &&&      6?,=>>> #G,,  " "; ; ; 1n--- j'(((w{+++ R(((q!!! Z!,,,  712233333r cgttGfdd}Gddt}|}|}||t t }|j|d|j|d|j|d|j|d|j|d|td |ttttgd z|dd |dd |d d |dd|dddS)zm L{ThreadedResolver.getHostByName} is passed L{str}, encoded using IDNA if required. ceZdZdfd ZdS)AThreadedResolverTests.test_resolverGivenStr..FakeResolverr7cJ|tSr)rLr )rrMtimeoutsrZs rrVzOThreadedResolverTests.test_resolverGivenStr..FakeResolver.getHostByNames T"""zz!r N)r7)rArBrCrV)rZsr FakeResolverrqs3 " " " " " " " "r rtceZdZdZdS)FThreadedResolverTests.test_resolverGivenStr..JustEnoughReactorcdSrr7rs r installWakerzSThreadedResolverTests.test_resolverGivenStr..JustEnoughReactor.installWakersr N)rArBrCrxr7r rJustEnoughReactorrvs#     r ryzexample.exampleuvääntynyt.exampleu рф.examplezxn----7sbb4ac0ad0be6cf.xn--p1airrRzxn--vntynyt-5waa.examplezxn--p1ai.exampleN)rrr installResolverrr nameResolverresolveHostNamerXrflistmaptypestr)rrtryfaker\recrZs @rtest_resolverGivenStrz+ThreadedResolverTests.test_resolverGivenStrs  _ % % " " " " " " " " " & % "          |~~##%%%%%8::&&,,S2CDDD,,S2CDDD,,S2KLLL,,S2HIII,,S2STTT UQ''' c$..//#;;; *E!H555 *E!H555 3U1X>>> +U1X666 :E!HEEEEEr N)rArBrCrDr`rhrnrr7r rrHrHTsa!3!3!3F333:444B!F!F!F!F!Fr rHcdS)z8 Function used by L{DelayedCallTests.test_str}. Nr7r7r rnothingrr cNeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d S) DelayedCallMixin L{DelayedCall} c 4d}t|ddi||dS)z Get a L{DelayedCall} instance at a given C{time}. @param time: The absolute time at which the returned L{DelayedCall} will be scheduled. cdSrr7)calls rnoopz0DelayedCallMixin._getDelayedCallAt..noops Dr cdSrr7r7r rrz4DelayedCallMixin._getDelayedCallAt..sr r7N)r )rtimers r_getDelayedCallAtz"DelayedCallMixin._getDelayedCallAts/   4r2tT4HHHr cn|d|_|d|_dS)zb Create two L{DelayedCall} instanced scheduled to run at different times. rrRN)rzerooners rsetUpzDelayedCallMixin.setUps2 **1-- ))!,,r c tdtdddiddd}|t|dt |fzdS) The string representation of a L{DelayedCall} instance, as returned by L{str}, includes the unsigned id of the instance, as well as its state, the function to be called, and the function arguments. r|ArzNcdSNg?r7r7r rrz+DelayedCallMixin.test_str..#r z?)r rrXridrdcs rtest_strzDelayedCallMixin.test_strsa WdS!HdD++ N N  GG M"vvi      r c tdtdddiddd}|t|t |dS)z The string representation of a L{DelayedCall} instance, as returned by {repr}, is identical to that returned by L{str}. )r NcdS)Ng?r7r7r rrz,DelayedCallMixin.test_repr..rr )r rrXrreprrs r test_reprzDelayedCallMixin.test_repr sK WdS!HdD++ N N R$r((+++++r c|j|j}}|||k|||k|||k|||kdS)z For two instances of L{DelayedCall} C{a} and C{b}, C{a < b} is true if and only if C{a} is scheduled to run before C{b}. Nrr assertTrue assertFalserrrs rtest_ltzDelayedCallMixin.test_ltsu Itxc s ### t$$$ %%% s#####r c|j|j}}|||k|||k|||k|||kdS)z For two instances of L{DelayedCall} C{a} and C{b}, C{a <= b} is true if and only if C{a} is scheduled to run before C{b} or at the same time as C{b}. Nrrs rtest_lezDelayedCallMixin.test_lesq Itxc  $$$ %%%  %%% s #####r c|j|j}}|||k|||k|||k|||kdS)z For two instances of L{DelayedCall} C{a} and C{b}, C{a > b} is true if and only if C{a} is scheduled to run after C{b}. Nrrs rtest_gtzDelayedCallMixin.test_gt*su Itxc d ### $$$ %%% s#####r c|j|j}}|||k|||k|||k|||kdS)z For two instances of L{DelayedCall} C{a} and C{b}, C{a > b} is true if and only if C{a} is scheduled to run after C{b} or at the same time as C{b}. Nrrs rtest_gezDelayedCallMixin.test_ge5sq Itxc t $$$ %%%  %%% s #####r c||j|jk||j|jk||j|jkdS)zD A L{DelayedCall} instance is only equal to itself. N)rrrrrs rtest_eqzDelayedCallMixin.test_eqAs] dh.///  TY./// DH,-----r c||j|jk||j|jk||j|jkdS)zM A L{DelayedCall} instance is not equal to any other object. N)rrrrrs rtest_nezDelayedCallMixin.test_neKs_  TX-... di/000 TX-.....r N)rArBrCrDrrrrrrrrrrr7r rrrs I I I---    ,,, $ $ $ $ $ $ $ $ $ $ $ $.../////r rc$eZdZdZdZdZdZdS)DelayedCallNoDebugTestsrcr|tddt|dS)z! Turn debug off. debugFNrTr rrrs rrzDelayedCallNoDebugTests.setUp[s4 ;///t$$$$$r c tdtdddiddd}dt|}|t ||dS)rrrrrzNcdSrr7r7r rrz2DelayedCallNoDebugTests.test_str..hrr zA)r rformatrrXr)rrexpecteds rrz DelayedCallNoDebugTests.test_strbsb WdS!HdD++ N N %vbff~~  R(+++++r c tdddittd}d|_|dt |dS)z If L{DelayedCall.debug} changes from C{0} to C{1} between L{DelayeCall.__init__} and L{DelayedCall.__repr__} then L{DelayedCall.__repr__} returns a string that does not include the creator stack. r|cdSrr7r7r rrz.vDr r7cdSNr{r7r7r rrz.vAr rRtraceback at creationN)r rr assertNotInrrs rtest_switchToDebugz*DelayedCallNoDebugTests.test_switchToDebugosKLL"b'7II N N 0$r((;;;;;r N)rArBrCrDrrrr7r rrrVsK%%% , , , < < < < .rr z\.rr r7cdSrr7r7r rrz.rr rrN)r rrassertInrrs rtest_switchFromDebugz*DelayedCallDebugTests.test_switchFromDebugsILL"b'7II N N -tBxx88888r N)rArBrCrDrrrr7r rrr{sK%%% 2 2 2 9 9 9 9 9r rceZdZdZdZdS)TestSpySignalCapturingReactorza Subclass of ReactorBase to capture signals delivered to the reactor for inspection. cdS)z* Required method, unused. Nr7rs rrxz*TestSpySignalCapturingReactor.installWakerrr N)rArBrCrDrxr7r rrrs-      r rzsignal module not availablec*eZdZdZdZdZdZdZdS)ReactorBaseSignalTestszE Tests to exercise ReactorBase's signal exit reporting path. cXt}|d|jdS)zI The default value of the _exitSignal attribute is None. N)rassertIs _exitSignalrr\s rtest_exitSignalDefaultsToNonez4ReactorBaseSignalTests.test_exitSignalDefaultsToNones,011 dG/00000r ct}|tjd|tj|jdS)zn ReactorBase's SIGINT handler saves the value of SIGINT to the _exitSignal attribute. N)rsigIntsignalSIGINT assertEqualsrrs rtest_captureSIGINTz)ReactorBaseSignalTests.test_captureSIGINTsF 011v}d+++ &-)<=====r ct}|tjd|tj|jdS)zp ReactorBase's SIGTERM handler saves the value of SIGTERM to the _exitSignal attribute. N)rsigTermrSIGTERMrrrs rtest_captureSIGTERMz*ReactorBaseSignalTests.test_captureSIGTERMsF 011--- &.'*=>>>>>r cttdstdt}|tjd|tj|jdS)zr ReactorBase's SIGBREAK handler saves the value of SIGBREAK to the _exitSignal attribute. SIGBREAKz$signal module does not have SIGBREAKN)hasattrrrrsigBreakrrrrs rtest_captureSIGBREAKz+ReactorBaseSignalTests.test_captureSIGBREAKsj vz** CABB B/11$/// &/7+>?????r N)rArBrCrDrrrrr7r rrrs_111>>>??? @ @ @ @ @r r)-rDrUqueuertypingrunittestrzope.interfacertyping_extensionsrtwisted.internet._resolverrtwisted.internet.baser r r twisted.internet.deferr twisted.internet.errorr twisted.internet.interfacesrrrtwisted.internet.taskrtwisted.python.threadpoolrtwisted.trial.unittestrrr_signal ImportErrorrrrHrrrrrrr7r rrs &&&&&&''''''333333LLLLLLLLLL++++++111111VVVVVVVVVV''''''00000055555555FF FFF Yt__ \?++, , , , , , , ,+, ^GFGFGFGFGFHGFGFGFT o/o/o/o/o/o/o/o/d"<"<"<"<"<."<"<"