U
'7` @ s d dl Z d dlZd dlmZmZmZmZ ddlmZ ddl m
Z
dZ z d dl Z W n e
k
rh dZ Y nX dZG dd d eZG d
d d eZereneZdS ) N)AnyDictListOptional )AbstractResolver)get_running_loop)ThreadedResolver
AsyncResolverDefaultResolverFc @ s^ e Zd ZdZd
eej ddddZdej fe
e e e e
e
ef ddd Zdd
d d ZdS )r zsUse Executor for synchronous getaddrinfo() calls, which defaults to
concurrent.futures.ThreadPoolExecutor.
N)loopreturnc C s t || _d S N)r _loop)selfr r C/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/resolver.py__init__ s zThreadedResolver.__init__r )hostnameportfamilyr
c
s | j j||tj|tjdI d H }g }|D ]r\}}}}}|tjkrj|d rjt|tjtjB \} }
t |
}n|d d \} }|
|| |||tj tj B d q(|S )N)typer flags r hostr r protor )
r getaddrinfosocket SOCK_STREAM
AI_ADDRCONFIGAF_INET6 getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintappendAI_NUMERICHOSTAI_NUMERICSERV) r r r r Zinfoshosts_r addressr Z_portr r r resolve s4
zThreadedResolver.resolver
c s d S r r r r r r close@ s zThreadedResolver.close)N)__name__
__module__ __qualname____doc__r asyncioAbstractEventLoopr r AF_INETstrr& r r r r- r0 r r r r r s $r c @ s e Zd ZdZdeej eeddddZde j
fe e e e
ee ef ddd Zde j
fe e e e
ee ef dd
d Zdd d
dZdS )r
z9Use the `aiodns` package to make asynchronous DNS lookupsN)r argskwargsr
c O sH t d krtdt|| _t j|d|i|| _t| jdsD| j| _d S )Nz Resolver requires aiodns libraryr
gethostbyname) aiodns RuntimeErrorr r Z DNSResolver _resolverhasattr_resolve_with_queryr- )r r r9 r: r r r r G s
zAsyncResolver.__init__r )r r r r
c
s z| j ||I d H }W nL tjjk
rd } z*t|jdkrF|jd nd}t||W 5 d }~X Y nX g }|jD ]$}| ||||dt
j t
j B d qp|std|S )Nr DNS lookup failedr r )
r> r; r< errorDNSErrorlenr9 OSErrorZ addressesr' r r( r) ) r r r r respexcmsgr* r, r r r r- W s&
zAsyncResolver.resolvec
s |t jkrd}nd}z| j||I d H }W nL tjjk
rx } z*t|jdkrZ|jd nd}t ||W 5 d }~X Y nX g }|D ] } |
|| j ||dt j d q|st d|S )NZAAAAAr rA r r )
r r" r> queryr< rB rC rD r9 rE r' r r( )
r r r r ZqtyperF rG rH r* Zrrr r r r@ q s,
z!AsyncResolver._resolve_with_queryr. c s
| j S r )r> cancelr/ r r r r0 s zAsyncResolver.close)N)r1 r2 r3 r4 r r5 r6 r r r r7 r8 r& r r r- r@ r0 r r r r r
D s2 r
)r5 r typingr r r r abcr Zhelpersr __all__r< ImportErrorZaiodns_defaultr r
r r r r r