Viewing File: /opt/hc_python/lib/python3.12/site-packages/dns/__pycache__/_asyncio_backend.cpython-312.pyc

�

`��g[#��h�dZddlZddlZddlZddlZddlZddlZddlZejdk(Z
d�ZGd�d�Zd�Z
Gd�d	ejj�ZGd
�dejj �Zej"j%d�rgddlZddlZddlZddlZej.Zej2j&j4Zdd
lmZmZmZGd�de�Z Gd�dejB�Z"nejjFZ"Gd�dejjH�Z$y)zasyncio library query support�N�win32c�r�	tj�S#t$rtj�cYSwxYw�N)�asyncio�get_running_loop�AttributeError�get_event_loop���C/opt/hc_python/lib/python3.12/site-packages/dns/_asyncio_backend.py�_get_running_loopr
s4��(��'�'�)�)���(��%�%�'�'�(�s��6�6c�0�eZdZd�Zd�Zd�Zd�Zd�Zd�Zy)�_DatagramProtocolc� �d|_d|_yr)�	transport�recvfrom��selfs r�__init__z_DatagramProtocol.__init__s�������
rc��||_yr)r)rrs  r�connection_madez!_DatagramProtocol.connection_mades	��"��rc��|jr9|jj�s|jj||f�yyyr)r�done�
set_result)r�data�addrs   r�datagram_receivedz#_DatagramProtocol.datagram_received s5���=�=����!3�!3�!5��M�M�$�$�d�D�\�2�"6�=rc��|jr7|jj�s|jj|�yyyr)rr�
set_exception)r�excs  r�error_receivedz _DatagramProtocol.error_received$s1���=�=����!3�!3�!5��M�M�'�'��,�"6�=rc��|jrE|jj�s*|�	td��|jj|�yyy#t$r%}|jj|�Yd}~yd}~wwxYw)N�EOF)rr�EOFErrorr)rr �es   r�connection_lostz!_DatagramProtocol.connection_lost(sn���=�=����!3�!3�!5��{�3�"�5�/�)��
�
�+�+�C�0�"6�=��
 �3��M�M�/�/��2�2��3�s�A�	B�A<�<Bc�8�|jj�yr)r�closers rr(z_DatagramProtocol.close3s�������rN)	�__name__�
__module__�__qualname__rrrr!r&r(r
rrrrs ���#�3�-�	1�rrc���K�|�	tj||��d{���S|�d{���S7�#tj$r!tjj|���wxYw7�=�w)N)�timeout)r�wait_for�TimeoutError�dns�	exception�Timeout)�	awaitabler-s  r�_maybe_wait_forr47sh������	9� �)�)�)�W�=�=�=����	>���#�#�	9��-�-�'�'��'�8�8�	9���s/�A)�0�.�0�A)�A'�A)�0�4A$�$A)c�B��eZdZ�fd�Zd�Zd�Zd�Zd�Zd�Zd�Z	�xZ
S)�DatagramSocketc�^��t�|�|tj�||_||_yr)�superr�socket�
SOCK_DGRAMr�protocol)r�familyrr;�	__class__s    �rrzDatagramSocket.__init__Bs&���
�����!2�!2�3�"��� ��
rc��XK�|jj||�t|�S�wr)r�sendto�len)r�what�destinationr-s    rr?zDatagramSocket.sendtoGs$���������d�K�0��4�y��s�(*c��(K�t�j�}	|jj�J�||j_t	||��d{���|j�d|j_S7�%#d|j_wxYw�wr)r
�
create_futurer;rr4�result)r�sizer-rs    rrzDatagramSocket.recvfromLsw���� �"�0�0�2��	*��=�=�)�)�1�1�1�%)�D�M�M�"�!�$��0�0�0��;�;�=�%)�D�M�M�"�
1��&*�D�M�M�"�s.�B�8A<�A:�A<�(B�:A<�<B�Bc��@K�|jj�y�wr)r;r(rs rr(zDatagramSocket.closeWs�����
�
������c��@K�|jjd�S�w�N�peername�r�get_extra_infors r�getpeernamezDatagramSocket.getpeernameZ������~�~�,�,�Z�8�8�rHc��@K�|jjd�S�w�N�socknamerLrs r�getsocknamezDatagramSocket.getsockname]rOrHc��K�t��wr��NotImplementedError�rr-s  r�getpeercertzDatagramSocket.getpeercert`s����!�!���	)r)r*r+rr?rr(rNrSrX�
__classcell__�r=s@rr6r6As&���!�
�
	*��9�9�"rr6c�B��eZdZ�fd�Zd�Zd�Zd�Zd�Zd�Zd�Z	�xZ
S)�StreamSocketc�^��t�|�|tj�||_||_yr)r8rr9�SOCK_STREAM�reader�writer)r�afr`rar=s    �rrzStreamSocket.__init__es&���
����V�/�/�0������rc��K�|jj|�t|jj�|��d{���S7��wr)ra�writer4�drain)rrAr-s   r�sendallzStreamSocket.sendalljs8���������$��$�T�[�[�%6�%6�%8�'�B�B�B�B�s�AA�A
�Ac��hK�t|jj|�|��d{���S7��wr)r4r`�read)rrFr-s   r�recvzStreamSocket.recvns(����$�T�[�[�%5�%5�d�%;�W�E�E�E�E�s�)2�0�2c��@K�|jj�y�wr)rar(rs rr(zStreamSocket.closeqs����������rHc��@K�|jjd�S�wrJ�rarMrs rrNzStreamSocket.getpeernamet������{�{�)�)�*�5�5�rHc��@K�|jjd�S�wrQrlrs rrSzStreamSocket.getsocknamewrmrHc��@K�|jjd�S�w)N�peercertrlrWs  rrXzStreamSocket.getpeercertzrmrH)r)r*r+rrfrir(rNrSrXrZr[s@rr]r]ds(����
C�F��6�6�6rr]�doh)�_compute_times�_expiration_for_this_attempt�
_remainingc�8��eZdZ�fd�Z	dd�Z	dd�Zd�Z�xZS)�_NetworkBackendc�z��t�|��||_||_||_||_|dk7rt
d��y)Nrz9the asyncio transport for HTTPX cannot set the local port)r8r�_local_port�	_resolver�_bootstrap_address�_familyrV)r�resolver�
local_port�bootstrap_addressr<r=s     �rrz_NetworkBackend.__init__�sH����G���)�D��%�D�N�&7�D�#�!�D�L��Q��)�O���rc���K�g}t|�\}}tjj|�r|j	|�n�|j
�|j	|j
�nnt
|�}|j}	|rtjj|�}	|jj||	|���d{���}
|
j�}|D]d}	td|�}t
|�}tj|�5tj|||���d{���}
ddd�t!
�cSt$j&�7��7�,#1swY�+xYw#t"$rY��wxYw�w)N)r<�lifetimeg@)�remote_host�remote_port�
local_host)rrr0�inet�
is_address�appendrzrtr{�af_for_addressry�resolve_name�	addressesrs�anyio�
fail_after�connect_tcp�_CoreAnyIOStream�	Exception�httpcore�ConnectError)r�host�portr-�
local_address�socket_optionsr��_�
expirationr<�answers�address�attempt_expiration�streams              rr�z_NetworkBackend.connect_tcp�sT�����I�*�7�3�M�A�z��x�x�"�"�4�(�� � ��&��(�(�4�� � ��!8�!8�9�$�Z�0������ � �X�X�4�4�]�C�F� $��� ;� ;���'�!<�!���$�-�-�/�	�$���)E�c�:�)V�&�(�);�<�G��)�)�'�2�',�'8�'8�(/�(,�'4�(�"��3�,�F�3�3�%��'�'�'�#��"��3�2��!����s`�CE2�E�E2� ,E#�E�(E�)E�-E#�?E2�E�E 	�E#�#	E/�,E2�.E/�/E2c��K�t��wrrU)r�pathr-r�s    r�connect_unix_socketz#_NetworkBackend.connect_unix_socket�s����&�%�rYc��JK�tj|��d{���y7��wr)r��sleep)r�secondss  rr�z_NetworkBackend.sleep�s�����+�+�g�&�&�&���#�!�#r)r)r*r+rr�r�r�rZr[s@rrvrv�s$���		�FJ�	(�D15�	&�
	'rrvc�>��eZdZdddejd��fd�
Z�xZS)�_HTTPTransportrN)r}r~r|r<c���|� |�ddl}|jj�}t�|�|i|��t||||�|j_y)Nr)�dns.asyncresolver�
asyncresolver�Resolverr8rrv�_pool�_network_backend)	rr}r~r|r<�args�kwargsr0r=s	        �rrz_HTTPTransport.__init__�sU�����$5�$=�(��,�,�5�5�7���G��d�-�f�-�*9��*�&7��+�D�J�J�'r)r)r*r+r9�	AF_UNSPECrrZr[s@rr�r��s!����"���#�#�
	�	rr�c�>�eZdZd�Z						dd�Zd�Zd�Zd�Zd�Zy)	�Backendc��y)Nrr
rs r�namezBackend.name�s��rNc	���K�t�}	|tjk(r[tr#|�!tj
j
|�df}|	jt||||���d{���\}
}t||
|�S|tjk(rQ|�td��ttj|d|d|||||��|��d{���\}}
t|||
�St!dd|��z��7��7�'�w)Nr)r<�proto�remote_addrz'destination required for stream sockets�)�sslr<r��
local_addr�server_hostnamezunsupported socket ztype )r
r9r:�	_is_win32r0r��
any_for_af�create_datagram_endpointrr6r_�
ValueErrorr4r�open_connectionr]rV)rrb�socktyper��sourcerBr-�ssl_contextr��looprr;�r�ws              r�make_socketzBackend.make_socket�s����!�"���v�(�(�(��V�^��(�(�-�-�b�1�1�5��(,�(E�(E�!����'�)F�)�#��I�x�"�"�i��:�:�
��+�+�
+��"�!�!J�K�K�*��'�'���N���N�#���%�$3�����F�Q�� ��A�q�)�)�!�!�e�H�:�$6�6�
�	
�5#���s%�A$C4�&C0�'A#C4�
C2�&C4�2C4c��JK�tj|��d{���y7��wr)rr�)r�intervals  rr�z
Backend.sleep	s�����m�m�H�%�%�%�r�c��y)NFr
rs r�datagram_connection_requiredz$Backend.datagram_connection_requireds��rc��tSr)r�rs r�get_transport_classzBackend.get_transport_classs���rc��6K�t||��d{���S7��wr)r4)rr3r-s   rr.zBackend.wait_fors����$�Y��8�8�8�8�s���)rNNNNN)	r)r*r+r�r�r�r�r�r.r
rrr�r��s5���������-
�^&���9rr�)%�__doc__rr9�sys�dns._asyncbackendr0�
dns._features�
dns.exception�dns.inet�platformr�r
rr4�
_asyncbackendr6r]�	_features�haver�r��httpcore._backends.anyio�httpx�AsyncNetworkBackend�_CoreAsyncNetworkBackend�	_backends�AnyIOStreamr��	dns.queryrrrsrtrv�AsyncHTTPTransportr��
NullTransportr�r
rr�<module>r�s��$��
�
������L�L�G�#�	�(���>� "�S�&�&�5�5� "�F6�3�$�$�1�1�6�4�=�=���e����#��'�;�;���)�)�/�/�;�;��R�R�3'�2�3'�j��1�1��*�&�&�4�4�N�=9�c���'�'�=9r
Back to Directory File Manager