+ j9Rt^RIt^RIHt^RIHt^RIHt^RIH t ^RIH t ^RI H t ^RI HtHtHt^R IHt^R IHt^R IHtHtHt^R IHt^R IHt^RIHtHt^RI t!]!t ] !R4t#] !]]4!RR44t$!RR]4t%Rt&!RR4t'!RR]']4t(!RR]']4t)!RR]4t*]!] '*R4!RR]44t+R# ]"dRt Li;i) z% Tests for L{twisted.internet.base}. N)Queue)Callable)skipIf) implementer) ParamSpec) FirstOneWins) DelayedCall ReactorBaseThreadedResolver)Deferred)DNSLookupError)IReactorThreads IReactorTimeIResolverSimple)Clock) ThreadPool)SkipTestTestCase_Pcxa]tRt^$toRtRtV3RlRltRtRtRt V3RlR lt V3R lR lt R t R t VtR#) FakeReactorz` A fake reactor implementation which just supports enough reactor APIs for L{ThreadedResolver}. ca\4SnSPPSn\4SnSPP 4V3RlSn\4SnR#)c<SP#N) _threadpoolselfsA/usr/lib/python3/dist-packages/twisted/internet/test/test_base.py&FakeReactor.__init__..1s T%5%5N) r_clock callLaterrrstart getThreadPoolr _threadCallsrsfr__init__FakeReactor.__init__+sKg ..%<  5!Gr cn<V^8dQhRS[S[S[3,RS[PRS[PRR/#callableargskwargsreturnNrrobjectr,r-)format __classdict__s"r __annotate__FakeReactor.__annotate__5s>88 V,857WW8HJ 8 8r c@VPPWV34R#r)r%putrr+r,r-s&&*,rcallFromThreadFakeReactor.callFromThread5s xv67r cPVPP4wrpV!V/VBR#r)r%get)rfr,r-s& r_runThreadCallsFakeReactor._runThreadCalls:s'++//1 46r c:VPP4R#r)rstoprs&r_stopFakeReactor._stop>s r cR#rrs&rgetDelayedCallsFakeReactor.getDelayedCallsA r c <V^8dQhRS[/#)r*r.)float)r1r2s"rr3r4Es   r cR#rrDrs&rsecondsFakeReactor.secondsErGr cn<V^8dQhRS[S[S[3,RS[PRS[PRR/#r)r/)r1r2s"rr3r4Is>   V, 57WW HJ   r cR#rrDr7s&&*,r callInThreadFakeReactor.callInThreadIs r cR#rrD)rsizes&&rsuggestThreadPoolSize!FakeReactor.suggestThreadPoolSizeOrGr )r!r%rr"r$N)__name__ __module__ __qualname____firstlineno____doc__r&r8r=rArErKrOrS__static_attributes____classdictcell__r2s@rrr$sF $88         r rc<a]tRt^TtoRtRtRtRtRtRt Vt R#)ThreadedResolverTestsz Tests for L{ThreadedResolver}. c aa RoRp^p\4pVPVP4.o .pVV 3RlpVP\RV4\ V4pVP W34pVPVP4VP4VPS V.4VPVS.4VPPV^,4VPVPP.4R#)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.comc*<SPV4S#r)append)nameiplookedUps&rfakeGetHostByName=ThreadedResolverTests.test_success..fakeGetHostByNameis OOD !Ir gethostbynameN)r addCleanuprApatchsocketr getHostByName addCallbackrar= assertEqualr!advancecalls) rrbtimeoutreactor resolvedToreresolverdrcrds & @@r test_success"ThreadedResolverTests.test_successYs $-  &   6?,=>#G,  " "4 4 j''(! D6* bT* w{+ --r2r c ^p\4pVPVP4RpVP\RV4.p\ V4pVP RV34pVPV\4VPVP4VP4VP\V4^4VPPV^,4VPVPP .4R#)z L{ThreadedResolver.getHostByName} returns a L{Deferred} which fires a L{Failure} if the call to L{socket.gethostbyname} raises an exception. c\R4h)zENOBUFS (this is a funny joke))OSError)rbs&rre=ThreadedResolverTests.test_failure..fakeGetHostByNames:; ;r rg some.nameN)rrhrArirjr rk assertFailurer rlrar=rmlenr!rnro)rrprqre failedWithrsrts& r test_failure"ThreadedResolverTests.test_failure|s -  & < 6?,=> #G,  " "; ; 1n- j''(! Z!, w{+ --r2r c Na^ p\4pVPVP4\4oV3RlpVP \ RV4.p\ V4pVPRV34pVPV\4VPVP4VPPV^, 4VPV.4VPP^4VP\V4^4SP!\#R44R#)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$<SP4hr)r;)rbresults&rre=ThreadedResolverTests.test_timeout..fakeGetHostByNames**, r rgr{zThe I/O was errorfulN)rrhrArrirjr rkr|r rlrar!rnrmr}r6IOError)rrprqrer~rsrtrs& @r test_timeout"ThreadedResolverTests.test_timeouts -  &  6?,=> #G,  " "; ; 1n- j''(w{+ R(q! Z!,  7123r c ~a.o\\4!V3RlR44p!RR\4pV!4pV!4pVPV4\ \ 44pVP PVR4VP PVR4VP PVR4VP PVR4VP PVR4VP\S4^4VP\\\S44\.^,4VPRS^,4VPRS^,4VPR S^,4VPR S^,4VPRS^,4R #) zU L{ThreadedResolver.getHostByName} is passed L{str}, encoded using IDNA if required. c2<a]tRt^toRV3RlltRtVtR#)AThreadedResolverTests.test_resolverGivenStr..FakeResolverc:<SPV4\4#r)rar )rrbtimeoutsros&&&rrkOThreadedResolverTests.test_resolverGivenStr..FakeResolver.getHostByNames T"z!r rDN)rD)rUrVrWrXrkrZr[)r2ros@r FakeResolverrs " "r rc&a]tRt^toRtRtVtR#)FThreadedResolverTests.test_resolverGivenStr..JustEnoughReactorcR#rrDrs&r installWakerSThreadedResolverTests.test_resolverGivenStr..JustEnoughReactor.installWakersr rDN)rUrVrWrXrrZr[r\s@rJustEnoughReactorrs  r rzexample.exampleuvääntynyt.exampleu рф.examplezxn----7sbb4ac0ad0be6cf.xn--p1aizxn--vntynyt-5waa.examplezxn--p1ai.exampleN)rrr installResolverrr nameResolverresolveHostNamermr}listmaptypestr)rrrfakerqrecros& @rtest_resolverGivenStr+ThreadedResolverTests.test_resolverGivenStrso  _ % " " & "    ~#%%8:&,,S2CD,,S2CD,,S2KL,,S2HI,,S2ST UQ' c$./#; *E!H5 *E!H5 3U1X> +U1X6 :E!HEr rDN) rUrVrWrXrYrurrrrZr[r\s@rr^r^Ts'!3F3:4B!F!Fr r^cR#)z0 Function used by L{DelayedCallTests.test_str}. NrDrDr rnothingrr c`a]tRt^toRtRtRtRtRtRt Rt Rt R t R t R tR tVtR #)DelayedCallMixin L{DelayedCall} c  *Rp\VRR/W"R4#)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. cR#rrD)calls&rnoop0DelayedCallMixin._getDelayedCallAt..noops r cR#rrDrDr rr4DelayedCallMixin._getDelayedCallAt..sr NrD)r)rtimers&& r_getDelayedCallAt"DelayedCallMixin._getDelayedCallAts 4r2t4HHr c ^VP^4VnVP^4VnR#)zJ Create two L{DelayedCall} instanced scheduled to run at different times. N)rzerooners&rsetUpDelayedCallMixin.setUps( **1- ))!,r c  \^ \RR^/RRR4pVP\V4R\ V43,4R#) 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. ANcR#g?rDrDr rr+DelayedCallMixin.test_str..#r z?)rrrmridrdcs& rtest_strDelayedCallMixin.test_strsD WdS!HdD+ N  G M"vi  r c  ~\^ \RR^ /RRR4pVP\V4\ V44R#)zy The string representation of a L{DelayedCall} instance, as returned by {repr}, is identical to that returned by L{str}. rNcR#)g?rDrDr rr,DelayedCallMixin.test_repr..rr ))rrrmrreprrs& r test_reprDelayedCallMixin.test_repr s6 WdS!HdD+ N R$r(+r c VPVPr!VPW84VPW!84VPW84VPW"84R#)zz 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_ltDelayedCallMixin.test_ltsQ IItxxc  # $ % #r c VPVPr!VPW8*4VPW!8*4VPW8*4VPW"8*4R#)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_leDelayedCallMixin.test_lesM IItxxc  $ %  %  #r c VPVPr!VPW!84VPW84VPW84VPW"84R#)zy 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_gtDelayedCallMixin.test_gt*sQ IItxxc  # $ % #r c VPVPr!VPW!84VPW84VPW84VPW"84R#)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_geDelayedCallMixin.test_ge5sM IItxxc  $ %  %  #r c VPVPVP8H4VPVPVP8H4VPVPVP8H4R#)z4 A L{DelayedCall} instance is only equal to itself. N)rrrrrs&rtest_eqDelayedCallMixin.test_eqAsQ dhh./  TYY./ DHH,-r c VPVPVP8g4VPVPVP8g4VPVPVP8g4R#)z= A L{DelayedCall} instance is not equal to any other object. N)rrrrrs&rtest_neDelayedCallMixin.test_neKsS  TXX-. dii/0 TXX-.r )rrN)rUrVrWrXrYrrrrrrrrrrrZr[r\s@rrrsB I-  , $ $ $ $.//r rc6a]tRtRtoRtRtRtRtRtVt R#)DelayedCallNoDebugTestsiVrc ^VP\RR4\PV4R#)z Turn debug off. debugFNrirrrrs&rrDelayedCallNoDebugTests.setUp[s" ;/t$r c  \^ \RR^/RRR4pRP\V44pVP \ V4V4R#)rrNcR#rrDrDr rr2DelayedCallNoDebugTests.test_str..hrr zAr)rrr1rrmr)rrexpecteds& rr DelayedCallNoDebugTests.test_strbsK WdS!HdD+ N %vbf~  R(+r c  \^RR/\\R4p^VnVPR\ V44R#)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. cR#rrDrDr rr.vDr c^#r*rDrDr rrrvAr traceback at creationNrD)rrr assertNotInrrs& rtest_switchToDebug*DelayedCallNoDebugTests.test_switchToDebugos6L"b'7I N 0$r(;r rDN) rUrVrWrXrYrrrrZr[r\s@rrrVs% , < .rr z\.rr c^#rrDrDr rrrrr rNrD)rrrassertInrrs& rtest_switchFromDebug*DelayedCallDebugTests.test_switchFromDebugs4L"b'7I N -tBx8r rDN) rUrVrWrXrYrrrrZr[r\s@rrr{s% 2 9 9r rc*a]tRtRtoRtRtRtVtR#)TestSpySignalCapturingReactorizU Subclass of ReactorBase to capture signals delivered to the reactor for inspection. c R#)z Required method, unused. NrDrs&rr*TestSpySignalCapturingReactor.installWakerrr rDN)rUrVrWrXrYrrZr[r\s@rrrs   r rzsignal module not availablec<a]tRtRtoRtRtRtRtRtRt Vt R#) ReactorBaseSignalTestsiz= Tests to exercise ReactorBase's signal exit reporting path. c R\4pVPRVP4R#)z9 The default value of the _exitSignal attribute is None. N)rassertIs _exitSignalrrqs& rtest_exitSignalDefaultsToNone4ReactorBaseSignalTests.test_exitSignalDefaultsToNones 01 dG//0r c \4pVP\PR4VP \PVP 4R#)zV ReactorBase's SIGINT handler saves the value of SIGINT to the _exitSignal attribute. N)rsigIntsignalSIGINT assertEqualsrrs& rtest_captureSIGINT)ReactorBaseSignalTests.test_captureSIGINTs8 01v}}d+ &--)<)<=r c \4pVP\PR4VP \PVP 4R#)zX ReactorBase's SIGTERM handler saves the value of SIGTERM to the _exitSignal attribute. N)rsigTermrSIGTERMrrrs& rtest_captureSIGTERM*ReactorBaseSignalTests.test_captureSIGTERMs8 01- &..'*=*=>r c \\R4'g \R4h\4pVP \P R4VP \P VP4R#)zZ ReactorBase's SIGBREAK handler saves the value of SIGBREAK to the _exitSignal attribute. SIGBREAKz$signal module does not have SIGBREAKN)hasattrrrrsigBreakr rrrs& rtest_captureSIGBREAK+ReactorBaseSignalTests.test_captureSIGBREAKsS vz**AB B/1$/ &//7+>+>?r rDN) rUrVrWrXrYrrrr#rZr[r\s@rr r s%1>? @ @r r ),rYrjqueuertypingrunittestrzope.interfacerrtwisted.internet._resolverrtwisted.internet.baserr r twisted.internet.deferr twisted.internet.errorr twisted.internet.interfacesr rrtwisted.internet.taskrtwisted.python.threadpoolrtwisted.trial.unittestrrr_signal ImportErrorrrr^rrrrrr rDr rr3s&3LL+1VV'05Ft_ \?+, , ,, ^GFHGFT o/o/d"<."