o +if@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)selfrrI/var/www/html/corbot_env/lib/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)r getaddrinfosocket SOCK_STREAM AI_ADDRCONFIGAF_INET6len getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintAF_INETappendAI_NUMERICHOSTAI_NUMERICSERV) rrrrinfoshosts_raddressr_portrrrresolves>       zThreadedResolver.resolvecsdSrrrrrrcloseJszThreadedResolver.closerrN)__name__ __module__ __qualname____doc__rasyncioAbstractEventLooprr!r*strr)rrrr3r5rrrrr 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 r DNSResolver _resolverhasattr_resolve_with_queryr3)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) rDr@rAerrorDNSErrorr%r>OSError addressesr+r!r,r-) rrrrrespexcmsgr/r1rrrr3as,    zAsyncResolver.resolvec s|tjkr d}nd}z |j||IdH}Wn!tjjy8}zt|jdkr-|jdnd}t ||d}~wwg}|D]} | || j ||dtj dq=|sTt d|S)NAAAAArrGrr) r!r$rDqueryrArHrIr%r>rJr+rr,) rrrrqtyperLrMrNr/rrrrrrF{s2   z!AsyncResolver._resolve_with_querycs|jdSr)rDcancelr4rrrr5szAsyncResolver.closerr6)r7r8r9r:rr;r<rrr!r*r=r)rrr3rFr5rrrrr NsB    r r )r;r!typingrrrrrrabcr helpersr __all__rA ImportErroraiodns_defaultr r _DefaultTyper __annotations__rrrrs      :Q