+ DfjLRt^RIHt^RIHtHtHtHtHtH t H t H t H t ^RI HtHt^RIHt^RIHt^RIHtHtHt^RIHtHtHt^RIHtHt^R IH t H!t!^R I"H#t#^R I$H%t%^R I&H't'H(t(H)t)H*t*^R I+H,t,^RI-H.t/!RR],4t0Rt1Rt2!RR4t3]!])4!RR44t4!RR]/4t5!RR]/4t6]!]*4!RR44t7!RR]/4t8!RR ]!4t9!R!R"]/4t:R##)$zh Tests for implementations of L{IHostnameResolver} and their interactions with reactor implementations. ) defaultdict) AF_INETAF_INET6 AF_UNSPEC EAI_NONAME IPPROTO_TCP SOCK_DGRAM SOCK_STREAMgaierror getaddrinfo)Locklocal) implementer) verifyObject) LockWorkerTeamcreateMemoryWorker)ComplexResolverSimplifier GAIResolverSimpleResolverComplexifier) IPv4Address IPv6Address)PluggableResolverMixin ReactorBase)Deferred)DNSLookupError)IHostnameResolverIReactorPluggableNameResolverIResolutionReceiverIResolverSimple) ThreadPool)SynchronousTestCasec*a]tRt^/toRtRtRtVtR#)DeterministicThreadPoolz. Create a deterministic L{ThreadPool} object. c J^Vn^VnRVn.VnWnR#)z5 Create a L{DeterministicThreadPool} from a L{Team}. N)minmaxnamethreads_team)selfteams&&E/usr/lib/python3/dist-packages/twisted/internet/test/test_resolver.py__init__ DeterministicThreadPool.__init__4s%   )r)r&r%r'r(N)__name__ __module__ __qualname____firstlineno____doc__r-__static_attributes____classdictcell__ __classdict__s@r,r#r#/sr/r#c a\4wop\\\\ 4\ 44V3RlR44V3#)z Create a deterministic threadpool. @return: 2-tuple of L{ThreadPool}, 0-argument C{work} callable; when C{work} is called, do the work. c<S#N)workersr,#deterministicPool..Isvr/cR#r;r<r<r/r,r>r?Isr/)rr#rrr r )doerr=s @r,deterministicPoolrB?s?&'LFD DFEG,~ M   r/cJa\4wop!V3RlR4pV!4V3#)z Create a deterministic L{IReactorThreads} @return: a 2-tuple consisting of an L{IReactorThreads}-like object and a 0-argument callable that will perform one unit of work invoked via that object's C{callFromThread} method. c.<a]tRt^YtoV3RltRtVtR#)(deterministicReactorThreads..CFTc<<aaaSPVVV3Rl4R#)c<S!S/SB#r;r<)afksr,r>IdeterministicReactorThreads..CFT.callFromThread..[s ajajr/N)do)r*rIrHrJr=s&fjlr,callFromThread7deterministicReactorThreads..CFT.callFromThreadZs II( )r/r<N)r0r1r2r3rMr5r6)r8r=s@r,CFTrEYs * *r/rO)r)rArOr=s @r,deterministicReactorThreadsrPOs)&'LFD** 5$;r/cFa]tRt^`toRtRtRRlt]]] R3Rlt Rt Vt R#) FakeAddrInfoGetterz' Test object implementing getaddrinfo. c <.Vn\\4VnR#)z! Create a L{FakeAddrInfoGetter}. N)callsrlistresultsr*s&r,r-FakeAddrInfoGetter.__init__es "4( r/c VPPWW4WV34VPV,pV'dV#\\R4h)a9 Mock for L{socket.getaddrinfo}. @param host: see L{socket.getaddrinfo} @param port: see L{socket.getaddrinfo} @param family: see L{socket.getaddrinfo} @param socktype: see L{socket.getaddrinfo} @param proto: see L{socket.getaddrinfo} @param flags: see L{socket.getaddrinfo} @return: L{socket.getaddrinfo} z,nodename nor servname provided, or not known)rTappendrVr r)r*hostportfamilysocktypeprotoflagsrVs&&&&&&& r,r FakeAddrInfoGetter.getaddrinfolsA$ 4vFG,,t$ N:'UV Vr/r/c PVPV,PW4WVV34R#)aH Add a result for a given hostname. When this hostname is resolved, the result will be a L{list} of all results C{addResultForHost} has been called with using that hostname so far. @param host: The hostname to give this result for. This will be the next result from L{FakeAddrInfoGetter.getaddrinfo} when passed this host. @type canonname: native L{str} @param sockaddr: The resulting socket address; should be a 2-tuple for IPv4 or a 4-tuple for IPv6. @param family: An C{AF_*} constant that will be returned from C{getaddrinfo}. @param socktype: A C{SOCK_*} constant that will be returned from C{getaddrinfo}. @param proto: An C{IPPROTO_*} constant that will be returned from C{getaddrinfo}. @param canonname: A canonical name that will be returned from C{getaddrinfo}. @type canonname: native L{str} N)rVrZ)r*r[sockaddrr]r^r_ canonnames&&&&&&&r,addResultForHost#FakeAddrInfoGetter.addResultForHosts#H T!!6Ux"PQr/)rTrVN)rgrgrg) r0r1r2r3r4r-r rr rrer5r6r7s@r,rRrR`s/)W:$R$Rr/rRcDa]tRt^toRtRtRtRtRtRt Rt Rt Vt R#) ResultHolderzA A resolution receiver which holds onto the results it received. Fc WnR#)z. Create a L{ResultHolder} with a L{UnitTest}. N) _testCase)r*testCases&&r,r-ResultHolder.__init__s "r/c .RVnWn.VnR#)zO Hostname resolution began. @param hostResolution: see L{IResolutionReceiver} TN)_started _resolution _addresses)r*hostResolutions&&r,resolutionBeganResultHolder.resolutionBegans  )r/c <VPPV4R#)zF An address was resolved. @param address: see L{IResolutionReceiver} N)rqrZ)r*addresss&&r,addressResolvedResultHolder.addressResolveds w'r/c RVnR#)z" Hostname resolution is complete. TN)_endedrWs&r,resolutionCompleteResultHolder.resolutionCompletes  r/)rqrzrprorkN) r0r1r2r3r4rorzr-rsrwr{r5r6r7s@r,riris/H F" (r/ric*a]tRt^toRtRtRtVtR#) HelperTestsz7 Tests for error cases of helpers used in this module. c \4wVnVnRpVPPV4VP4VP \ VP \44^4R#)zY L{DeterministicThreadPool} will log any exceptions that its "thread" workers encounter. c^^, #)r<r<r/r, divideByZero9HelperTests.test_logErrorsInThreads..divideByZeros q5Lr/N)rBpool doThreadWork callInThread assertEquallenflushLoggedErrorsZeroDivisionError)r*rs& r,test_logErrorsInThreads#HelperTests.test_logErrorsInThreadss\ (9':$ 4$  |,  T334EFGKr/)rrN)r0r1r2r3r4rr5r6r7s@r,r~r~s L Lr/r~c`a]tRt^toRtRtRtRtRtRt Rt Rt R t R t R tR tVtR #)HostnameResolutionTestsz Tests for hostname resolution. c a\4wSnSn\4wSnSn\ 4Sn\SPV3RlSPP4Sn R#)z Set up a L{GAIResolver}. c<SP#r;rrWsr,r>/HostnameResolutionTests.setUp.. $))r/N) rBrrrPreactor doReactorWorkrRgetterrr resolverrWsfr,setUpHostnameResolutionTests.setUpsU(9':$ 4$+F+H( d((* # LL+T[[-D-D  r/c \V4pVPPRR4VPP VR4pVP VP V4VPVPR4VPVPR4VP4VP4VPVPR4VPVP\RR^4.4R#)z Resolving an individual hostname that results in one address from getaddrinfo results in a single call each to C{resolutionBegan}, C{addressResolved}, and C{resolutionComplete}. sample.example.com4.3.2.1TFTCPN)rrg)rirrerresolveHostNameassertIsrprrorzrrrqrr*receiver resolutions& r,test_resolveOneHost+HostnameResolutionTests.test_resolveOneHosts  % $$%9>J]]228=QR  h**J7 **D1 %0   $/ ,,{5)Q/O.PQr/c  \V4p^p^pVPPRR^W#3\R7VPP VR4pVP VPV4VPVPR4VPVPR4VP4VP4VPVPR4VPVP\RR^W#4.4R#)z Resolving an individual hostname that results in one address from getaddrinfo results in a single call each to C{resolutionBegan}, C{addressResolved}, and C{resolutionComplete}; C{addressResolved} will receive an L{IPv6Address}. r::1)r]TFrN)rirrerrrrrprrorzrrrqr)r*rflowInfoscopeIDrs& r,test_resolveOneIPv6Host/HostnameResolutionTests.test_resolveOneIPv6Host s % $$ 5!X"? % ]]228=QR  h**J7 **D1 %0   $/    +eUAx"Q!R r/c t\V4pVPPVR4pVPVPV4VP 4VP 4VPVPR4VPVPR4VPVP.4R#)z Resolving a hostname that results in C{getaddrinfo} raising a L{gaierror} will result in the L{IResolutionReceiver} receiving a call to C{resolutionComplete} with no C{addressResolved} calls in between; no failure is logged. rTN) rirrrrprrrrorzrqrs& r, test_gaierror%HostnameResolutionTests.test_gaierror!s %]]228=QR  h**J7   **D1 $/ ,,b1r/c 4\V4pVPPVRVR7pVPVPV4VP 4VP 4VPP^,wrVrxrVPWr4R#)z Verify that the given set of address types results in the given C{AF_} constant being passed to C{getaddrinfo}. @param addrTypes: iterable of L{IAddress} implementers @param expectedAF: an C{AF_*} constant r) addressTypesN) rirrrrprrrrTr) r* addrTypes expectedAFrrr[r\r]r^r_r`s &&& r,_resolveOnlyTest(HostnameResolutionTests._resolveOnlyTest1s %]]22 *3  h**J7  59[[5F5Fq5I2Fe ,r/c <VP\.\4R#)z When passed an C{addressTypes} parameter containing only L{IPv4Address}, L{GAIResolver} will pass C{AF_INET} to C{getaddrinfo}. N)rrrrWs&r,test_resolveOnlyIPv4,HostnameResolutionTests.test_resolveOnlyIPv4Ds {mW5r/c <VP\.\4R#)z When passed an C{addressTypes} parameter containing only L{IPv6Address}, L{GAIResolver} will pass C{AF_INET6} to C{getaddrinfo}. N)rrrrWs&r,test_resolveOnlyIPv6,HostnameResolutionTests.test_resolveOnlyIPv6Ks {mX6r/c rVP\\.\4VPR\4R#)z When passed an C{addressTypes} parameter containing both L{IPv4Address} and L{IPv6Address} (or the default of C{None}, which carries the same meaning), L{GAIResolver} will pass C{AF_UNSPEC} to C{getaddrinfo}. N)rrrrrWs&r,test_resolveBoth(HostnameResolutionTests.test_resolveBothRs) {K8)D dI.r/c \V4pVPPVRRR7\V4pVPPVRRR7VP4VP 4VP4VP 4VP P ^,wr4rVrxVP P ^,wr4rYrxVPV\4VPV \4R#)z When passed a C{transportSemantics} paramter, C{'TCP'} (the value present in L{IPv4Address.type} to indicate a stream transport) maps to C{SOCK_STREAM} and C{'UDP'} maps to C{SOCK_DGRAM}. example.comr)transportSemanticsUDPN) rirrrrrrTrr r) r*r receiver2r[r\r] socktypeTr_r` socktypeUs & r,#test_transportSemanticsToSocketType;HostnameResolutionTests.test_transportSemanticsToSocketType[s  % %%h RW%X &  %% } &     6:kk6G6G6J3Fu6:kk6G6G6J3Fu K0 J/r/c R\V4p^p^p\\3FLpVPP RR^W#3\ VR7VPP RR\ VR7KN VPPVR4VP4VP4VPwrVrxVPVPR4VPVPR4VPVPR4VPVPR4R#)z When L{GAIResolver} receives a C{SOCK_DGRAM} result from C{getaddrinfo}, it returns a C{'TCP'} L{IPv4Address} or L{IPv6Address}; if it receives C{SOCK_STREAM} then it returns a C{'UDP'} type of same. rr)r]r^rrN)z 127.0.0.3rg)rir rrrerrrrrrrqrtype) r*rrrr^stream4stream6dgram4dgram6s & r,test_socketTypeToAddressType4HostnameResolutionTests.test_socketTypeToAddressTypeps  %#Z/H KK ( (8-! )  KK ( (/( ) 0 %%h >  +3+>+>(& u- u- e, e,r/rrrrrrN)r0r1r2r3r4rrrrrrrrrrr5r6r7s@r,rrsB  R" 02 -&67/0*--r/rc4a]tRtRtoRtRtRRltRtVtR#)SillyResolverSimpleiz. Trivial implementation of L{IResolverSimple} c .VnR#)zL Create a L{SillyResolverSimple} with a queue of requests it is working on. N _requestsrWs&r,r-SillyResolverSimple.__init__s r/c nVPP\44VPR,#)z Implement L{IResolverSimple.getHostByName}. @param name: see L{IResolverSimple.getHostByName}. @param timeout: see L{IResolverSimple.getHostByName}. @return: see L{IResolverSimple.getHostByName}. )rrZr)r*r'timeouts&&&r, getHostByName!SillyResolverSimple.getHostByNames' hj)~~b!!r/rN)r<) r0r1r2r3r4r-rr5r6r7s@r,rrs " "r/rcBa]tRtRtoRtRtRtRtRtRt Rt Vt R #) LegacyCompatibilityTestsiz Older applications may supply an object to the reactor via C{installResolver} that only provides L{IResolverSimple}. L{SimpleResolverComplexifier} is a wrapper for an L{IResolverSimple}. c \4p\V4p\V4pVPVPR4VP VR4VPVPR4VPVP R4VPVP.4VP^,PR4VPVP\RR^4.4VPVP R4R#)zj L{SimpleResolverComplexifier} translates C{resolveHostName} into L{IResolutionReceiver.addressResolved}. FrT 192.168.1.1rN) rrrirrorrzrqrcallbackrr*simplecomplexrs& r, test_success%LegacyCompatibilityTests.test_successs %&,V4% **E2-8 **D1 %0 ,,b1$$]3 ,,{5-QR/S.TU $/r/c \4p\V4p\V4pVPVPR4VP VR4VPVPR4VPVP R4VPVP.4VP^,P\R44VPVP R4VPVP.4R#)z} L{SimpleResolverComplexifier} translates a known error result from L{IResolverSimple.resolveHostName} into an empty result. FrTnopeN) rrrirrorrzrqrerrbackrrs& r, test_failure%LegacyCompatibilityTests.test_failures %&,V4% **E2-8 **D1 %0 ,,b1##N6$:; $/ ,,b1r/c l\4p\V4p\V4pVPVPR4VP VR4VPVPR4VPVP R4VPVP.4VP^,P\R44VP\VP\44^4VPVP R4VPVP.4R#)z L{SimpleResolverComplexifier} translates an unknown error result from L{IResolverSimple.resolveHostName} into an empty result and a logged error. FrTzowN) rrrirrorrzrqrrrrrrs& r, test_error#LegacyCompatibilityTests.test_errors %&,V4% **E2-8 **D1 %0 ,,b1##$5e$<= T334EFGK $/ ,,b1r/c a\4wSnSn\4wSnSn\ 4Sn\SPV3RlSPP4Sn \SP4pSPPRR4VPR4pVPR4pSP4SP 4SP4SP 4SPSPV4P \"4SPSP%V4R4R#)z L{ComplexResolverSimplifier} translates an L{IHostnameResolver} into an L{IResolverSimple} for applications that still expect the old interfaces to be in place. c<SP#r;rrWsr,r>:LegacyCompatibilityTests.test_simplifier..rr/r 192.168.3.4znx.example.comN)r)rBrrrPrrrRrrr rrrerrfailureResultOfrrsuccessResultOf)r*simpleResolversuccessfailuresf r,test_simplifier(LegacyCompatibilityTests.test_simplifiers (9':$ 4$+F+H( d((* # LL+T[[-D-D  34==A $$]4IJ ..}= ../?@     --g6;;^L --g6 Fr/c \4p\V4p\V4pVPVRR4VP VP R4VP VP R4VP VP.4VP^,PR4VP VP\RRR4.4VP VP R4R#)zv L{SimpleResolverComplexifier} preserves the C{port} argument passed to C{resolveHostName} in its returned addresses. rrTFrrN) rrrirrrorzrqrrrrs& r,test_portNumber(LegacyCompatibilityTests.test_portNumbers %&,V4%-> **D1 %0 ,,b1$$]3 ,,{5-QU/V.WX $/r/rN) r0r1r2r3r4rrrrrr5r6r7s@r,rrs) 0"2"2&G.00r/rc*a]tRtRtoRtRtRtVtR#)JustEnoughReactori zL Just enough subclass implementation to be a valid L{ReactorBase} subclass. c R#)z Do nothing. Nr<rWs&r, installWakerJustEnoughReactor.installWakersr/r<N)r0r1r2r3r4rr5r6r7s@r,rr s  r/rc6a]tRtRtoRtRtRtRtRtVt R#)ReactorInstallationTestsiz Tests for installing old and new resolvers onto a L{PluggableResolverMixin} and L{ReactorBase} (from which all of Twisted's reactor implementations derive). c \4p\\V4\\VP4\\ VP 4R#)z L{PluggableResolverMixin} (and its subclasses) implement both L{IReactorPluggableNameResolver} and L{IReactorPluggableResolver}. N)rrrrrr nameResolverr*rs& r,test_interfaceCompliance1ReactorInstallationTests.test_interfaceCompliances8 )*2G<_g&6&67&(<(<=r/c \4p\4p\\VP V44VP VP \4VPVP PV4R#)zN L{PluggableResolverMixin} will wrap an L{IResolverSimple} in a complexifier. N) rrrrinstallResolverassertIsInstancerrr_simpleResolver)r*rits& r,test_installingOldStyleResolver8ReactorInstallationTests.test_installingOldStyleResolver(sZ )* "_g&=&=b&AB g224NO g**::B?r/c \4pVPVP\4VP VPP \ 4VPVP\4VP VPPV4VP VPPVP4R#)z4 L{ReactorBase} defaults to using a L{GAIResolver}. N) rr rrr _getaddrinfor rr_reactor _nameResolverrs& r,test_defaultToGAIResolver2ReactorInstallationTests.test_defaultToGAIResolver3s$% g22K@ g**77E g..0IJ g**33W= g&&44g6J6JKr/r<N) r0r1r2r3r4rr rr5r6r7s@r,rrs! > @ L Lr/rN);r4 collectionsrsocketrrrrrrr r r threadingr r zope.interfacerzope.interface.verifyrtwisted._threadsrrrtwisted.internet._resolverrrrtwisted.internet.addressrrtwisted.internet.baserrtwisted.internet.deferrtwisted.internet.errorrtwisted.internet.interfacesrrrrtwisted.python.threadpoolr twisted.trial.unittestr!UnitTestr#rBrPrRrir~rrrrrr<r/r,r$s $   "&.AA >E+1 1B j   "IRIRX !$$"$NL(L(b-hb-J _"""4a0xa0H  %Lx%Lr/