Ë
|
¸^iA( ã ó¾ U d dl Z d dlZd dlZd dlmZmZmZmZmZm Z m
|
Z
|
m Z ddl m Z mZ dZ d dlZ eej$ d« Zej* ej, z Zej0 ej2 z Zej6 Z eed« re ej: z Z G d d
|
e « Z G d d e « Z G d d« Z e
|
e e e f Z!ere ne Z"e!e#d< y# e$ r dZdZY w xY w)é N)ÚAnyÚDictÚFinalÚListÚOptionalÚTupleÚTypeÚUnioné )ÚAbstractResolverÚ ResolveResult)ÚThreadedResolverÚ AsyncResolverÚDefaultResolverÚ getaddrinfoFÚAI_MASKc
|
ó e Zd ZdZd deej ddfdZdej fde
|
de d ej de e fd
|
Zd d Zy)r zThreaded resolver.
|
|
Uses an Executor for synchronous getaddrinfo() calls.
|
concurrent.futures.ThreadPoolExecutor is used by default.
|
NÚloopÚreturnc ó> |xs t j « | _ y ©N)ÚasyncioÚget_running_loopÚ_loop)Úselfr s õc H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/resolver.pyÚ__init__zThreadedResolver.__init__" s ØÒ7W× 5Ñ 5Ó 7
|
ó r ÚhostÚportÚfamilyc óò K | j j ||t j |t ¬« d { }g }|D ] \ }}}}}|t j
|
k( rTt |« dk r+|d r7| j j |t « d { \ } }
|
t |
|
« }n#|d d \ } }n|t j k( sJ |\ } }|j t || |||t ¬« « ¯ |S 7 º7 `w)N)Útyper! Úflagsé é ©Úhostnamer r r! Úprotor$ )r r ÚsocketÚ SOCK_STREAMÚ_AI_ADDRCONFIGÚAF_INET6ÚlenÚ getnameinfoÚ_NAME_SOCKET_FLAGSÚintÚAF_INETÚappendr Ú_NUMERIC_SOCKET_FLAGS) r r r r! ÚinfosÚhostsÚ_r) ÚaddressÚ resolved_hostÚ_ports r ÚresolvezThreadedResolver.resolve% s è ø ð jj×,Ñ,Ø Ø Ü×#Ñ#ØÜ ð -ó
|
÷
|
ð &(Ø,1ò Ñ (FAua Ø Ò(Üw< !Ò#ð Ø1:ð 26·±×1GÑ1GØ Ô!3ó2÷ ,Ñ(M 5ô u:Dà*1°"°1¨+Ñ'M¡4à ¤§ ¡ Ò/Ð/Ð/Ø&-Ñ# tØ LLÜ Ø !Ø&Ø Ø!Ø Ü/ô õ ð' ð< ðO
|
øð&,ús# 6C7¸C3¹AC7ÂC5ÂA C7Ã5C7c ó K y wr © ©r s r ÚclosezThreadedResolver.closeQ s è ø Ø ùs r ©r N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r ÚAbstractEventLoopr r* r2 Ústrr1 Ú AddressFamilyr r r; r? r= r r r r sf ññ 8X g×&?Ñ&?Ñ @ð 8ÈDó 8ð &'ÀvÇ~Á~ñ*Øð*Ø "ð*Ø06×0DÑ0Dð*à mÑ ó*ôX r r c óÜ e Zd ZdZ ddeej dededdfdZde j fd e d
|
e d e j dee fd Zde j fd e d
|
e d e deee ef fd ZddZy)r z9Use the `aiodns` package to make asynchronous DNS lookupsNr ÚargsÚkwargsr c óp t t d« |xs t j « | _ d | _ |s|rt j |i |¤| _ y t « | _ | j
|
j | | j « | _ t | j d« s| j | _ y y )Nz Resolver requires aiodns libraryÚ gethostbyname) ÚaiodnsÚ RuntimeErrorr r r Ú_managerÚ DNSResolverÚ _resolverÚ_DNSResolverManagerÚ get_resolverÚhasattrÚ_resolve_with_queryr; )r r rI rJ s r r zAsyncResolver.__init__X s ô >Ü Ð AÓBÐ BàÒ7W× 5Ñ 5Ó 7
|
Ø7; ñ 6Ü #× /Ñ /°Ð @¸Ñ @DNØ ä+Ó- Ø ×3Ñ3°D¸$¿*¹*ÓEät~~ Ô7à ×3Ñ3DLð 8r r r r r! c óv K | j j ||t j |t ¬« d { }g }|j D ]ú }|j } |j }|t j k( r{t | « dkD rS| d rN| j j | d j! d« g| dd ¢t" « d { }
|
|
|
j$ } nH| d j! d« } | d }n.|t j& k( sJ | d j! d« } | d }|j) t+ || ||dt, ¬« « ü |s t d d« |S 7 # t
|
j j $ r;}t |j « dk\ r|j d nd}t d |« |d }~ww xY w7 íw)N)r r# r! r$ r úDNS lookup failedr% r Úasciir' )rQ r r* r+ r, rM ÚerrorÚDNSErrorr. rI ÚOSErrorÚnodesÚaddrr! r- r/ Údecoder0 Únoder2 r3 r r4 ) r r r r! ÚrespÚexcÚmsgr6 r_ r8 Úresultr9 s r r; zAsyncResolver.resolveq s° è ø ð
|
.Ø ×3Ñ3ØØÜ×'Ñ'Ø Ü$ð 4ó ÷ Dð &(ØJJò DØMQÏYÉYGØ[[FØ Ò(Üw< !Ò#¨°ª
|
ð $(§>¡>×#=Ñ#=Ø ×*Ñ*¨7Ó3ÐB°g¸a¸b°kÑBÜ*ó$÷ Fð %+§K¡KMà$+¨A¡J×$5Ñ$5°gÓ$>MØ" 1:Dà ¤§ ¡ Ò/Ð/Ð/Ø '¨¡
|
× 1Ñ 1°'Ó : Ø qzØ LLÜ Ø !Ø&Ø Ø!ØÜ/ô õ ð) ñ> Ü$Ð 3Ó4Ð 4à ð[úô ||×$Ñ$ò .Ü!$ S§X¡X£ °!Ò!3#((1+Ð9LCÜ$ Ó$¨#Ð -ûð .úð úsE F95E ¹EºE ¾B F9Ã F7Ã
|
BF9ÅE Å F4Å96F/Æ/F4Æ4F9c
|
óÎ K |t j k( rdnd} | j j ||« d { }g }|D ]2 } |j || j ||dt j d« 4 |s t d d« |S 7 M# t j
|
j $ r;}t |j « dk\ r|j d nd}t d |« |d }~ww xY ww)NÚAAAAÚAr rW r r' ) r* r- rQ ÚqueryrM rY rZ r. rI r[ r3 r ÚAI_NUMERICHOST)
|
r r r r! Úqtyper` ra rb r6 Úrrs
|
r rU z!AsyncResolver._resolve_with_query¤ sß è ø ð "(¬6¯?©?Ò!:vÀð .Ø ×-Ñ-¨d°EÓ:×:Dð
|
Øò
|
BØ LLà $Ø GGØ Ø $Ø Ü #× 2Ñ 2ñ õ ð
|
ñ Ü$Ð 3Ó4Ð 4à ð+ ;ùÜ||×$Ñ$ò .Ü!$ S§X¡X£ °!Ò!3#((1+Ð9LCÜ$ Ó$¨#Ð -ûð .üs8 C% B
|
ºB»B
|
¿A C%ÂB
|
Â
|
C"Â'6C Ã C"Ã"C%c óè K | j r5| j j | | j « d | _ d | _ y | j | j j « d | _ y wr )rO Úrelease_resolverr rQ Úcancelr> s r r? zAsyncResolver.closeÁ sW è ø Ø ==à MM× *Ñ *¨4°·±Ô <Ø DMØ !DNØ à >>Ð %Ø NN× !Ñ !Ô #Ø ùs A0A2r r@ )rA rB rC rD r r rE r r r* r2 rF r1 rG r r r; r rU r? r= r r r r U s¾ ÙCð 59ñ4àw×0Ñ0Ñ1ð4ð ð4ð ð 4ð
|
|
ó 4ð4 &'ÀvÇ~Á~ñ1Øð1Ø "ð1Ø06×0DÑ0Dð1à mÑ ó1ðh &'°f·n±nñØðØ "ðØ03ðà d38nÑ óô:
|
r r c ó e Zd ZU dZdZed ed< d fd ZddZddd e j dd
|
fd Z ddd e j ddfd Z xZ S )rR z£Manager for aiodns.DNSResolver objects.
|
|
This class manages shared aiodns.DNSResolver instances
|
with no custom arguments across different event loops.
|
NÚ _instancer c ó | j .t | | « | _ | j j « | j S r )ro ÚsuperÚ__new__Ú_init)ÚclsÚ __class__s r rr z_DNSResolverManager.__new__× s7 ø Ø ==Ð Ü !GO¨CÓ 0CMØ MM× Ñ Ô !Ø}}Ð r c ó6 t j « | _ y r )ÚweakrefÚWeakKeyDictionaryÚ
|
_loop_datar> s r rs z_DNSResolverManager._initÝ s ô
|
× %Ñ %Ó 'ð r Úclientr r zaiodns.DNSResolverc óà || j vr<t j |¬« }t j « }||f| j |< n| j | \ }}|j |« |S )a& Get or create the shared aiodns.DNSResolver instance for a specific event loop.
|
|
Args:
|
client: The AsyncResolver instance requesting the resolver.
|
This is required to track resolver usage.
|
loop: The event loop to use for the resolver.
|
)r )ry rM rP rw ÚWeakSetÚadd)r rz r ÚresolverÚ
|
client_sets r rS z _DNSResolverManager.get_resolverä sg ð tÑ &Ü ×)Ñ)¨tÔ4HÜ;B¿?¹?Ó;LJØ%-¨zÐ$:DOODÒ !ð $(§?¡?°4Ñ#8Ñ Hjð vÔ Ør c ó° | j j |« }|y|\ }}|j |« |s ||j « | j |= yy)zÎRelease the resolver for an AsyncResolver client when it's closed.
|
|
Args:
|
client: The AsyncResolver instance to release.
|
loop: The event loop the resolver was using.
|
N)ry ÚgetÚdiscardrm )r rz r Úcurrent_loop_datar~ r s r rl z$_DNSResolverManager.release_resolverû s^ ð !OO× /Ñ /°Ó 5ÐØ Ð $Ø Ø 0Ñ *Ø×Ñ6Ô"áØÐ#ØÔ!Ø Ñ%ð r )r rR r@ )rA rB rC rD ro r Ú__annotations__rr rs r rE rS rl Ú __classcell__)ru s @r rR rR Î sj ø
ñð 26IxÐ-Ñ.Ó5õ ó (ðØ%ðØ-4×-FÑ-Fðà óð.&Ø%ð&Ø-4×-FÑ-Fð&à ÷&r rR r )$r r* rw Útypingr r r r r r r r
|
Úabcr r Ú__all__rM rT rP Úaiodns_defaultÚ ImportErrorrh ÚAI_NUMERICSERVr4 ÚNI_NUMERICHOSTÚNI_NUMERICSERVr0 Ú AI_ADDRCONFIGr, r r r rR Ú _DefaultTyper r r= r r ú<module>r sù ðÜ Û Û ß G× GÓ Gç 0à
|
BðÛá V× /Ñ /° Ó?Nð ×-Ñ-°×0EÑ0EÑEÐ Ø×*Ñ*¨V×-BÑ-BÑBÐ Ø×%Ñ%Ù
|
69Ô ØfnnÑ$Nô7 Ð'ô 7 ôtv Ð$ô v ÷r@&ñ @&ðF E-Ð)9Ð9Ñ:Ñ; Ù1?¡ ÐEU Ô UøðG ò Ø FØNðús C Ã C ÃC
|
