Da

✏️ Editing: _asyncio_backend.cpython-310.pyc

������h!����������������������@���s����d�Z�ddlZddlZddlZddlZddlZejdkZdd��Z	G�dd��d�Z
dd	��ZG�d
d��dejj
�Z
G�dd
��d
ejj�ZG�dd��dejj�ZdS�)zasyncio library query support�����N�win32c�������������������C���s&���zt����W�S��ty���t�����Y�S�w��N)�asyncio�get_running_loop�AttributeError�get_event_loop��r���r����H/opt/plesk/python/3/lib/python3.10/site-packages/dns/_asyncio_backend.py�_get_running_loop���s
���
�r
���c�������������������@����<���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd	d
��Zdd��Zd
S�)�_DatagramProtocolc�����������������C���s���d�|�_�d�|�_d�S�r���)�	transport�recvfrom��selfr���r���r	����__init__���s���
z_DatagramProtocol.__init__c�����������������C���s
���||�_�d�S�r���)r
���)r���r
���r���r���r	����connection_made���s���
z!_DatagramProtocol.connection_madec�����������������C���s2���|�j�r|�j����s|�j��||f��d�|�_�d�S�d�S�d�S�r���)r����done�
set_result)r����data�addrr���r���r	����datagram_received���s���
�z#_DatagramProtocol.datagram_receivedc�����������������C����(���|�j�r|�j����s|�j��|��d�S�d�S�d�S�r����r���r����
set_exception�r����excr���r���r	����error_received#��������z _DatagramProtocol.error_receivedc�����������������C���r���r���r���r���r���r���r	����connection_lost'���r���z!_DatagramProtocol.connection_lostc�����������������C���s���|�j�����d�S�r���)r
����closer���r���r���r	���r ���+���s���z_DatagramProtocol.closeN)	�__name__�
__module__�__qualname__r���r���r���r���r���r ���r���r���r���r	���r������s����r���c���������������������sD����|rz
t��|�|�I�d�H�W�S��t�jy���tjj|d��w�|�I�d�H�S�)N)�timeout)r����wait_for�TimeoutError�dns�	exception�Timeout)�	awaitabler$���r���r���r	����_maybe_wait_for/���s�����
r+���c�������������������@���r���)�DatagramSocketc�����������������C�������||�_�||�_||�_d�S�r���)�familyr
����protocol)r���r.���r
���r/���r���r���r	���r���:�������
zDatagramSocket.__init__c���������������������s����|�j��||��d�S�r���)r
����sendto)r����what�destinationr$���r���r���r	���r1���?���s����zDatagramSocket.sendtoc���������������������s<����t������}|�jjd�u�sJ��||�j_t||�I�d�H��|���S�r���)r
����
create_futurer/���r���r+����result)r����sizer$���r���r���r���r	���r���C���s����
zDatagramSocket.recvfromc���������������������s����|�j�����d�S�r���)r/���r ���r���r���r���r	���r ���K���s����zDatagramSocket.closec��������������������������|�j��d�S��N�peername�r
����get_extra_infor���r���r���r	����getpeernameN��������zDatagramSocket.getpeernamec���������������������r7����N�socknamer:���r���r���r���r	����getsocknameQ���r=���zDatagramSocket.getsocknameN)	r!���r"���r#���r���r1���r���r ���r<���r@���r���r���r���r	���r,���9���s����r,���c�������������������@���r���)�StreamSocketc�����������������C���r-���r���)r.����reader�writer)r����afrB���rC���r���r���r	���r���V���r0���zStreamSocket.__init__c���������������������s$����|�j��|��t|�j����|�I�d�H�S�r���)rC����writer+����drain)r���r2���r$���r���r���r	����sendall[���s����zStreamSocket.sendallc���������������������s����t�|�j�|�|�I�d�H�S�r���)r+���rB����read)r���r6���r$���r���r���r	����recv_���s����
�zStreamSocket.recvc���������������������s8����|�j�����z|�j����I�d�H��W�d�S��ty���Y�d�S�w�r���)rC���r ����wait_closedr���r���r���r���r	���r ���c���s����
�zStreamSocket.closec���������������������r7���r8����rC���r;���r���r���r���r	���r<���j���r=���zStreamSocket.getpeernamec���������������������r7���r>���rK���r���r���r���r	���r@���m���r=���zStreamSocket.getsocknameN)	r!���r"���r#���r���rG���rI���r ���r<���r@���r���r���r���r	���rA���U���s����rA���c�������������������@���s4���e�Zd�Zdd��Z			ddd�Zdd��Zd	d
��ZdS�)�Backendc�����������������C���s���dS�)Nr���r���r���r���r���r	����namer�������zBackend.namer���Nc	��������������
�������s�����|d�u�r|t�jkrtrtd��t��}	|t�jkr-|	jt||||d�I�d�H�\}
}t||
|�S�|t�jkrPt	t
j|d�|d�|||||d�|�I�d�H�\}}
t|||
�S�tdd|������)NzHdestinationless datagram sockets are not supported by asyncio on Windows)r.����proto�remote_addrr�������)�sslr.���rO����
local_addr�server_hostnamezunsupported socket ztype )
�socket�
SOCK_DGRAM�	_is_win32�NotImplementedErrorr
����create_datagram_endpointr���r,����SOCK_STREAMr+���r����open_connectionrA���)r���rD����socktyperO����sourcer3���r$����ssl_contextrT����loopr
���r/����r�wr���r���r	����make_socketu���s8�����
�

��	�zBackend.make_socketc���������������������s����t��|�I�d�H��d�S�r���)r����sleep)r����intervalr���r���r	���rc�������s����z
Backend.sleepc�����������������C���s���t�S�r���)rW���r���r���r���r	����datagram_connection_required����rN���z$Backend.datagram_connection_required)r���NNNNN)r!���r"���r#���rM���rb���rc���re���r���r���r���r	���rL���q���s����
�rL���)�__doc__rU���r����sysZdns._asyncbackendr'���Z
dns.exception�platformrW���r
���r���r+���Z
_asyncbackendr,���rA���rL���r���r���r���r	����<module>���s���

📁 Sid Gifari File Manager