U u?d@sUddlZddlZddlmZmZmZmZmZmZddl m Z ddl m Z dZ z ddlZWnek rrdZYnXdZGdd d e ZGd d d e ZeeeefZereneZeed <dS) N)AnyDictListOptionalTypeUnion)AbstractResolver)get_running_loop)ThreadedResolver AsyncResolverDefaultResolverFc@s^eZdZdZd eejddddZdej fe e e e e e efddd Zdd d d ZdS)r zThreaded resolver. Uses an Executor for synchronous getaddrinfo() calls. concurrent.futures.ThreadPoolExecutor is used by default. N)loopreturncCst||_dSN)r _loop)selfrr4/tmp/pip-unpacked-wheel-_pk67_um/aiohttp/resolver.py__init__szThreadedResolver.__init__r)hostnameportfamilyrc s|jj||tj|tjdIdH}g}|D]\}}}}}|tjkrt|dkrNq(|drxt|tjtj B\} } t | }q|dd\} }n|tj kst |\} }| || |||tjtjBdq(|S)N)typerflagsrhostrrprotor)r getaddrinfosocket SOCK_STREAM AI_ADDRCONFIGAF_INET6len getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintAF_INETAssertionErrorappendAI_NUMERICHOSTAI_NUMERICSERV) rrrrZinfoshosts_raddressrZ_portrrrresolves>       zThreadedResolver.resolvercsdSrrrrrrcloseJszThreadedResolver.close)N)__name__ __module__ __qualname____doc__rasyncioAbstractEventLooprr!r*strr)rrrr2r5rrrrr s ,r c@seZdZdZdeejeeddddZde j fe e e e ee efddd Zde j fe e e e ee efdd d Zdd d dZdS)r z9Use the `aiodns` package to make asynchronous DNS lookupsN)rargskwargsrcOsHtdkrtdt||_tj|d|i||_t|jdsD|j|_dS)Nz Resolver requires aiodns libraryr gethostbyname) aiodns RuntimeErrorr rZ DNSResolver _resolverhasattr_resolve_with_queryr2)rrr=r>rrrrQs   zAsyncResolver.__init__r)rrrrc sz|j||IdH}WnLtjjk rd}z*t|jdkrF|jdnd}t||W5d}~XYnXg}|jD]$}| ||||dt j t j Bdqp|std|S)NrDNS lookup failedrr) rBr?r@errorDNSErrorr%r=OSError addressesr,r!r-r.) rrrrrespexcmsgr/r1rrrr2as&   zAsyncResolver.resolvec s|tjkrd}nd}z|j||IdH}WnLtjjk rx}z*t|jdkrZ|jdnd}t ||W5d}~XYnXg}|D] } | || j ||dtj dq|st d|S)NZAAAAArrErr) r!r$rBqueryr@rFrGr%r=rHr,rr-) rrrrZqtyperJrKrLr/rrrrrrD{s,  z!AsyncResolver._resolve_with_queryr3cs|jdSr)rBcancelr4rrrr5szAsyncResolver.close)N)r6r7r8r9rr:r;rrr!r*r<r)rrr2rDr5rrrrr Ns2   r r )r:r!typingrrrrrrabcr Zhelpersr __all__r@ ImportErrorZaiodns_defaultr r Z _DefaultTyper __annotations__rrrrs     :Q