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 Z getaddrinfosocketZ SOCK_STREAMZ
AI_ADDRCONFIGAF_INET6Z getnameinfoZNI_NUMERICHOSTZNI_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' r* 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 r3 r4 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 )
r8 r5 r6 errorDNSErrorlenr3 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 r; r r )
r r r8 Zqueryr6 r< r= r> r3 r? r! r r" )
r r r r Zqtyper@ rA rB r$ Zrrr r r r: q s,
z!AsyncResolver._resolve_with_queryr( c s
| j S r )r8 Zcancelr) r r r r* s zAsyncResolver.close)N)r+ r, r- r. r r/ r0 r r r r1 r2 r r r r' r: r* r r r r r
D s2 r
)r/ r typingr r r r abcr Zhelpersr __all__r6 ImportErrorZaiodns_defaultr r
r r r r r <module> s
0Q