H/\c@`sJddlmZmZmZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlm Z ddlm Z ddlm Z ddlmZddlZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZdgZdZeZdZeej_ej Z ej j!Z"e#eddZ$ddeddddZ&e&e _&dZ'ej(j)dZ*e*Z+dZ,de-fdYZ.dej j/fdYZ0de-fdYZ1de-fdYZ2d Z3defd!YZ4dS("i(tabsolute_importtprint_functiontdivisionN(tAI_NUMERICHOST(terror(tNI_NUMERICSERV(tAF_INET(tAF_INET6(t AF_UNSPEC(tAbstractResolver(thostname_types(t string_types(t iteritems(timport_patched(tconfigtResolvercC`s_td}xLdD]D}t|}x/|jD]$}t||t|d|q/WqW|S(Ntdnss dns.rdtypessdns.rdtypes.INsdns.rdtypes.ANYt.(Rs dns.rdtypessdns.rdtypes.INsdns.rdtypes.ANY(R t__all__tsetattr(ttoptpkgtmodtname((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt _patch_dns\s   &cC`s#|jdstt|tS(NR(t startswithtAssertionErrorR R(R((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt_dns_import_patchedis t exc_clearcC`sdS(N(tNone(((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pytysc C`sG|tjtjB@dkr#tn|dkrP|dkrPtjtjng}g}d}y|dkrd}|tj@dkr|jd|jdq|jd|jdnY|j d} t | dkr| d} n|} t j j | } |j||}Wntk rty)t jj |} |j||}Wqtk rt|tj@dkry*|tjks|tjkrtjj|t jjd t} | j}| jjt}| jdk rx$| jD]} |j| jqWqn|tj ks<|tjkrtjj|t jj!d t}|j}|jjt}|jdk rx$|jD]} |j| jqWqnWqt jj"k rttjtjqtk r ttjtj#qXqqXnXd}y%|dkr7d}n t$|}Wn\tk rt|tj%@dkrytj&|}Wqtk rtqXqnX|dkrtjtjng}|dkrtj'tj(g}n |g}|tj)@dkr|}nd }|tjks4|tjkrxe|D]Z} xQ|D]I}x@tj*|D]1}|jtj|||| |ddffq\WqHWq;Wn|tj ks|tjkrx_|D]T} xK|D]C}x:tj*|D]+}|jtj |||| |ffqWqWqWnt |dkrCtjtjn|S( Nit localhosts::s0.0.0.0s::1s 127.0.0.1t%itraise_on_no_answert(+tsockett AI_ADDRCONFIGt AI_V4MAPPEDtNotImplementedErrorRtgaierrort EAI_NONAMEt AI_PASSIVEtappendtsplittlenRtipv6t inet_atont Exceptiont _exc_cleartipv4RRRtresolvert _resolvertqueryt rdatatypetAAAAtFalsetqnametcanonical_nametto_texttTruetrrsettaddressRtAtNXDOMAINt EAI_SYSTEMtinttAI_NUMERICSERVt getservbynamet SOCK_DGRAMt SOCK_STREAMt AI_CANONNAMEt_protocols_for_socktype(thosttservicetfamilytsocktypetprototflagstv6addrstv4addrsR9tpartstahosttaddrtv6trdatatv4tportttuplest socktypestcname((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt _getaddrinfos                !          (  "gr@cC`s\|s tSt|ts+tt|y||Wntjjk rStSXtSdS(N( R7t isinstanceR RtreprRt exceptiont SyntaxErrorR;(RHtparse((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt_is_addrs!cC`sM|r:t|trdnd}|j|dd}nt|tjjS(NR ii(R[tstrR+R`RR-R.(RHts((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt _is_ipv6_addrst HostsFilecB`sJeZdZejdejZddZdZ dZ dZ RS(sD A class to read the contents of a hosts file (/etc/hosts). s \s* # Leading space ([^\r\n#]+?) # The actual match, non-greedy so as not to include trailing space \s* # Trailing space (?:[#][^\r\n]+)? # Comments (?:$|[\r\n]+) # EOF or newline cC`si|_i|_i|_i|_|dkrotjdkrHd}qotjdkrotjjd}qon||_ |j st d|_ dS(Ntposixs /etc/hoststnts'%SystemRoot%\system32\drivers\etc\hostsi( RURStaliasestreverseRtosRtpatht expandvarstfnameRt _last_load(tselfRl((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt__init__s        cC`s^t|jd}|j}WdQXt|tsH|jddn|}|jj|S(Ntrbterrorstignore(topenRltreadR[RatdecodetLINES_REtfindall(Rntfptfdatatudata((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt _readlines%s'cC`sy(tj|jj}||jk}WnFttfk rpddlm}|j |t j t }nX|s{dSi}i}i}i}x-|j D]}|j} t| dkrqn| jd} t| r|} n-t| r| jdrqn|} nq| jdj} | | | RURR6RSRRgRRhtgett is_absolutetaddR(RnR8RRttcptsourceR!tnowRRR<tmappingtkindRR((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyR4s>             cC`s|jj}g}||kr+||}n|}|j|x6t|D](\}}||krK|j|qKqKW|j||S(N(RRgR*R tremove(RnthostnameRgtresulttcannonRRY((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt getaliasess      N(RRRRt HOSTS_TTLRoRR5R>RRR7R;R4R(((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyRs 0t _DualResolvercB`sSeZdZejjejjede ejjejj ejj fdZ RS(cC`s1t|_tj|_tj|j_dS(N(Rthosts_resolverR2tget_default_resolvertnetwork_resolvertLRUCachetcache(Rn((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyRos c C`s?|dkrd}nt|tsHt|trH|jd}qHnt|trotjj|d}nt|trtjj|}n|tj j kr||kry|j j ||dt }Wn:tk r ddlm} | j|tjqX|jr|Sn|jj |||||d|S(Ns0.0.0.0tidnaR!i(R|(RR[R tbytesRuRRRR5RRRR4R7R/RR|RRRR<R( RnR8RRRRR!t_hosts_rdtypestanswerR|((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyR4s&    N(RRRoRR5R>RRR7RR;R6RR4(((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyRs  cC`sU|tjkrtjj}n3|tjkr<tjj}ntjtjd|S(NsAddress family not supported( R#RRR5R>RR6R't EAI_FAMILY(RJR((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt_family_to_rdtypes  cB`sbeZdZd dZedZdZdZdddddZ dZ dZ RS( s An *experimental* resolver that uses `dnspython`_. This is typically slower than the default threaded resolver (unless there's a cache hit, in which case it can be much faster). It is usually much faster than the c-ares resolver. It tends to scale well as more concurrent resolutions are attempted. Under Python 2, if the ``idna`` package is installed, this resolver can resolve Unicode host names that the system resolver cannot. .. note:: This **does not** use dnspython's default resolver object, or share any classes with ``import dns``. A separate copy of the objects is imported to be able to function in a non monkey-patched process. The documentation for the resolver object still applies. The resolver that we use is available as the :attr:`resolver` attribute of this object (typically ``gevent.get_hub().resolver.resolver``). .. caution:: Many of the same caveats about DNS results apply here as are documented for :class:`gevent.resolver.ares.Resolver`. .. caution:: This resolver is experimental. It may be removed or modified in the future. As always, feedback is welcome. .. versionadded:: 1.3a2 .. _dnspython: http://www.dnspython.org cC`stjdkrYt}t_tjr;tj|jj(ntjrYtj|j_ qYnt tjtsqt tj|_dS(N( R2R3RRRtresolver_nameserversRt nameserverstresolver_timeouttlifetimeR[R(RnthubR3((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyRo+s  cC`s |jjS(s The dnspython resolver object we use. This object has several useful attributes that can be used to adjust the behaviour of the DNS system: * ``cache`` is a :class:`dns.resolver.LRUCache`. Its maximum size can be configured by calling :meth:`resolver.cache.set_max_size` * ``nameservers`` controls which nameservers to talk to * ``lifetime`` configures a timeout for each individual query. (R3R(Rn((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyR27s cC`sdS(N((Rn((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pytcloseFscC`st|ts3t|tr3|jd}q3n|jjj|}|jj}t|}xt ry|j |t j j |}Wn>t jjt jjt jjfk rPqctk rPqcX|jd|jD|dj}qcW|S(NRcs`s|]}t|jVqdS(N(Rattarget(t.0trr((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pys Xsi(R[RaRRuR3RRRRR;R4RR5RR2RR?t NoNameserverstdTimeouttextendR<R(RnRRJRgt net_resolverRtans((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt _getaliasesIs    ( icC`s|dksAt|r'|jdsAt|t sA|t@r]tj||||||S|tkryt||||||SWqt j k ryt||t |||SWqt j k rt||t |||SXqXnt||||||SdS(Nu localhostRR}(u localhostR( RcRR[RaRt_sockett getaddrinfoRRZR#R'RR(RnRHRVRJRKRLRM((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyR\s  !cC`s|r;t|ttfr;|ddkr;tj||St|ttfrst|dt rstdnytj||SWn't k r|stj|t SnXdS(Nis::1s 127.0.0.1Rs(getnameinfo(): illegal sockaddr argument(s::1s 127.0.0.1R( R[tlistttupleRt getnameinfoR t TypeErrorR2t _getnameinfoRR(RntsockaddrRM((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyR}s) cC`sQ|dkrtj|St|tsDtdt|fntj|S(Nu 127.0.0.1u::1s 127.0.0.1s::1Rs2argument 1 must be str, bytes or bytearray, not %s(u 127.0.0.1u::1s 127.0.0.1s::1R(Rt gethostbyaddrR[R RttypeR2t_gethostbyaddr(Rnt ip_address((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyRs  N( RRRRRotpropertyR2RRRRR(((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyRs$   ! (5t __future__RRRRRRiRRRRRRRRR#tgevent.resolverR R tgevent._compatR R tgevent._patcherR tgevent._configRRRRRRTt __import__R2tTimeoutRtgetattrR0RRZRR1R.R`RRctobjectRdtAnswerRRRRR(((s8lib/python2.7/site-packages/gevent/resolver/dnspython.pyt=sN            m   lN)