HEX
Server: Apache
System: Linux nc-ph-4101.simplemoneygoals.com 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64
User: dailygoldindex (1004)
PHP: 8.1.33
Disabled: NONE
Upload Files
File: //lib/python3.9/site-packages/dns/__pycache__/_asyncio_backend.cpython-39.pyc
a

�M�e#�@s"dZddlZddlZddlZddlZddlZddlZddlZej	dkZ
dd�ZGdd�d�Zdd	�Z
Gd
d�dejj�ZGdd
�d
ejj�Zej�d��rddlZddlZddlZddlZejZejjjZddlmZmZmZGdd�de�Z Gdd�dej!�Z"nejj#Z"Gdd�dejj$�Z$dS)zasyncio library query support�N�win32cCs*z
t��WSty$t��YS0dS�N)�asyncioZget_running_loop�AttributeErrorZget_event_loop�rr�8/usr/lib/python3.9/site-packages/dns/_asyncio_backend.py�_get_running_loops
rc@s<eZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)�_DatagramProtocolcCsd|_d|_dSr)�	transport�recvfrom��selfrrr�__init__sz_DatagramProtocol.__init__cCs
||_dSr)r
)r
r
rrr�connection_madesz!_DatagramProtocol.connection_madecCs$|jr |j��s |j�||f�dSr)r�doneZ
set_result)r
�dataZaddrrrr�datagram_received sz#_DatagramProtocol.datagram_receivedcCs |jr|j��s|j�|�dSr)rr�
set_exception)r
�excrrr�error_received$sz _DatagramProtocol.error_receivedc
Csd|jr`|j��s`|durTzt�Wq`tyP}z|j�|�WYd}~q`d}~00n|j�|�dSr)rr�EOFErrorr)r
r�errr�connection_lost(s$z!_DatagramProtocol.connection_lostcCs|j��dSr)r
�closerrrrr3sz_DatagramProtocol.closeN)	�__name__�
__module__�__qualname__rrrrrrrrrrr	sr	c�sP|durBzt�||�IdHWStjy>tjj|d��YqL0n
|IdHSdS)N)�timeout)r�wait_for�TimeoutError�dns�	exceptionZTimeout)�	awaitablerrrr�_maybe_wait_for7sr#csLeZdZ�fdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	�Z
S)�DatagramSocketcst��|�||_||_dSr)�superrr
�protocol)r
�familyr
r&��	__class__rrrBszDatagramSocket.__init__c�s|j�||�t|�Sr)r
�sendto�len)r
�what�destinationrrrrr*GszDatagramSocket.sendtoc�sTt���}z:|jjdusJ�||j_t||�IdH|��Wd|j_Sd|j_0dSr)rZ
create_futurer&rr#�result)r
�sizerrrrrrLs
�zDatagramSocket.recvfromc�s|j��dSr)r&rrrrrrWszDatagramSocket.closec�s|j�d�S�NZpeername�r
�get_extra_inforrrr�getpeernameZszDatagramSocket.getpeernamec�s|j�d�S�NZsocknamer1rrrr�getsockname]szDatagramSocket.getsocknamec�st�dSr��NotImplementedError�r
rrrr�getpeercert`szDatagramSocket.getpeercert)rrrrr*rrr3r5r9�
__classcell__rrr(rr$Asr$c@sDeZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dS)�StreamSocketcCs||_||_||_dSr)r'�reader�writer)r
�afr<r=rrrreszStreamSocket.__init__c�s"|j�|�t|j��|�IdHSr)r=�writer#Zdrain)r
r,rrrr�sendalljszStreamSocket.sendallc�st|j�|�|�IdHSr)r#r<�read)r
r/rrrr�recvnszStreamSocket.recvc�s|j��dSr)r=rrrrrrqszStreamSocket.closec�s|j�d�Sr0�r=r2rrrrr3tszStreamSocket.getpeernamec�s|j�d�Sr4rCrrrrr5wszStreamSocket.getsocknamec�s|j�d�S)NZpeercertrCr8rrrr9zszStreamSocket.getpeercertN)
rrrrr@rBrr3r5r9rrrrr;dsr;Zdoh)�_compute_times�_expiration_for_this_attempt�
_remainingcs8eZdZ�fdd�Zd
dd�Zddd�Zdd	�Z�ZS)�_NetworkBackendcs6t���||_||_||_||_|dkr2td��dS)Nrz9the asyncio transport for HTTPX cannot set the local port)r%rZ_local_port�	_resolver�_bootstrap_address�_familyr7)r
�resolver�
local_port�bootstrap_addressr'r(rrr�s
�z_NetworkBackend.__init__Nc	�sg}t|�\}}tj�|�r(|�|�nV|jdur@|�|j�n>t|�}|j}	|r^tj�|�}	|j	j
||	|d�IdH}
|
��}|D]x}z`td|�}t|�}t
�|��&t
j|||d�IdH}
Wd�n1s�0Yt|
�WSty�Yq�0q�tj�dS)N)r'Zlifetimeg@)Zremote_hostZremote_portZ
local_host)rDr �inetZ
is_address�appendrIrFrJZaf_for_addressrH�resolve_name�	addressesrE�anyioZ
fail_after�connect_tcp�_CoreAnyIOStream�	Exception�httpcoreZConnectError)r
�host�portrZ
local_address�socket_optionsrQ�_Z
expirationr'ZanswersZaddressZattempt_expiration�streamrrrrS�s8
�
�*z_NetworkBackend.connect_tcpc�st�dSrr6)r
�pathrrYrrr�connect_unix_socket�sz#_NetworkBackend.connect_unix_socketc�st�|�IdHdSr)rR�sleep)r
Zsecondsrrrr^�sz_NetworkBackend.sleep)N)N)rrrrrSr]r^r:rrr(rrG�s�
"�
rGcs*eZdZdddejd��fdd�
Z�ZS)�_HTTPTransportrN)rLrMrKr'csB|durddl}|j��}t�j|i|��t||||�|j_dS)Nr)Zdns.asyncresolverZ
asyncresolverZResolverr%rrGZ_poolZ_network_backend)r
rLrMrKr'�args�kwargsr r(rrr�s	
�z_HTTPTransport.__init__)rrr�socketZ	AF_UNSPECrr:rrr(rr_�s
�r_c@s>eZdZdd�Zddd�Zdd�Zd	d
�Zdd�Zd
d�ZdS)�BackendcCsdS)Nrrrrrr�name�szBackend.namerNc	
�s�t�}	|tjkrVtr,|dur,tj�|�df}|	jt||||d�IdH\}
}t	||
|�S|tj
kr�|durptd��tt
j|d|d|||||d�|�IdH\}}
t|||
�Stdd|����dS)Nr)r'�protoZremote_addrz'destination required for stream sockets�)Zsslr'reZ
local_addr�server_hostnamezunsupported socket ztype )rrbZ
SOCK_DGRAM�	_is_win32r rNZ
any_for_afZcreate_datagram_endpointr	r$ZSOCK_STREAM�
ValueErrorr#rZopen_connectionr;r7)r
r>Zsocktypere�sourcer-rZssl_contextrgZloopr
r&�r�wrrr�make_socket�s>
�
�	��zBackend.make_socketc�st�|�IdHdSr)rr^)r
�intervalrrrr^	sz
Backend.sleepcCsdS)NFrrrrr�datagram_connection_requiredsz$Backend.datagram_connection_requiredcCstSr)r_rrrr�get_transport_classszBackend.get_transport_classc�st||�IdHSr)r#)r
r"rrrrrszBackend.wait_for)rNNNNN)	rrrrdrmr^rorprrrrrrc�s�
/rc)%�__doc__rrb�sysZdns._asyncbackendr Z
dns._featuresZ
dns.exceptionZdns.inet�platformrhrr	r#Z
_asyncbackendr$r;Z	_featuresZhaverRrVZhttpcore._backends.anyioZhttpxZAsyncNetworkBackendZ_CoreAsyncNetworkBackendZ	_backendsZAnyIOStreamrTZ	dns.queryrDrErFrGZAsyncHTTPTransportr_Z
NullTransportrcrrrr�<module>s2

#
5