֛h9SrSSKrSSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r SS KJrJrJr SS KJr SS KJr SS KJrJrJr SS KJr SSKJr SSKJrJ r SSK!r"\"r!\ "S5r$\ "\\5"SS55r%"SS\ 5r&Sr'"SS5r("SS\(\ 5r)"SS\(\ 5r*"SS\5r+\"\!(+S5"SS \ 55r,g!\#a Sr!Nf=f)!z% Tests for L{twisted.internet.base}. N)Queue)Callable)skipIf) implementer) ParamSpec) FirstOneWins) DelayedCall ReactorBaseThreadedResolver)Deferred)DNSLookupError)IReactorThreads IReactorTimeIResolverSimple)Clock) ThreadPool)SkipTestTestCase_Pc\rSrSrSrSrS\\\4S\RS\RSS4S jr S r S r S rS\4S jrS\\\4S\RS\RSS4SjrSrSrg) FakeReactor$z` A fake reactor implementation which just supports enough reactor APIs for L{ThreadedResolver}. c^[5TlTRRTl[5TlTRR 5 U4SjTl[5Tlg)Nc>TR$N) _threadpoolselfscC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_base.py&FakeReactor.__init__..1s T%5%5) r_clock callLaterrrstart getThreadPoolr _threadCallsrs`r__init__FakeReactor.__init__+sKg ..%<  5!Gr"callableargskwargsreturnNc>URRXU45 gr)r'putrr*r+r,s rcallFromThreadFakeReactor.callFromThread5s xv67r"cNURR5upnU"U0UD6 gr)r'get)rfr+r,s r_runThreadCallsFakeReactor._runThreadCalls:s'++//1 46r"c8URR5 gr)rstoprs r_stopFakeReactor._stop>s r"cgrrs rgetDelayedCallsFakeReactor.getDelayedCallsA r"cgrr=rs rsecondsFakeReactor.secondsEr@r"cgrr=r0s r callInThreadFakeReactor.callInThreadIs r"cgrr=)rsizes rsuggestThreadPoolSize!FakeReactor.suggestThreadPoolSizeOr@r")r#r'rr$r&)__name__ __module__ __qualname____firstlineno____doc__r(rrobjectr+r,r1r6r:r>floatrBrErI__static_attributes__r=r"rrr$s $8 V,857WW8HJ 8 8       V, 57WW HJ    r"rc0\rSrSrSrSrSrSrSrSr g) ThreadedResolverTestsTz Tests for L{ThreadedResolver}. c^^ SmSnSn[5nURUR5 /m /nUU 4SjnUR[SU5 [ U5nUR X45nURUR5 UR5 URT U/5 URUT/5 URRUS-5 URURR/5 g)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*>TRU5 T$r)append)nameiplookedUps rfakeGetHostByName=ThreadedResolverTests.test_success..fakeGetHostByNameis OOD !Ir" gethostbynameN)r addCleanupr:patchsocketr getHostByName addCallbackrYr6 assertEqualr#advancecalls) rrZtimeoutreactor resolvedTor]resolverdr[r\s @@r test_success"ThreadedResolverTests.test_successYs $-  &   6?,=>#G,  " "4 4 j''(! D6* bT* w{+ --r2r"cSn[5nURUR5 SnUR[SU5 /n[ U5nUR SU45nURU[5 URUR5 UR5 UR[U5S5 URRUS-5 URURR /5 g)z L{ThreadedResolver.getHostByName} returns a L{Deferred} which fires a L{Failure} if the call to L{socket.gethostbyname} raises an exception. rWc[S5e)NzENOBUFS (this is a funny joke))OSError)rZs rr]=ThreadedResolverTests.test_failure..fakeGetHostByNames:; ;r"r_ some.namer`N)rrar:rbrcr rd assertFailurer rerYr6rflenr#rgrh)rrirjr] failedWithrlrms r test_failure"ThreadedResolverTests.test_failure|s -  & < 6?,=> #G,  " "; ; 1n- j''(! Z!, w{+ --r2r"cD^Sn[5nURUR5 [5mU4SjnUR [ SU5 /n[ U5nURSU45nURU[5 URUR5 URRUS- 5 URU/5 URRS5 UR[U5S5 TR![#S55 g)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$>TR5er)r4)rZresults rr]=ThreadedResolverTests.test_timeout..fakeGetHostByNames**, r"r_rtr`zThe I/O was errorfulN)rrar:rrbrcr rdrur rerYr#rgrfrvr/IOError)rrirjr]rwrlrmr}s @r test_timeout"ThreadedResolverTests.test_timeouts -  &  6?,=> #G,  " "; ; 1n- j''(w{+ R(q! Z!,  7123r"cL^/m[[5"U4SjS55n"SS[5nU"5nU"5nURU5 [ [ 55nUR RUS5 UR RUS5 UR RUS5 UR RUS5 UR RUS5 UR[T5S 5 UR[[[T55[/S -5 URSTS 5 URSTS 5 URS TS 5 URSTS5 URSTS5 g)zU L{ThreadedResolver.getHostByName} is passed L{str}, encoded using IDNA if required. c&>\rSrSrSU4SjjrSrg)AThreadedResolverTests.test_resolverGivenStr..FakeResolverr=c:>TRU5 [5$r)rYr )rrZtimeoutsrhs rrdOThreadedResolverTests.test_resolverGivenStr..FakeResolver.getHostByNames T"z!r"N)r=)rKrLrMrNrdrR)rhsr FakeResolverrs  " "r"rc\rSrSrSrSrg)FThreadedResolverTests.test_resolverGivenStr..JustEnoughReactorcgrr=rs r installWakerSThreadedResolverTests.test_resolverGivenStr..JustEnoughReactor.installWakersr"r=N)rKrLrMrNrrRr=r"rJustEnoughReactorrs r"rzexample.exampleuvääntynyt.exampleu рф.examplezxn----7sbb4ac0ad0be6cf.xn--p1airr`zxn--vntynyt-5waa.examplezxn--p1ai.exampleN)rrr installResolverrr nameResolverresolveHostNamerfrvlistmaptypestr)rrrfakerjrecrhs @rtest_resolverGivenStr+ThreadedResolverTests.test_resolverGivenStrso  _ % " " & "    ~#%%8:&,,S2CD,,S2CD,,S2KL,,S2HI,,S2ST UQ' c$./#; *E!H5 *E!H5 3U1X> +U1X6 :E!HEr"r=N) rKrLrMrNrOrnrxrrrRr=r"rrTrTTs!3F3:4B!Fr"rTcg)z0 Function used by L{DelayedCallTests.test_str}. Nr=r=r"rnothingrr"cT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rg)DelayedCallMixin L{DelayedCall} c *Sn[USS0X"S5$)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. cgrr=)calls rnoop0DelayedCallMixin._getDelayedCallAt..noops r"cgrr=r=r"rr 4DelayedCallMixin._getDelayedCallAt..sr"r=N)r )rtimers r_getDelayedCallAt"DelayedCallMixin._getDelayedCallAts 4r2t4HHr"c\URS5UlURS5Ulg)zJ Create two L{DelayedCall} instanced scheduled to run at different times. rr`N)rzerooners rsetUpDelayedCallMixin.setUps( **1- ))!,r"c [S[SSS0SSS5nUR[U5S[ U54-5 g) 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. rArNcgNg?r=r=r"rr +DelayedCallMixin.test_str..#r"z?)r rrfridrdcs rtest_strDelayedCallMixin.test_strsD WdS!HdD+ N  G M"vi  r"c |[S[SSS0SSS5nUR[U5[ U55 g)zy The string representation of a L{DelayedCall} instance, as returned by {repr}, is identical to that returned by L{str}. )r Ncg)Ng?r=r=r"rr ,DelayedCallMixin.test_repr..rr")r rrfrreprrs r test_reprDelayedCallMixin.test_repr s6 WdS!HdD+ N R$r(+r"cURURp!URX:5 URX!:5 URX:5 URX":5 g)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"cURURp!URX:*5 URX!:*5 URX:*5 URX":*5 g)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"cURURp!URX!:5 URX:5 URX:5 URX":5 g)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"cURURp!URX!:5 URX:5 URX:5 URX":5 g)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"cURURUR:H5 URURUR:H5 URURUR:H5 g)z4 A L{DelayedCall} instance is only equal to itself. N)rrrrrs rtest_eqDelayedCallMixin.test_eqAsQ dhh./  TYY./ DHH,-r"cURURUR:g5 URURUR:g5 URURUR:g5 g)z= A L{DelayedCall} instance is not equal to any other object. N)rrrrrs rtest_neDelayedCallMixin.test_neKsS  TXX-. dii/0 TXX-.r")rrN)rKrLrMrNrOrrrrrrrrrrrRr=r"rrrs: I-  , $ $ $ $./r"rc*\rSrSrSrSrSrSrSrg)DelayedCallNoDebugTestsiVrc\UR[SS5 [RU5 g)z Turn debug off. debugFNrbr rrrs rrDelayedCallNoDebugTests.setUp[s" ;/t$r"c [S[SSS0SSS5nSR[U55nUR [ U5U5 g)rrrrrNcgrr=r=r"rr 2DelayedCallNoDebugTests.test_str..hrr"zA)r rformatrrfr)rrexpecteds rr DelayedCallNoDebugTests.test_strbsK WdS!HdD+ N %vbf~  R(+r"c ~[SSS0[[S5nSUlURS[ U55 g)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. rcgrr=r=r"rr .vDr"r=cgNrr=r=r"rr rvAr"r`traceback at creationN)r rr assertNotInrrs rtest_switchToDebug*DelayedCallNoDebugTests.test_switchToDebugos6L"b'7I N 0$r(;r"r=N) rKrLrMrNrOrrrrRr=r"rrrVs% , .rr"z\.rr"r=cgrr=r=r"rr rrr"rrN)r rrassertInrrs rtest_switchFromDebug*DelayedCallDebugTests.test_switchFromDebugs4L"b'7I N -tBx8r"r=N) rKrLrMrNrOrrr rRr=r"rrr{s% 2 9r"rc\rSrSrSrSrSrg)TestSpySignalCapturingReactorizU Subclass of ReactorBase to capture signals delivered to the reactor for inspection. cg)z Required method, unused. Nr=rs rr*TestSpySignalCapturingReactor.installWakerrr"r=N)rKrLrMrNrOrrRr=r"rr r s   r"r zsignal module not availablec0\rSrSrSrSrSrSrSrSr g) ReactorBaseSignalTestsiz= Tests to exercise ReactorBase's signal exit reporting path. cP[5nURSUR5 g)z9 The default value of the _exitSignal attribute is None. N)r assertIs _exitSignalrrjs rtest_exitSignalDefaultsToNone4ReactorBaseSignalTests.test_exitSignalDefaultsToNones 01 dG//0r"c[5nUR[RS5 UR [RUR 5 g)zV ReactorBase's SIGINT handler saves the value of SIGINT to the _exitSignal attribute. N)r sigIntsignalSIGINT assertEqualsrrs rtest_captureSIGINT)ReactorBaseSignalTests.test_captureSIGINTs8 01v}}d+ &--)<)<=r"c[5nUR[RS5 UR [RUR 5 g)zX ReactorBase's SIGTERM handler saves the value of SIGTERM to the _exitSignal attribute. N)r sigTermrSIGTERMrrrs rtest_captureSIGTERM*ReactorBaseSignalTests.test_captureSIGTERMs8 01- &..'*=*=>r"c[[S5(d [S5e[5nUR [R S5 UR [R UR5 g)zZ ReactorBase's SIGBREAK handler saves the value of SIGBREAK to the _exitSignal attribute. SIGBREAKz$signal module does not have SIGBREAKN)hasattrrrr sigBreakr$rrrs rtest_captureSIGBREAK+ReactorBaseSignalTests.test_captureSIGBREAKsS vz**AB B/1$/ &//7+>+>?r"r=N) rKrLrMrNrOrrr!r'rRr=r"rrrs1>? @r"r)-rOrcqueuertypingrunittestrzope.interfacertyping_extensionsrtwisted.internet._resolverrtwisted.internet.baser r r twisted.internet.deferr twisted.internet.errorr twisted.internet.interfacesrrrtwisted.internet.taskrtwisted.python.threadpoolrtwisted.trial.unittestrrr_signal ImportErrorrrrTrrrrr rr=r"rr8s&'3LL+1VV'05Ft_ \?+, , ,, ^GFHGFT o/o/d"<."