Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
resolver.cpython-313.pyc66 linesDownload Raw Back to __pycache__
1�

2��jA(����%SSKrSSKrSSKrSSKJrJrJrJrJrJ	r	J3r4Jr SSKJ
r
Jr SrSSKr\"\R$S5r\R*\R,-r\R0\R2-r\R6r\"\S5(a\\R:-r"S	S5\
5r"SS\
5r"S
S5r \6\\\4r!\(a\O\r"\!\#S'g!\a SrSrN�f=f)�N)�Any�Dict�Final�List�Optional�Tuple�Type�Union�)�AbstractResolver�
ResolveResult)�ThreadedResolver�
AsyncResolver�DefaultResolver�getaddrinfoF�AI_MASKc7��\rSrSrSrSS\\RSS4SjjrS\	R4S\S	\S8\	RS\\4SjjrSSjrS
rg)r�z�Threaded resolver.9 10Uses an Executor for synchronous getaddrinfo() calls.11concurrent.futures.ThreadPoolExecutor is used by default.12N�loop�returnc�J�U=(d [R"5Ulg�N)�asyncio�get_running_loop�_loop)�selfrs  �VD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/resolver.py�__init__�ThreadedResolver.__init__"s���7�W�5�5�7��13�r�host�port�familyc���# �URRUU[RU[S9IShv�Nn/nUH�up6pvnU[R14:XaY[
U5S:aM,US(a6URRU[5IShv�Nup�[U155nO"USSup�OU[R:XdeUup�UR[UU	UUU[S95 M� U$N�N]7f)N)�typer#�flags����hostnamer!r"r#�protor&)rr�socket�SOCK_STREAM�_AI_ADDRCONFIG�AF_INET6�len�getnameinfo�_NAME_SOCKET_FLAGS�int�AF_INET�appendr
�_NUMERIC_SOCKET_FLAGS)rr!r"r#�infos�hosts�_r+�address�
resolved_host�_ports           r�resolve�ThreadedResolver.resolve%s����j�j�,�,����#�#�� �-�16�17��&(��,1�(�F�u������(��w�<�!�#���1�:�26���1G�1G��!3�2�,�(�M��u�:�D�*1�"�1�+�'�M�4�����/�/�/�&-�#�
��L�L��!�&��!��/�
�	
�'-2�<��O18�&,�s#�3C7�C3�A!C7�C5�AC7�5C7c��# �g7fr��rs r�close�ThreadedResolver.closeQs����s�)rr�rN)�__name__�19__module__�__qualname__�__firstlineno__�__doc__rr�AbstractEventLooprr,r4�strr3�
AddressFamilyrr
r=rB�__static_attributes__r@r rrrsf���8�X�g�&?�&?�@�8�D�8�&'�v�~�~�*��*�"�*�06�0D�0D�*�	
�m�	�*�X
r rc���\rSrSrSrSS\\RS\S\SS4Sjjr	S	\20R4S21\S\
S\22RS\\4S
jjrS	\23R4S24\S\
S\
S\\\\44SjjrSSjrSrg)r�Uz9Use the `aiodns` package to make asynchronous DNS lookupsNr�args�kwargsrc��[c[S5eU=(d [R"5UlSUlU(dU(a[R"U0UD6Ulg[5UlUR25RXR5Ul[URS5(dURUlgg)Nz Resolver requires aiodns library�
gethostbyname)
�aiodns�RuntimeErrorrrr�_manager�DNSResolver�	_resolver�_DNSResolverManager�get_resolver�hasattr�_resolve_with_queryr=)rrrPrQs    rr�AsyncResolver.__init__Xs����>��A�B�B��7�W�5�5�7��26�7;��
��6�#�/�/��@��@�D�N��+�-��
����3�3�D�*�*�E����t�~�~��7�7��3�3�D�L�8r rr!r"r#c��# �URRUU[RU[S9IShv�Nn/nURGHnURn	URnU[R:Xa�[U	5S:�aXU	S(aNURRU	SR!S5/U	SSQ7["5IShv�Nn27U28R$nOIU	SR!S5nU	SnO/U[R&:XdeU	SR!S5nU	SnUR)[+UUUUS[,S95 GM U(d[SS5eU$GN.![29RRa<n[UR5S:�aURSOSn[SU5UeSnAff=fN�7f)N)r"r%r#r&r�DNS lookup failedr'r�asciir))rXrr,r-r.rT�error�DNSErrorr0rP�OSError�nodes�addrr#r/r1�decoder2�noder4r5r
r6)rr!r"r#�resp�exc�msgr8rgr:�resultr;s            rr=�AsyncResolver.resolveqs����30	.����3�3����'�'��$�4���D�&(���J�J�D�MQ�Y�Y�G��[�[�F�����(��w�<�!�#���31�$(�>�>�#=�#=� ���*�*�7�3�B�g�a�b�k�B�*�$��F�%+�K�K�M�$+�A�J�$5�$5�g�$>�M�"�1�:�D�����/�/�/� '��32� 1� 1�'� :�
��q�z���L�L��!�&��!��/�
�	
�)�>��$� 3�4�4���[���|�|�$�$�	.�!$�S�X�X��!�!3�#�(�(�1�+�9L�C��$��$�#�-��	.���sE�G�2E'�E$�E'�BG�G�BG�$E'�'G�7F<�<G�Gc33���# �U[R:XaSOSnURRX5IShv�Nn/nUH3n	URUU	RUUS[RS.5 M5 U(d[SS5eU$NT![R34Ra<n[UR5S:�aURSOSn[SU5UeSnAff=f7f)N�AAAA�Arr_rr))
r,r/rX�queryrTrarbr0rPrcr5r!�AI_NUMERICHOST)35rr!r"r#�qtyperhrirjr8�rrs36          rr\�!AsyncResolver._resolve_with_query�s����"(�6�?�?�!:�v���	.����-�-�d�:�:�D�37���B��L�L� $��G�G� �$��#�2�2�
�	
����$� 3�4�4���+;���|�|�$�$�	.�!$�S�X�X��!�!3�#�(�(�1�+�9L�C��$��$�#�-��	.�s8�C.�B�B�B�AC.�B�C+�/7C&�&C+�+C.c���# �UR(a4URRXR5 SUlSUlgURbURR	5 SUlg7fr)rV�release_resolverrrX�cancelrAs rrB�AsyncResolver.close�sT����=�=��M�M�*�*�4���<� �D�M�!�D�N���>�>�%��N�N�!�!�#����s�A5A7)rrVrXr=rrD)rErFrGrHrIrrrJrrr,r4rKr3rLrr
r=rr\rBrMr@r rrrUs���C�59�4��w�0�0�1�4��4��	4�3839�4�4&'�v�~�~�1��1�"�1�06�0D�0D�1�	
�m�	�1�h&'�f�n�n����"��03��	
�d�3��8�n�	��:40r rc�^�\rSrSr%SrSr\S\S'SU4SjjrSSjr	SS	S41\42RSS4SjrSS	S43\44RSS4S
jr
SrU=r$)rY��z�Manager for aiodns.DNSResolver objects.45 46This class manages shared aiodns.DNSResolver instances47with no custom arguments across different event loops.48N�	_instancerc�>�URc.[TU]	U5UlURR5 UR$r)r{�super�__new__�_init)�cls�	__class__s �rr~�_DNSResolverManager.__new__�s7����=�=� �!�G�O�C�0�C�M��M�M���!��}�}�r c�8�[R"5Ulgr)�weakref�WeakKeyDictionary�49_loop_datarAs rr�_DNSResolverManager._init�s��50
�%�%�'�	
�r �clientrrzaiodns.DNSResolverc���X R;a:[R"US9n[R"5nX44URU'OURUup4URU5 U$)z�Get or create the shared aiodns.DNSResolver instance for a specific event loop.51 52Args:53    client: The AsyncResolver instance requesting the resolver.54           This is required to track resolver usage.55    loop: The event loop to use for the resolver.56)r)r�rTrWr��WeakSet�add)rr�r�resolver�57client_sets     rrZ� _DNSResolverManager.get_resolver�sa�����&��)�)�t�4�H�;B�?�?�;L�J�%-�$:�D�O�O�D�!�$(�?�?�4�#8� �H�	���v���r c��URRU5nUcgUupEURU5 U(d!UbUR5 URU	gg)z�Release the resolver for an AsyncResolver client when it's closed.58 59Args:60    client: The AsyncResolver instance to release.61    loop: The event loop the resolver was using.62N)r��get�discardrw)rr�r�current_loop_datar�r�s      rrv�$_DNSResolverManager.release_resolver�s\��!�O�O�/�/��5���$��0������6�"���#����!�����%�r )r�)rrYrD)rErFrGrHrIr{r�__annotations__r~rrrJrZrvrM�
__classcell__)r�s@rrYrY�so����26�I�x�-�.�5��(��%��-4�-F�-F��	��.&�%�&�-4�-F�-F�&�	
�&�&r rYr)$rr,r��typingrrrrrrr	r63�abcrr
�__all__rTr[rW�aiodns_default�ImportErrorrq�AI_NUMERICSERVr6�NI_NUMERICHOST�NI_NUMERICSERVr2�
AI_ADDRCONFIGr.rrrrY�_DefaultTyperr�r@r r�<module>r�s����
��G�G�G�0�64B�����V�/�/��?�N��-�-��0E�0E�E���*�*�V�-B�-B�B���%�%��65�6�9����f�n�n�$�N�7
�'�7
�tv�$�v�r@&�@&�F�E�-�)9�9�:�;��1?�
�EU���U��G��
�F��N��s�C�66C'�&C'
codekingpro/portable-devtools · Team Ai