$kR U d dl Z d dlZd dlmZmZmZmZmZmZ ddl m
Z
ddl m Z dZ
d dlZn
# e$ r dZY nw xY wdZ G d d e
Z G d
d e
Zeeeef ZereneZeed < dS )
N)AnyDictListOptionalTypeUnion )AbstractResolver)get_running_loop)ThreadedResolver
AsyncResolverDefaultResolverFc e Zd ZdZd deej ddfdZdej fde
de d e de e
e
ef fd
Zd
d ZdS )r zThreaded resolver.
Uses an Executor for synchronous getaddrinfo() calls.
concurrent.futures.ThreadPoolExecutor is used by default.
Nloopreturnc . t | | _ d S N)r _loop)selfr s r/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib64/python3.11/site-packages/aiohttp/resolver.py__init__zThreadedResolver.__init__ s %d++
r hostnameportfamilyc
K | j ||t j |t j d {V }g }|D ]\ }}}}}|t j k rit
| dk r,|d r?t j |t j t j z \ } }
t |
}n%|d d \ } }n|t j k sJ |\ } }| || |||t j
t j z d |S )N)typer flags r hostr r protor )r getaddrinfosocket SOCK_STREAM
AI_ADDRCONFIGAF_INET6len getnameinfoNI_NUMERICHOSTNI_NUMERICSERVintAF_INETappendAI_NUMERICHOSTAI_NUMERICSERV) r r r r infoshosts_r# addressr" _ports r resolvezThreadedResolver.resolve sV j,, #& -
,1 (FAua ((w< ABB B%d++
+TGGGGt~77 4 3DLLL 4 4r r r" r r c
K | j || d {V }nS# t j j $ r<}t |j dk r
|j d nd}t | |d }~ww xY wg }|j D ]5}| ||||dt j t j z d 6|st d |S )Nr DNS lookup failedr r! )
rL rH rI errorDNSErrorr) rE OSError addressesr/ r% r0 r1 ) r r" r r respexcmsgr3 r5 s r r7 zAsyncResolver.resolvea s ( 55dFCCCCCCCCDD|$ ( ( (!$SX !!3!3#(1++9LC#,,C ' ( ~
G LL $ # $ # 2V5J J
/-.. . s !& A67A11A6c
K |t j k rd}nd} | j || d {V }nS# t j j $ r<}t |j dk r
|j d nd}t | |d }~ww xY wg }|D ]-} |
|| j ||dt j d .|st d |S )NAAAAAr rP r r! )
r% r( rL queryrI rQ rR r) rE rS r/ r" r0 )
r r" r r qtyperU rV rW r3 rrs
r rN z!AsyncResolver._resolve_with_query{ s V_ $ $EEE ( --dE::::::::DD|$ ( ( (!$SX !!3!3#(1++9LC#,,C ' (
B LL $ G $ # 2
/-.. . s !; B 7BB c < K | j d S r )rL cancelr: s r r; zAsyncResolver.close s r r r< )r= r> r? r@ r rA rB r r r% r. rC r- r r r7 rN r; r9 r r r
r
N s CC 594 4w014 4 4
4 4 4 4" &'fn "03
d38n 6 &'fn " 03
d38n @ r r
r )rA r% typingr r r r r r abcr
helpersr __all__rI ImportErroraiodns_defaultr r
_DefaultTyper __annotations__r9 r r rh sF
9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 ! ! ! ! ! ! % % % % % %
BMMMM
FFF 7
7
7
7
7
' 7
7
7
tN N N N N $ N N N b E-)99:; 1? U
EU U U U U Us . 88