B ind@sUddlZddlZddlmZmZmZmZmZmZddl m Z ddl m Z dZ y 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||_dS)N)r _loop)selfrr4/tmp/pip-unpacked-wheel-fdo6ttx3/aiohttp/resolver.py__init__szThreadedResolver.__init__r)hostnameportfamilyrc s|jj||tj|tjdIdH}g}x|D]\}}}}}|tjkrt|dkrPq*|drzt|tjtj B\} } t | }q|dd\} }n|tj kst |\} }| || |||tjtjBdq*W|S)N)typerflags)rhostrrprotor)r getaddrinfosocket SOCK_STREAM AI_ADDRCONFIGAF_INET6len getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintAF_INETAssertionErrorappendAI_NUMERICHOSTAI_NUMERICSERV) rrrrinfoshosts_raddressrZ_portrrrresolves4   zThreadedResolver.resolve)rcsdS)Nr)rrrrcloseJszThreadedResolver.close)N)__name__ __module__ __qualname____doc__rasyncioAbstractEventLooprrr(strr'rrrr1r2rrrrr 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_queryr1)rrr:r;rrrrQs   zAsyncResolver.__init__r)rrrrc sy|j||IdH}WnLtjjk rd}z*t|jdkrF|jdnd}t||Wdd}~XYnXg}x.|jD]$}| ||||dt j t j BdqrW|std|S)NrzDNS lookup failedr)rrrrrr) r?r<r=errorDNSErrorr#r:OSError addressesr*rr+r,) rrrrrespexcmsgr.r0rrrr1as" zAsyncResolver.resolvec s|tjkrd}nd}y|j||IdH}WnLtjjk rx}z*t|jdkrZ|jdnd}t ||Wdd}~XYnXg}x(|D] } | || j ||dtj dqW|st d|S)NZAAAAArzDNS lookup failedr)rrrrrr) rr"r?queryr=rBrCr#r:rDr*rr+) rrrrZqtyperFrGrHr.rrrrrrA{s(  z!AsyncResolver._resolve_with_query)rcs|jdS)N)r?cancel)rrrrr2szAsyncResolver.close)N)r3r4r5r6rr7r8rrrr(r9r'rrr1rAr2rrrrr Ns  r r )r7rtypingrrrrrrabcr Zhelpersr __all__r= ImportErrorZaiodns_defaultr r Z _DefaultTyper __annotations__rrrrs     :Q