o )f@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)selfrr0lib/python3.10/site-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)rZ getaddrinfosocketZ SOCK_STREAMZ AI_ADDRCONFIGAF_INET6lenZ getnameinfoZNI_NUMERICHOSTZNI_NUMERICSERVintAF_INETappendAI_NUMERICHOSTAI_NUMERICSERV) rrrrZinfoshosts_raddressrZ_portrrrresolves>       zThreadedResolver.resolvecsdSrrrrrrcloseJszThreadedResolver.closerrN)__name__ __module__ __qualname____doc__rasyncioAbstractEventLooprr r$strr#rrrr+r-rrrrr 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_queryr+)rrr6r7rrrrQs   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) r;r8r9errorDNSErrorr"r6OSErrorZ addressesr%r r&r') rrrrrespexcmsgr(r*rrrr+as,    zAsyncResolver.resolvec s|tjkr d}nd}z |j||IdH}Wn!tjjy8}zt|jdkr-|jdnd}t ||d}~wwg}|D]} | || j ||dtj dq=|sTt d|S)NZAAAAArr>rr) r r!r;Zqueryr9r?r@r"r6rAr%rr&) rrrrZqtyperBrCrDr(Zrrrrrr={s2   z!AsyncResolver._resolve_with_querycs|jdSr)r;Zcancelr,rrrr-szAsyncResolver.closerr.)r/r0r1r2rr3r4rrr r$r5r#rrr+r=r-rrrrr NsB    r r )r3r typingrrrrrrabcr Zhelpersr __all__r9 ImportErrorZaiodns_defaultr r Z _DefaultTyper __annotations__rrrrs      :Q