i/'UddlZddlZddlZddlmZmZmZmZmZm Z m Z m Z ddl m Z mZdZ ddlZeejdZn#e$rdZdZYnwxYwejejzZejejzZejZeedr eejzZGd d e ZGd d e ZGd dZ e e eefZ!ereneZ"e!e#d<dS)N)AnyDictFinalListOptionalTupleTypeUnion)AbstractResolver ResolveResult)ThreadedResolver AsyncResolverDefaultResolver getaddrinfoFAI_MASKc eZdZdZd deejddfdZdej fde de d ej de efd Zd d ZdS)rzThreaded resolver. Uses an Executor for synchronous getaddrinfo() calls. concurrent.futures.ThreadPoolExecutor is used by default. Nloopreturnc:|ptj|_dSN)asyncioget_running_loop_loop)selfrs U/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/aiohttp/resolver.py__init__zThreadedResolver.__init__"s7W577 rhostportfamilyc K|j||tj|td{V}g}|D]\}}}}}|tjkrct |dkr,|dr9|j|td{V\} } t| }n%|dd\} }n|tj ksJ|\} }| t|| |||t|S)N)typer!flagshostnamerr r!protor$)rrsocket SOCK_STREAM_AI_ADDRCONFIGAF_INET6len getnameinfo_NAME_SOCKET_FLAGSintAF_INETappendr _NUMERIC_SOCKET_FLAGS) rrr r!infoshosts_r)address resolved_host_ports rresolvezThreadedResolver.resolve%slj,,  # -        &(,1   (FAua((w<ABB B7W577 7;   6 #/@@@DN F+-- 33D$*EEt~77 43DLLL 4 4rrrr r!c K |j||tj|td{V}nT#t jj$r=}t|j dkr |j dnd}td||d}~wwxYwg}|j D]}|j } |j }|tjkrt| dkr[| drS|j| ddg| ddRt"d{V} | j} nY| dd} | d}n5|tjksJ| dd} | d}|t+|| ||dt,|stdd|S)N)r r#r!r$r DNS lookup failedr%rasciir')rQrr*r+r,rMerrorDNSErrorr.rIOSErrornodesaddrr!r-r/decoder0noder2r3r r4) rrr r!respexcmsgr6r_r8resultr9s rr;zAsyncResolver.resolveqs! .33'$ 4DD|$ . . .!$SX!!3!3#(1++9LC$$$# - .&(J  DMQYG[F((w<#=#= **733BgabbkBB*$$F%+KMM$+AJ$5$5g$>$>M"1:DD//// ' 1 1' : : qz LL!&!/      5$ 344 4 s49B  8BB c K|tjkrdnd} |j||d{V}nT#tjj$r=}t|jdkr |jdnd}td||d}~wwxYwg}|D]-} | || j ||dtj d.|stdd|S)NAAAAAr rWrr') r*r-rQqueryrMrYrZr.rIr[r3rAI_NUMERICHOST) rrr r!qtyper`rarbr6rrs rrUz!AsyncResolver._resolve_with_querys"(6?!:!:vv .--dE::::::::DD|$ . . .!$SX!!3!3#(1++9LC$$$# - .  B LL $G $#2      5$ 344 4 s!:B 8BB cK|jr0|j||jd|_d|_dS|j|jd|_dSr)rOrelease_resolverrrQcancelr>s rr?zAsyncResolver.closesd =  M * *4 < < < DM!DN F > % N ! ! # # #rrr@)rArBrCrDrrrErrr*r2rFr1rGrr r;rrUr?r=rrrrUsCC5944w0144 4  44444&'v~111"1060D1 m 1111h&'fn"03 d38n :      rrceZdZUdZdZeded<d fd ZddZddd e j dd fd Z ddd e j ddfd Z xZ S)rRzManager for aiodns.DNSResolver objects. This class manages shared aiodns.DNSResolver instances with no custom arguments across different event loops. N _instancerc|j?t||_|j|jSr)rosuper__new___init)cls __class__s rrrz_DNSResolverManager.__new__s> = !GGOOC00CM M   ! ! !}rc6tj|_dSr)weakrefWeakKeyDictionary _loop_datar>s rrsz_DNSResolverManager._inits  % ' ' rclientrrzaiodns.DNSResolverc||jvr5tj|}tj}||f|j|<n|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)ryrMrPrwWeakSetadd)rrzrresolver client_sets rrSz _DNSResolverManager.get_resolversq t & &)t444H;B?;L;LJ%-z$:DOD ! !$(?4#8 Hj vrc|j|}|dS|\}}|||s |||j|=dSdS)zRelease 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)rygetdiscardrm)rrzrcurrent_loop_datar~rs rrlz$_DNSResolverManager.release_resolvers{!O//55  $ F0*6""" &#!!!%%% & &r)rrRr@)rArBrCrDror__annotations__rrrsrrErSrl __classcell__)rus@rrRrRs 26Ix-.555 ((((%-4-F .&%&-4-F& &&&&&&&&rrRr)$rr*rwtypingrrrrrrr r abcr r __all__rMrTrPaiodns_default ImportErrorrhAI_NUMERICSERVr4NI_NUMERICHOSTNI_NUMERICSERVr0 AI_ADDRCONFIGr,rrrrR _DefaultTyperrr=rrrs GGGGGGGGGGGGGGGGGGGG00000000 BMMMWV/??NN FNNN -0EE*V-BB% 769%fn$N7 7 7 7 7 '7 7 7 tvvvvv$vvvr@&@&@&@&@&@&@&@&FE-)99:; 1? U EUUUUUUsA AA