q|ZYZ
L d dl Z d dlZd dlZd dlZd dlmZmZmZmZ ddl m
Z
dZ dZ dZ
dZej ej ej ej ej ej ej ej ej ej ej ej d Zej ej ej ej ej d Z! G d
d Z"dS ) N)AnyListOptionalSet )errorz3.0.0) DNSResolverr ) AAAAAANYCAACNAMEMXNAPTRNSPTRSOASRVTXT)INCHAOSHSNONEr
c e Zd Z d deee deej deddfdZ e
de j fd Z
e
j dee ddfd Z
ed
ej d ed eddfd
Zd dedededej fdZdedej dej fdZdedej fdZd dZdedededdfdZdededdfd Zd d Z dS )!r N nameserversloopkwargsreturnc |pt j | _ | j J | dd t j dd| j i|| _ |r|| _ t | _
t | _ d | _ d S )N
sock_state_cb )
asyncioget_event_loopr poppycaresChannel_sock_state_cb_channelr set _read_fds
_write_fds_timer)selfr r r s o/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/aiodns/__init__.py__init__zDNSResolver.__init__/ s 4G 2 4 4 y$$$
?D))) TTd6ITVTT
+ *D %% c | j j S Nr) serversr. s r/ r zDNSResolver.nameservers< s
}$$r1 valuec || j _ d S r3 r4 )r. r7 s r/ r zDNSResolver.nameservers@ s %
r1 futresulterrornoc | rd S |G| t j |t j | d S | | d S r3 ) cancelled
set_exceptionr DNSErrorr& errnostrerror
set_result)r9 r: r; s r/ _callbackzDNSResolver._callbackD sk ==?? F enWgm6L6LW6U6U V V W W W W W NN6 " " " " "r1 hostqtypeqclassc t | }n0# t $ r# t d | w xY w|? t | }n0# t $ r# t d | w xY wt j | j }t j | j
| }| j |||| |S )Nzinvalid query type: {}zinvalid query class: {}r ) query_class)
query_type_mapKeyError
ValueErrorformatquery_class_mapr# Futurer functoolspartialrC r) query)r. rD rE rF r9 cbs r/ rR zDNSResolver.queryM s E"5)EE E E E 5 < familyc t j | j }t j | j | }| j ||| |S NrH )r# rO r rP rQ rC r)
gethostbyname)r. rD rT r9 rS s r/ rW zDNSResolver.gethostbyname] sI n$),,,
t~s
3
3
##D&"555
r1 namec t j | j }t j | j | }| j || |S rV )r# rO r rP rQ rC r)
gethostbyaddr)r. rX r9 rS s r/ rZ zDNSResolver.gethostbyaddrc sG n$),,,
t~s
3
3
##D"---
r1 c 8 | j d S r3 )r) cancelr6 s r/ r\ zDNSResolver.canceli s
r1 fdreadablewritablec |s|r|rA| j || j |t | j | |rA| j || j |t | j | | j '| j
d| j | _ d S d S || j v r4| j | | j
| || j v r4| j | | j | | j s0| j s+| j &| j d | _ d S d S d S d S Ng ?)r
add_reader
_handle_eventREADr+ add
add_writerWRITEr, r-
call_later _timer_cbdiscard
remove_reader
remove_writerr\ )r. r] r^ r_ s r/ r( zDNSResolver._sock_state_cbl s #x #
' $$R);RFFF""2&&&
( $$R);RGGG##B'''{" "i 2 23 G G #" T^##&&r*** ''+++T_$$''+++ ''+++>
#$/
#dk>U ""$$$ "
#
#
#
#>U>Ur1 eventc t j }t j }|t k r|}n
|t k r|}| j || d S r3 )r& ARES_SOCKET_BADrd rg r)
process_fd)r. r] rm read_fdwrite_fds r/ rc zDNSResolver._handle_event sN )* D==GG
e^^H
(33333r1 c | j s| j rV| j t j t j | j d| j | _ d S d | _ d S ra )
r+ r, r) rp r& ro r rh ri r- r6 s r/ ri zDNSResolver._timer_cb s] > T_ M $ $W%U V V V )..sDNCCDKKK DKKKr1 )NNr3 )r N) __name__
__module__ __qualname__r r strr# AbstractEventLoopr r0 propertyr& r' r setter staticmethodrO intrC rR socket
AddressFamilyrW rZ r\ boolr( rc ri r" r1 r/ r r . s
:>=A HT#Y$7 9: #' %W_ % % % X% &c &t & & & & #w~ #s #S #T # # # \# # c 3 # v/C # '. # # # # # # # #04 4C 4D 4 4 4 4 r1 r )#r# rP r& r} typingr r r r r __version____all__rd rg QUERY_TYPE_AQUERY_TYPE_AAAAQUERY_TYPE_ANYQUERY_TYPE_CAAQUERY_TYPE_CNAME
QUERY_TYPE_MXQUERY_TYPE_NAPTR
QUERY_TYPE_NSQUERY_TYPE_PTRQUERY_TYPE_SOAQUERY_TYPE_SRVQUERY_TYPE_TXTrJ QUERY_CLASS_INQUERY_CLASS_CHAOSQUERY_CLASS_HSQUERY_CLASS_NONEQUERY_CLASS_ANYrN r r" r1 r/ r sP
" # 0 # 3 # 2 # 2 # 4 # 1 # 4 # 1 # 2 # 2 # 2 # 2
% 3 $ 6 $ 3 $ 5 $ 4 d d d d d d d d d d r1