o n~b@sUddlZddlZddlmZmZmZmZmZmZddl m Z ddl m Z dZ zddlZWn ey8dZYnwdZGdd d e ZGd d d e ZeeeefZerWeneZeed <dS) N)AnyDictListOptionalTypeUnion)AbstractResolver)get_running_loop)ThreadedResolver AsyncResolverDefaultResolverFc @sbeZdZdZddeejddfddZdej fde d e d e de e e effd d Zdd dZdS)r zThreaded resolver. Uses an Executor for synchronous getaddrinfo() calls. concurrent.futures.ThreadPoolExecutor is used by default. NloopreturncCst||_dSN)r _loop)selfrr;/usr/local/lib/python3.10/dist-packages/aiohttp/resolver.py__init__szThreadedResolver.__init__rhostnameportfamilyc s|jj||tj|tjdIdH}g}|D]L\}}}}}|tjkrFt|dkr(q|dr=t|tjtj B\} } t | }n|dd\} }n |tj ksMJ|\} }| || |||tj tjBdq|S)N)typerflagsrhostrrprotor)r getaddrinfosocket SOCK_STREAM AI_ADDRCONFIGAF_INET6len getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintAF_INETappendAI_NUMERICHOSTAI_NUMERICSERV) rrrrinfoshosts_raddressrZ_portrrrresolves>       zThreadedResolver.resolvecsdSrrrrrrcloseJszThreadedResolver.closerrN)__name__ __module__ __qualname____doc__rasyncioAbstractEventLooprr!r*strr)rrrr2r4rrrrr s ,r c @seZdZdZ ddeejdededdfddZd e j fd e d e d e de ee effd dZd e j fd e d e d e de ee effddZdddZdS)r z9Use the `aiodns` package to make asynchronous DNS lookupsNrargskwargsrcOsLtdurtdt||_tj|d|i||_t|jds$|j|_dSdS)Nz Resolver requires aiodns libraryr gethostbyname) aiodns RuntimeErrorr rZ DNSResolver _resolverhasattr_resolve_with_queryr2)rrr=r>rrrrQs   zAsyncResolver.__init__rrrrc sz |j||IdH}Wn!tjjy.}zt|jdkr#|jdnd}t||d}~wwg}|jD]}| ||||dt j t j Bdq4|sMtd|S)NrDNS lookup failedrr) rBr?r@errorDNSErrorr%r=OSError addressesr+r!r,r-) rrrrrespexcmsgr/r1rrrr2as,    zAsyncResolver.resolvec s|tjkr d}nd}z |j||IdH}Wn!tjjy8}zt|jdkr-|jdnd}t ||d}~wwg}|D]} | || j ||dtj dq=|sTt d|S)NZAAAAArrErr) r!r$rBqueryr@rFrGr%r=rHr+rr,) rrrrZqtyperJrKrLr/rrrrrrD{s2   z!AsyncResolver._resolve_with_querycs|jdSr)rBcancelr3rrrr4szAsyncResolver.closerr5)r6r7r8r9rr:r;rrr!r*r<r)rrr2rDr4rrrrr NsB    r r )r:r!typingrrrrrrabcr helpersr __all__r@ ImportErrorZaiodns_defaultr r Z _DefaultTyper __annotations__rrrrs      :Q